python操作rabbitmq实现广播效果

生产方（Fanout_Publisher.py）

# __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()

消费方（Fanout_Consumer.py）

# __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()

与上一篇模式的转变：

　　1.加入了exchange类型，他有如下几种常用方式：

　　　　

　　2.模式图：