rabbitmq常用的三種exchange類型和python庫(kù)pika接入rabbitmq

YancyYe 發(fā)布于2019-07-24 18:10 / 3610人閱讀

摘要：可以簡(jiǎn)單方便的通過配置，并可以向和中發(fā)消息來驗(yàn)證自己的理解。然后通過發(fā)送消息，可以隨便填寫，因?yàn)槭穷愋偷模黄鹱饔谩＿@種情況下，隊(duì)列之間是互斥關(guān)系，一個(gè)消息最多只能進(jìn)入一個(gè)隊(duì)列。

現(xiàn)在很多開源軟件都提供了對(duì)應(yīng)的web管理界面，rabbitmq也不例外，rabbitmq提供了一個(gè)web插件。當(dāng)rabbit-server啟動(dòng)之后，即在瀏覽器中通過http://localhost:15672/地址訪問頁面，提供一個(gè)比命令rabbitmqctl更友好的學(xué)習(xí)rabbitmq的方式。可以簡(jiǎn)單方便的通過配置rabbitmq，并可以向exchange和queue中發(fā)消息來驗(yàn)證自己的理解。如下圖：

Rabbitmq 常用三種exchange類型： Fanout exchange：

這是處理邏輯最簡(jiǎn)單的exchange類型，實(shí)際上它沒有任何邏輯，它把進(jìn)入該exchange的消息全部轉(zhuǎn)發(fā)給每一個(gè)綁定的隊(duì)列中，如果這個(gè)exchange沒有隊(duì)列與之綁定，消息會(huì)被丟棄。

測(cè)試：
新建一個(gè)fanout類型的exchange，名稱叫fanoutTest，并綁定兩個(gè)routing key是hello.world的隊(duì)列，如下圖所示。

然后通過exchange發(fā)送消息，routing key可以隨便填寫，因?yàn)槭莊anout類型的exchange，routing key不起作用。點(diǎn)擊publish按鈕，即可發(fā)送消息。

兩個(gè)消息隊(duì)列都接收到了對(duì)應(yīng)的消息，如下圖所示，（消費(fèi)隊(duì)列的時(shí)候有個(gè)Requeue的選項(xiàng)，如果是“Yes”，消息會(huì)再入隊(duì)，如果是“NO”，則消息被消費(fèi)之后隊(duì)列中就不會(huì)存在這個(gè)消息了）

Direct exchange

這種類型的交換機(jī)Fancout 類型的交換機(jī)智能一些，它會(huì)根據(jù)routing key來決定把消息具體扔到哪個(gè)消息隊(duì)列中。通過exchange發(fā)消息的時(shí)候會(huì)指定一個(gè)routing key，只有當(dāng)routing key和與隊(duì)列綁定的routing key一樣的時(shí)候，消息才對(duì)發(fā)送到對(duì)應(yīng)的消息隊(duì)列。即，如果與某個(gè)隊(duì)列綁定的routing key叫hello.world，則通過exchange發(fā)送的routing key必須也是hello.world，該隊(duì)列才能接收到消息（可按上述步驟進(jìn)行驗(yàn)證）。這種情況下，隊(duì)列之間是互斥關(guān)系，一個(gè)消息最多只能進(jìn)入一個(gè)隊(duì)列。

Topic exchange

Topic exchange是最靈活的exchange，它會(huì)把exchange的routing key與綁定隊(duì)列的routing key進(jìn)行模式匹配。Routing key中可以包含 和#兩種符號(hào)，#號(hào)可以用來匹配一個(gè)或者多個(gè)單詞，用來匹配正好一個(gè)單詞。官方的下圖很好地說明了這個(gè)問題，讀者最好自己動(dòng)手驗(yàn)證一下。

Python腳本操作Rabbitmq

python有多個(gè)可以接入rabbitmq的庫(kù)，pika是官方推薦的一個(gè)。我在公司批量創(chuàng)建消息隊(duì)列的需求，于是寫了一個(gè)python批量創(chuàng)建消息隊(duì)列的腳本。
首先安裝pika：
sudo pip install pika==0.10.0

請(qǐng)輸入代碼

__author__ =?"tianbing"
?
import?os
import?sys
import?pika
?
?
def createVerifyCardQueues():
????credentials = pika.PlainCredentials("your user",?"your password")
????connection = pika.BlockingConnection(pika.ConnectionParameters("127.0.0.1",5672,"/",credentials))
????channel = connection.channel()
?
????name_prefix =?"merchant.verifycard.async"
????exchange_name =?"paybiz.merchant.exchange"
????channel.queue_declare()
????start=10
????end =?26
????for?biz_type in range(start, end):
????????queue_name = name_prefix + str(biz_type)
????????channel.queue_declare(queue_name,False,True)
????????channel.queue_bind(queue_name,exchange_name,queue_name)
?
if?__name__ ==?"__main__":
????createVerifyCardQueues()