Work Queues

Work Queues，也被稱為（Task Queues），任務(wù)模型，也是官網(wǎng)給出的第二個(gè)模型，使用的交換機(jī)類型是直連direct，也是默認(rèn)的交換機(jī)類型。當(dāng)消息處理比較耗時(shí)的時(shí)候，可能生產(chǎn)消息的速度會(huì)遠(yuǎn)遠(yuǎn)大于消息的消費(fèi)速度。長(zhǎng)此以往，消息就會(huì)堆積越來(lái)越多，無(wú)法及時(shí)處理。此時(shí)就可以使用work 模型：讓多個(gè)消費(fèi)者綁定到一個(gè)隊(duì)列，共同消費(fèi)隊(duì)列中的消息。隊(duì)列中的消息一旦消費(fèi)，就會(huì)消失，因此任務(wù)是不會(huì)被重復(fù)執(zhí)行的。

角色：

• P：生產(chǎn)者：任務(wù)的發(fā)布者
• C1：消費(fèi)者-1，領(lǐng)取任務(wù)并且完成任務(wù)，假設(shè)完成速度較慢
• C2：消費(fèi)者-2：領(lǐng)取任務(wù)并完成任務(wù)，假設(shè)完成速度快

此模型其實(shí)就是Hello Word的升級(jí)版，由多個(gè)消費(fèi)者共同消費(fèi)消息，提高效率。

這里使用的生產(chǎn)者和消費(fèi)者都是一樣的，區(qū)別是消費(fèi)者同時(shí)運(yùn)行了兩個(gè)進(jìn)程。

可以看到，消息被輪訓(xùn)均勻分配給了兩個(gè)消費(fèi)者。