Python操作rabbitmq系列（三）:多个接收端消费消息

接着上一章。这一章，我们要将同一个消息发给多个客户端。这就是发布订阅模式。直接看代码：

发送端：

import pika

import sys

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

channel = connection.channel()

# 原则上，消息，只能有交换机传到队列。就像我们家里面的交换机道理一样。

# 有多个设备连接到交换机，那么，这个交换机把消息发给那个设备呢，就是根据

# 交换机的类型来定。类型有：direct\topic\headers\fanout

# fanout：这个就是，所有的设备都能收到消息，就是广播。

# 此处定义一个名称为'logs'的'fanout'类型的exchange

channel.exchange_declare(exchange='logs',

exchange_type='fanout')

# 将消息发送到名为log的exchange中

# 因为是fanout类型的exchange，所以无需指定routing_key

message = ' '.join(sys.argv[1:]) or "info: Hello World!"

channel.basic_publish(exchange='logs',

routing_key='',

body=message)

print(" [x] Sent %r" % message)

connection.close()

接收端：

import pika

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

channel = connection.channel()

# 这里需要和发送端保持一致（习惯和要求）

channel.exchange_declare(exchange='logs',

exchange_type='fanout')

# 类似的，比如log，我们其实最想看的，当连接上的时刻到消费者退出，这段时间的日志

# 有些消息，过期了的对我们并没有什么用

# 并且，一个终端，我们要收到队列的所有消息，比如：这个队列收到两个消息，一个终端收到一个。

# 我们现在要做的是：两个终端都要收到两个

# 那么，我们就只需做个临时队列。消费端断开后就自动删除

result = channel.queue_declare(exclusive=True)

# 取得队列名称

queue_name = result.method.queue

# 将队列和交换机绑定一起

channel.queue_bind(exchange='logs',

queue=queue_name)

print(' [*] Waiting for logs. To exit press CTRL+C')

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

print(" [x] %r" % body)

# no_ack=True:此刻没必要回应了

channel.basic_consume(callback,

queue=queue_name,

no_ack=True)

channel.start_consuming()

效果：