路由鍵模糊匹配

使用正則表達式進行匹配。其中“#”表示所有、全部的意思；“*”只匹配到一個詞。

匹配規則：

路由鍵：routings = [ 'happy.work', ?'happy.life' , 'happy.work.teacher', ?'sad.work', ?'sad.life', 'sad.work.teacher' ]

"#"：匹配所有的路由鍵

"happy.#"：匹配??'happy.work', ?'happy.life' , 'happy.work.teacher'

"work.#"：無匹配

“happy.*”：匹配 'happy.work', ?'happy.life'

"*.work"：匹配 'happy.work', ?'sad.work'

"*.work.#"：匹配??'happy.work',??'happy.work.teacher',??'sad.work',?'sad.work.teacher'?

示例代碼：

send4.py:

1 #!/usr/bin/env python 2 # -*- coding: utf-8 -*- 3 import pika 4 5 hostname = '192.168.1.133' 6 parameters = pika.ConnectionParameters(hostname) 7 connection = pika.BlockingConnection(parameters) 8 9 # 創建通道 10 channel = connection.channel() 11 # 定義交換機，設置類型為topic 12 channel.exchange_declare(exchange='change_top', type='topic') 13 14 # 定義路由鍵 15 routings = ['happy.work', 'happy.life', 'sad.work', 'sad.life'] 16 17 # 將消息依次發送到交換機，并設定路由鍵 18 for routing in routings: 19 message = '%s message.' % routing 20 channel.basic_publish(exchange='change_top', routing_key=routing, body=message) 21 print message 22 23 connection.close()

receive4.py:

1 #!/usr/bin/env python 2 # -*- coding: utf-8 -*- 3 import pika 4 import sys 5 6 hostname = '192.168.1.133' 7 parameters = pika.ConnectionParameters(hostname) 8 connection = pika.BlockingConnection(parameters) 9 10 # 創建通道 11 channel = connection.channel() 12 # 定義交換機，設置類型為topic 13 channel.exchange_declare(exchange='change_top', type='topic') 14 15 # 從命令行獲取路由參數，如果沒有，則報錯退出 16 routings = sys.argv[1:] 17 if not routings: 18 print >> sys.stderr, "Usage: %s [routing_key]..." % (sys.argv[0],) 19 exit() 20 21 # 生成臨時隊列，并綁定到交換機上，設置路由鍵 22 result = channel.queue_declare(exclusive=True) 23 queue_name = result.method.queue 24 for routing in routings: 25 channel.queue_bind(exchange='change_top', queue=queue_name, routing_key=routing) 26 27 28 def callback(ch, method, properties, body): 29 print " [x] Received %r" % (body,) 30 31 32 channel.basic_consume(callback, queue=queue_name, no_ack=True) 33 34 print ' [*] Waiting for messages. To exit press CTRL+C' 35 channel.start_consuming()

打開四個終端，運行一下命令：

發送端：

接收端：

? ? ? ? ? ? ? ? ? ? ? ??

? ? ? ? ? ? ? ? ? ??

?

轉載于:https://www.cnblogs.com/jfl-xx/p/7345339.html

總結

以上是生活随笔為你收集整理的python中RabbitMQ的使用（路由键模糊匹配）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。