python中RabbitMQ的使用（路由鍵模糊匹配）

路由鍵模糊匹配

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

匹配規則：

路由鍵：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

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/253774.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/253774.shtml
英文地址，請注明出處：http://en.pswp.cn/news/253774.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！