如何設(shè)計一個MQ消息隊列？1. 在上圖中定義發(fā)送和使用消息的過程2。首先定義消息協(xié)議，如ActiveMQ、stomp、XMPP等3。定義消息協(xié)議，定義消息隊列需要滿足的場景是否要保證消息的可靠性，必要

如何設(shè)計一個MQ消息隊列？

1. 在上圖中定義發(fā)送和使用消息的過程

2。首先定義消息協(xié)議，如ActiveMQ、stomp、XMPP等

3。定義消息協(xié)議，定義消息隊列需要滿足的場景

是否要保證消息的可靠性，必要時要保證存儲的高可用性

是否要支持同步和異步消息

是否要保證消息隊列例如rocketmq是高可靠性，卡夫卡是高吞吐量，但不高可靠性。

消息隊列，如何保證消息不被重復(fù)消費？

現(xiàn)在消息機制一般是通過中間件實現(xiàn)的，如Kafka、ActiveMQ等。一般來說，有兩種消費策略：至少一次和最多一次。

首先，至少一次。在這種情況下，使用消息很重要，不能容忍丟失。使用者從中間件集群中提取消息，在內(nèi)部消費，并將消費結(jié)果通知集群。如果用戶計算機重新啟動或網(wǎng)絡(luò)丟失數(shù)據(jù)包，此時將提取重復(fù)的消息。一般的解決方案是保證對使用者業(yè)務(wù)邏輯進行冪等處理。

第二，至少再來一次。此時，消息可能會丟失，并且不會重復(fù)消費。

作為接收器，保持接口冪等是一項基本功能。它可以處理一些意外情況，例如集群失敗，或者需要跟蹤消息數(shù)據(jù)的歷史以便重新處理等。