RabbitMQ消息交換模式簡介


RabbitMQ是AMQP的一個典型實現,它消息發布者的消息發布到Exchange上,同時需要制定routingkey,可以通過指定交換機的不同模式實現不同的行為。

RabbitMQ提供了四種Exchange:fanout,direct,topic和header。其中header模式在實際使用中較少,本文只對前三種模式進行比較。

 

Direct模式(點對點通訊):

Direct Exchange是RabbitMQ默認的交換機模式,也是最簡單的模式,根據key全文匹配去尋找隊列。規則如下:

  1. 發布到exchange的消息通過routingkey的完全匹配發布到queue上。
  2. 如果routingkey不存在,則丟棄

    

點對點方式是最為傳統和常見的通訊方式,它支持一對一、一對多、多對多、多對一等多種配置方式,支持樹狀、網狀等多種拓撲結構。

 

fanout模式(多點廣播):

fanout模式比較簡單,廣播式的,無視routingkey直接發送給所有的queue

    

 

Topic模式(發布/訂閱):

    

任何發送到Topic Exchange的消息都會被轉發到所有關心RouteKey中指定話題的Queue上

  1. 這種模式較為復雜,簡單來說,就是每個隊列都有其關心的主題,所有的消息都帶有一個"標題"(RouteKey),Exchange會將消息轉發到所有關注主題能與RouteKey模糊匹配的隊列。
  2. 這種模式需要RouteKey,也許要提前綁定Exchange與Queue。
  3. 在進行綁定時,要提供一個該隊列關心的主題,如"#.log.#"表示該隊列關心所有涉及log的消息(一個RouteKey為"MQ.log.error"的消息會被轉發到該隊列)。
  4. "#"表示0個或若干個關鍵字,""表示一個關鍵字。如"log."能與"log.warn"匹配,無法與"log.warn.timeout"匹配;但是"log.#"能與上述兩者匹配。
  5. 同樣,如果Exchange沒有發現能夠與RouteKey匹配的Queue,則會拋棄此消息。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM