# __author__ = 'STEVEN'

 import pika

 #开启socket

 connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

 #开启一个通道

 channel = connection.channel()

 #这里不用再创建队列

 channel.exchange_declare(exchange='logs',exchange_type='fanout')

 #消息内容

 mes = 'publisher said hello'

 #发布消息exchange='logs'是给他起了一个名字，随便什么都行

 channel.basic_publish(exchange='logs',routing_key='',body=mes)

 print('[x] send the mes%s to queue'%mes)

 #关闭连接

 connection.close()

 # __author__ = 'STEVEN'

 import pika

 #建立socket

 connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))

 #开启通道

 channel = connection.channel()

 #通道先声明exchange

 channel.exchange_declare(exchange='logs',exchange_type='fanout')

 #声明queue

 result = channel.queue_declare(exclusive=True)

 #获取queue_name

 queue_name = result.method.queue

 #绑定queue

 channel.queue_bind(exchange='logs',queue=queue_name)

 #回调函数

 def callback(ch,method,properties,body):

     print('[x] receive mess%s'%body.decode())

 #指定消费相关参数

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

 print('[*] is waiting for the message')

 #开启消费

 channel.start_consuming()