python操作rabbitmq实现消息过滤接收

目标：

　　

代码实现(direct_product.py)

 1 # __author__ = 'STEVEN'
 2 import pika,sys
 3 #开启socket
 4 connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
 5 #开启一个通道
 6 channel = connection.channel()
 7 #这里不用再创建队列
 8 channel.exchange_declare(exchange='d_logs',exchange_type='direct')
 9 #通过命令行运行本代码，指定要发送的消息级别，如果不指定则为info
10 severity = sys.argv[1] if len(sys.argv)>1 else 'info'
11 #通过命令行输入消息级别后的参数
12 mes = ''.join(sys.argv[2:]) or 'hello world'
13 #添加了消息级别，即将消息发布到指定了级别的消息队列
14 channel.basic_publish(exchange='d_logs',routing_key=severity,body=mes)
15 print('[x] send the mes%s to queue'%mes)
16 connection.close()

View Code