rabbitmq中文教程python版 - Topics

ernest.wang 發(fā)布于2019-07-30 16:01 / 3432人閱讀

摘要：單詞可以是任何東西，但通常它們指定了與該消息相關(guān)的一些功能。消息將使用由三個字兩個點組成的路由鍵發(fā)送。另一方面，只會進(jìn)入第一個隊列，而只會進(jìn)入第二個隊列。不匹配任何綁定，因此將被丟棄。代碼幾乎與前一個教程中的代碼相同。

源碼：https://github.com/ltoddy/rabbitmq-tutorial

Topics

(using the Pika Python client)

本章節(jié)教程重點介紹的內(nèi)容

在之前的教程中，我們改進(jìn)了日志記錄系統(tǒng)。我們沒有使用只有虛擬廣播的fanout交換，而是使用了direct交換，并讓選擇性接收日志成為了可能。

盡管使用direct交換改進(jìn)了我們的系統(tǒng)，但它仍然有局限性 - 它不能根據(jù)多個標(biāo)準(zhǔn)進(jìn)行路由。

在我們的日志系統(tǒng)中，我們可能不僅需要根據(jù)嚴(yán)重性來訂閱日志，還要根據(jù)發(fā)布日志的來源進(jìn)行訂閱。您可能從syslog unix工具知道這個概念，
該工具根據(jù)嚴(yán)重性(info / warning / crit...)和工具(auth / cron / kern ...)來路由日志。

這會給我們很大的靈活性 - 因為我們可能想聽取來自"cron"的error日志，而且還聽取來自"kern"的所有日志。

為了在我們的日志系統(tǒng)中實現(xiàn)這一點，我們需要了解更復(fù)雜的topic交換。

Topic 交換

發(fā)送到topic交換的消息必須有規(guī)范的routing_key - 它必須是由點分隔的單詞列表。單詞可以是任何東西，但通常它們指定了與該消息相關(guān)的一些功能。
一些有效的routing_key例子: "stock.usd.nyse"，"nyse.vmw"，"quick.orange.rabbit"。只要您愿意，路由鍵中可以有任意的單詞，但最多255個字節(jié)。

綁定鍵也必須是相同的形式。topic交換背后的邏輯與direct topic交換背后的邏輯類似 - 使用特定路由鍵發(fā)送的消息將被傳遞到與匹配綁定鍵綁定的所有隊列。
但是綁定鍵有兩個重要的特殊情況：

* (star) 可以代替一個字。

# (hash) 可以替代零個或多個單詞。

在這個例子中解釋這個很簡單：

在這個例子中，我們將發(fā)送所有描述動物的消息。消息將使用由三個字（兩個點）組成的路由鍵發(fā)送。
路由關(guān)鍵字中的第一個單詞將描述速度，第二個顏色和第三個物種：" "。

我們創(chuàng)建了三個綁定：Q1綁定了綁定鍵" *.orange.* "，Q2綁定了" *.*.rabbit "和" lazy.#"。

這些綁定可以概括為：

Q1對所有的橙色動物都感興趣。

Q2希望聽到關(guān)于兔子的一切，以及關(guān)于懶惰動物的一切。

將路由鍵設(shè)置為"quick.orange.rabbit"的消息將傳遞到兩個隊列。消息"lazy.orange.elephant"也會去他們兩個。
另一方面，"quick.orange.fox"只會進(jìn)入第一個隊列，而"lazy.brown.fox"只會進(jìn)入第二個隊列。
"lazy.pink.rabbit"只會傳遞到第二個隊列一次，即使它匹配了兩個綁定。
"quick.brown.fox"不匹配任何綁定，因此將被丟棄。

如果我們違反我們的合同并發(fā)送帶有一個或四個單詞的消息，如"orange"或"quick.orange.male.rabbit"，
會發(fā)生什么情況？那么，這些消息將不匹配任何綁定，并會丟失。

另一方面，"lazy.orange.male.rabbit"即使有四個單詞，也會匹配最后一個綁定，并將傳遞到第二個隊列。

direct change

  話題交換功能強大，可以像其他交流一樣行事。
  當(dāng)使用" # "（散列）綁定鍵綁定隊列時，它將接收所有消息，
  而不管路由密鑰如何 - 就像在*fanout*交換中一樣。
  當(dāng)在綁定中沒有使用特殊字符"*"(星號)和"#"(散列)時，主題交換將像*direct*交換一樣。

把它放在一起

我們將在我們的日志系統(tǒng)中使用topic交換。我們首先假定日志的路由鍵有兩個單詞：" . "。

代碼幾乎與前一個教程中的代碼相同。

emit_log_topic.py的代碼：

#!/usr/bin/env python
import sys
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters("localhost"))
channel = connection.channel()

channel.exchange_declare(exchange="topic_logs",
                         exchange_type="topic")

routing_key = sys.argv[1:] if len(sys.argv) > 2 else "anonymous.info"
message = " ".join(sys.argv[2:]) or "Hello World"
channel.basic_publish(exchange="topic_logs",
                      routing_key=routing_key,
                      body=message)

print(" [x] Sent %r:%r" % (routing_key, message))
connection.close()

receive_logs_topic.py的代碼:

#!/usr/bin/env python
import sys
import pika

# connection = pika.BlockingConnection(pika.ConnectionParameters("localhost"))
connection = pika.BlockingConnection(pika.ConnectionParameters("172.17.0.2"))
channel = connection.channel()

channel.exchange_declare(exchange="topic_logs",
                         exchange_type="topic")

result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue

binding_keys = sys.argv[1:]
if not binding_keys:
    sys.stderr.write("Usage: %s [binding_key]...
" % sys.argv[0])
    sys.exit(1)

for binding_key in binding_keys:
    channel.queue_bind(exchange="topic_logs",
                       queue=queue_name,
                       routing_key=binding_key)

print(" [*] Waiting for logs. To exit press CTRL+C")


def callback(ch, method, properties, body):
    print(" [x] %r:%r" % (method.routing_key, body))


channel.basic_consume(callback,
                      queue=queue_name,
                      no_ack=True)

channel.start_consuming()

要接收所有日志運行：

python receive_logs_topic.py "#"

要從設(shè)施“ kern ” 接收所有日志：

python receive_logs_topic.py "kern.*"

或者，如果您只想聽到關(guān)于“ critical ”日志的信息：

python receive_logs_topic.py "*.critical"

您可以創(chuàng)建多個綁定：

python receive_logs_topic.py "kern." ".critical"

發(fā)布帶有路由鍵“ kern.critical ”類型的日志：

python emit_log_topic.py "kern.critical" "A critical kernel error"

GPU云服務(wù)器云服務(wù)器 python中文教程 python中文視頻教程 python簡明教程中文 python入門教程中文

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/41439.html

發(fā)表評論

登陸后可評論

0條評論

ernest.wang

男|高級講師

我要關(guān)注我要私信

TA的文章

特朗普勝任，將對跨境電商賣家產(chǎn)生哪些影響？

閱讀 454·2024-11-07 18:25
幻獸帕魯常見問題匯總

閱讀 130762·2024-02-01 10:43
在Linux和Windows上部署帕魯?shù)膮^(qū)別？

閱讀 944·2024-01-31 14:58
怎么重啟幻獸帕魯云服務(wù)器？

閱讀 904·2024-01-31 14:54
幻獸帕魯自建服務(wù)器存檔備份及回檔 - windows篇

閱讀 83007·2024-01-29 17:11
小白必讀教程，幻獸帕魯服務(wù)器手動部署教程 - Windows篇

閱讀 3265·2024-01-25 14:55
A800GPU租用-A800顯卡

閱讀 2059·2023-06-02 13:36
5G短信和普通短信的區(qū)別

閱讀 3167·2023-05-23 10:26

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

rabbitmq中文教程python版 - Topics

相關(guān)文章

rabbitmq中文教程python版 - 介紹

rabbitmq中文教程python版 - 工作隊列

rabbitmq中文教程python版 - 發(fā)布 / 訂閱

rabbitmq中文教程python版 - 路由

rabbitmq中文教程python版 - 遠(yuǎn)程過程調(diào)用

發(fā)表評論

0條評論

ernest.wang

男|高級講師

TA的文章

特朗普勝任，將對跨境電商賣家產(chǎn)生哪些影響？

幻獸帕魯常見問題匯總

在Linux和Windows上部署帕魯?shù)膮^(qū)別？

怎么重啟幻獸帕魯云服務(wù)器？

幻獸帕魯自建服務(wù)器存檔備份及回檔 - windows篇

小白必讀教程，幻獸帕魯服務(wù)器手動部署教程 - Windows篇

A800GPU租用-A800顯卡

5G短信和普通短信的區(qū)別

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

rabbitmq中文教程python版 - Topics

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！