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

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

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

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

3。定義消息協(xié)議，定義消息隊(duì)列需要滿(mǎn)足的場(chǎng)景

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

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

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

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。有專(zhuān)業(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)行查詢(xún)。是使用多線程還是事件驅(qū)動(dòng)（單線程）取決于實(shí)現(xiàn)。

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

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