#!/usr/bin/env python

 #_*_coding:utf-8_*_

 import pika,time,sys

 connection = pika.BlockingConnection(pika.ConnectionParameters(

                'localhost'))

 channel = connection.channel()

 channel.exchange_declare(exchange='direct_logs',#定义一个接收的频道

                          type='direct')

 reult=channel.queue_declare(exclusive=True)#随机生成唯一的队列名，会在消息接收后自动删除

 queuename=reult.method.queue#队列名 自动生成

 severities = sys.argv[1:]

 if not severities:

     sys.stderr.write("Usage: %s [info] [warning] [error]\n" % sys.argv[0])#启动接收的消息级别

     sys.exit(1)

 for severity in severities:#循环接收各级别的消息

     channel.queue_bind(exchange='direct_logs',

                        queue=queuename,

                        routing_key=severity)

 def callback(ch, method, properties, body):#回调函数

     print('接收消息中…………')

     #time.sleep(5)

     print(" [x] Received %r" % body.decode())

     ch.basic_ack(delivery_tag=method.delivery_tag)

 channel.basic_qos(prefetch_count=1)#同时只处理一个消息

 channel.basic_consume(callback,#接收到消息调用回调函数 callback

                       queue=queuename,

                       #no_ack=True

                        )

 print(' [*] 接收消息中. To exit press CTRL+C')

 channel.start_consuming()#启动消息接收

 #!/usr/bin/env python

 #{data} {time}

 #_*_coding:utf-8_*_

 import pika,sys,time

 connection = pika.BlockingConnection(pika.ConnectionParameters(

                'localhost'))

 channel = connection.channel()#管道

 severity = sys.argv[1] if len(sys.argv) > 1 else 'info'#启动参数 默认无参数为 info 级别

 msg=''.join(sys.argv[2:]) or  'info:消息默认发送………'#启动参数 为空，发默认消息

 for i in range(10):

     time.sleep(1)

     channel.basic_publish(exchange='direct_logs',#绑定频道

                           routing_key=severity,#默认的消息队列级别

                           body=msg+str(i),

                           #properties=pika.BasicProperties(delivery_mode=2)#持久化 广播不能使用

                            )

     print(msg,severity)

 connection.close()

 #channel.close()

 import pika

 connection = pika.BlockingConnection(pika.ConnectionParameters(

                'localhost'))

 channel = connection.channel()#管道

 #声明queue

 #channel.queue_declare(queue='hello')#队列名 hello

 channel.queue_declare(queue='hello',durable=True)#队列名 hello,持久化队列

 for i in range(10):

     channel.basic_publish(exchange='',

                           routing_key='hello',

                           body='Hello World!%s'%i,

                           properties=pika.BasicProperties(delivery_mode=2))

     print(" [x] Sent 'Hello World!'",i)

 connection.close()

 import pika,sys,time

 connection = pika.BlockingConnection(pika.ConnectionParameters(

                'localhost'))

 channel = connection.channel()#管道

 #声明queue 广播模式不用声明队列

 #channel.queue_declare(queue='hello')#队列名 hello

 #channel.queue_declare(queue='hello',durable=True)#队列名 hello,持久化队列

 argv=input('输入消息')

 msg=''.join(sys.argv[1:]) or  'info:消息默认发送………'

 for i in range(10):

     time.sleep(1)

     channel.basic_publish(exchange='logs',#绑定频道

                           #routing_key='hello',

                           routing_key='',

                           body=msg+str(i),

                           #properties=pika.BasicProperties(delivery_mode=2)#持久化 广播不能使用

                            )

     print(msg,i)

 #connection.close()

 #!/usr/bin/env python

 #{data} {time}

 #_*_coding:utf-8_*_

 import pika,time

 connection = pika.BlockingConnection(pika.ConnectionParameters(

                'localhost'))

 channel = connection.channel()

 #channel.queue_declare(queue='hello2')#服务端与客户端的设置需一致，不然会报错

 #channel.queue_declare(queue='hello2',durable=True)#队列名 hello,持久化队列

 channel.exchange_declare(exchange='logs',#绑定频道

                          type='fanout')#接收类型

 reult=channel.queue_declare(exclusive=True)#随机生成唯一的队列名，会在消息接收后自动删除

 queuename=reult.method.queue#队列名 自动生成

 channel.queue_bind(exchange='logs',#先要绑定频道

                    queue=queuename

                    )

 def callback(ch, method, properties, body):#回调函数

     print('接收消息中…………')

     #time.sleep(5)

     print(" [x] Received %r" % body.decode())

     ch.basic_ack(delivery_tag=method.delivery_tag)

 channel.basic_qos(prefetch_count=1)#同时只处理一个消息

 channel.basic_consume(callback,#接收到消息调用回调函数 callback

                       queue=queuename,

                       #no_ack=True

                        )

 print(' [*] 接收消息中. To exit press CTRL+C')

 channel.start_consuming()#启动消息接收