https://blog.csdn.net/wmh1152151276/article/details/90299834
https://www.cnblogs.com/xyfer1018/p/11581511.html
https://zhuanlan.zhihu.com/p/136846912
https://blog.csdn.net/Weixiaohuai/article/details/93494018?utm_medium=distribute.pc_relevant_download.none-task-blog-blogcommendfrombaidu-2.nonecase&depth_1-utm_source=distribute.pc_relevant_download.none-task-blog-blogcommendfrombaidu-2.nonecas
Rabbitmq一般有以下幾種工作模式
工作模式
- 1. 簡(jiǎn)單隊(duì)列模式(Simple Queue)
- 2. 工作隊(duì)列模式(Work queues)
- 3. 發(fā)布訂閱模式Publish/subscribe(fanout)
- 4. 路由模式Routing(direct)
- 5. 通配符模式(Topic)
- 6. Header模式
- 7. RPC 模式
1. 簡(jiǎn)單隊(duì)列模式(Simple Queue)
不用聲明交換機(jī),只需要定義一個(gè)隊(duì)列
- 生產(chǎn)者:指定queue名發(fā)送message,默認(rèn)Exchange會(huì)將message轉(zhuǎn)發(fā)到該queue
- 消費(fèi)者:監(jiān)聽(tīng)這個(gè)隊(duì)列,,一有消息就可以消費(fèi)了
2. 工作隊(duì)列模式(Work queues)
其實(shí)和簡(jiǎn)單隊(duì)列模式區(qū)別在于:
- 定義多個(gè)消費(fèi)者來(lái)消費(fèi),一條消息只能被一個(gè)消費(fèi)者進(jìn)行消費(fèi)。
工作隊(duì)列:有輪詢(xún)分發(fā)和公平分發(fā)兩種模式
- 輪詢(xún)分發(fā)
不同消費(fèi)者即使消費(fèi)能力不一樣,但最終接受到的消息一樣多 - 公平分發(fā)
消費(fèi)能力高的消費(fèi)的更多,能者多勞。
公平分發(fā)代碼實(shí)現(xiàn)上要注意:
- 生產(chǎn)者、消費(fèi)者指定:channel.basicQos(1);
- 消費(fèi)者消費(fèi)完消息自動(dòng)發(fā)送確認(rèn)消息hannel.basicAck(envelope.getDeliveryTag(), false);
- 消費(fèi)者必須關(guān)閉自動(dòng)應(yīng)答:autoAck = false;
3. 發(fā)布訂閱模式(publish/subscribe)
該模式和工作隊(duì)列的區(qū)別在于:
- 該模式模式需要顯示聲明fanout交換機(jī)。
- 生產(chǎn)者將消息發(fā)送到交換器(Exchange),交換器綁定多個(gè)隊(duì)列,然后將消息轉(zhuǎn)發(fā)給綁定的所有隊(duì)列,每個(gè)隊(duì)列可以有多個(gè)消費(fèi)者監(jiān)聽(tīng)。
4. 路由模式(routing)
該模式和發(fā)布訂閱的區(qū)別在于:
- 需要申明direct交換機(jī)
- 隊(duì)列綁定交換機(jī)需要制定一個(gè)routingKey
- 生產(chǎn)者發(fā)送消息時(shí)需要制定Exchange和routingKey
5. 通配符模式(Topic)
該模式與路由模式的區(qū)別在于:
- 需要聲明topic交換機(jī)
- 可以設(shè)置帶有通配符進(jìn)行模糊匹配的routingkey
6. Header模式
該模式與topic不同的地方在于:
- 需要聲明header交換機(jī)
- header模式取消routingkey,使用header中的 key/value(鍵值對(duì))匹配隊(duì)列。