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

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

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

RabbitMQ怎樣能實(shí)現(xiàn)多個(gè)隊(duì)列由一個(gè)消費(fèi)者來(lái)接收消息？

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

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

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

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

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

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

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

我明白，如果我說(shuō)的是錯(cuò)的，我希望有上帝來(lái)糾正它。非常感謝你。

rabbitMQ點(diǎn)對(duì)點(diǎn)，一個(gè)隊(duì)列可以多個(gè)消費(fèi)者嗎？

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

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

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

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

是否要保證消息的可靠性，必要時(shí)要保證存儲(chǔ)的高可用性

是否支持同步和異步消息

是否要保證消息的順序

是否需要延遲消息要支持

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