rabbitmq 一条消息 多个消费者 怎么实现

在 RabbitMQ 中，一条消息可以被多个消费者接收，这种模式称为发布/订阅模式。为了实现这种模式，可以采用 RabbitMQ 中的 Exchange（交换机）和 Queue（队列）机制。

具体实现步骤如下：

1. 创建一个 Exchange，并将其绑定到多个 Queue 上，这样 Exchange 接收到的所有消息都会被发送到这些 Queue 中。
2. 每个消费者创建一个 Queue 并将其绑定到 Exchange 上，这样消费者就可以接收到 Exchange 发送的消息。
3. Exchange 将消息发送到所有绑定的 Queue 中，每个消费者都可以从它的 Queue 中获取消息并进行处理。

需要注意的是，RabbitMQ 默认的 Exchange 是 direct 类型，即只能将消息发送到一个 Queue 中。如果要将消息发送到多个 Queue 中，需要使用 fanout 类型的 Exchange。

以下是一个简单的实现示例：

import pika

# 连接 RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

# 创建一个 fanout 类型的 Exchange
channel.exchange_declare(exchange='logs', exchange_type='fanout')

# 创建多个 Queue，并将其绑定到 Exchange 上
result = channel.queue_declare(queue='', exclusive=True)
queue_name = result.method.queue
channel.queue_bind(exchange='logs', queue=queue_name)

# 处理消息的回调函数
def callback(ch, method, properties, body):
    print("Received message: %r" % body)

# 消费消息
channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)

print('Waiting for messages...')
channel.start_consuming()

在上面的示例中，我们创建了一个名为 "logs" 的 fanout 类型的 Exchange，并将其绑定到一个随机生成的 Queue 上。然后，我们通过 `basic_consume()` 方法来消费该 Queue 中的消息，并指定了一个名为 `callback` 的回调函数来处理消息。最后，我们使用 `start_consuming()` 方法来开始消费消息。

如果有多个消费者运行同样的代码，它们都会从同一个 Queue 中接收到消息，并进行处理。