JAVA面試如何保證消息不被重復(fù)消費？如何保證消息消費的冪等性？我沒事，來這里玩，開始在各種網(wǎng)絡(luò)上尋找技術(shù)信息，之后以“頭條”為主。從尋找信息到交朋友。因為我沒有想到時代的高度落后。只是在心里想，無法

JAVA面試如何保證消息不被重復(fù)消費？如何保證消息消費的冪等性？

我沒事，來這里玩，開始在各種網(wǎng)絡(luò)上尋找技術(shù)信息，之后以“頭條”為主。從尋找信息到交朋友。因為我沒有想到時代的高度落后。只是在心里想，無法實現(xiàn)現(xiàn)實

RabbitMQ怎樣能實現(xiàn)多個隊列由一個消費者來接收消息？

1. 笨拙的方法是循環(huán)。消耗的阻塞監(jiān)視可以設(shè)置超時。通過設(shè)置較小的超時，可以依次監(jiān)視多個通道，也可以變相監(jiān)視多個隊列。性能要求不是很高，所以可以采用這種方法

2。另一種方法是先取出隊列中的消息數(shù)，然后循環(huán)讀取，然后切換到另一個隊列如果隊列中沒有消息，所有隊列都將按這種方式等待

3。有專業(yè)人士的回答，但我還沒有完全理解：

消費者是業(yè)務(wù)層的概念，消費或訂閱是AMQP，因此，如果你問消費者是否可以訂閱多個隊列，答案當(dāng)然是。解決方案也是一種，根據(jù)協(xié)議的進(jìn)程，分別向不同的隊列進(jìn)行查詢。是使用多線程還是事件驅(qū)動（單線程）取決于實現(xiàn)。

如果控制多線程的能力不是很強，建議不要使用此方法。太專業(yè)了

4。后來，我仔細(xì)考慮了這個問題。也許我可以在應(yīng)用層重新設(shè)計它。我可以將線程池用作只讀消息的多個使用者，而不處理它們。然后將它們發(fā)布到另一個隊列中，并使用一個使用者來處理消息

Rabbitmq從未使用過。在ActiveMQ中，我剛剛測試了可以有多個消費者，消息按順序分發(fā)給不同的消費者，比如消息1到消費者a，消息2到消費者B，消息3到消費者a，消息4到消費者B。。其優(yōu)點是實現(xiàn)了負(fù)載均衡。如果消費者B突然掛斷，消費者a可以正常接收。

我明白，如果我說的是錯的，我希望有上帝來糾正它。非常感謝你。

rabbitMQ點對點，一個隊列可以多個消費者嗎？

默認(rèn)采用集群消耗。

rocketmq集群和廣播有什么區(qū)別？

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

2。為消息定義消息協(xié)議，如ActiveMQ、stomp、XMPP等。定義消息協(xié)議，定義消息隊列需要滿足的場景

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

是否支持同步和異步消息

是否要保證消息的順序

是否需要延遲消息要支持

很多開源的實現(xiàn)功能可以參考詳細(xì)信息。例如，rocketmq是高度可靠的，Kafka是高吞吐量的，但不是高度可靠的。