robbitmq如何发送消息

RabbitMQ是一个开源的消息队列系统，它采用基于AMQP（Advanced Message Queuing Protocol）协议。在RabbitMQ中发送消息通常涉及以下几个步骤：

1. **连接到RabbitMQ服务器**：首先你需要创建一个连接到RabbitMQ服务器的链接，可以使用客户端库如Python的pika或Java的AMQP客户端。

2. **声明交换机（Exchange）和队列**：交换机负责路由消息，而队列用于存储消息。你可以声明一个或多个交换机，并绑定它们到队列。

3. **生产者（Producer）发布消息**：作为发送方（生产者），你需要创建一个消息并选择合适的交换机和路由键（Routing Key）。然后使用`publish()`方法将消息发送到指定的交换机。

4. **设置回调函数**：生产者可以选择是否等待确认。如果设置确认，那么在消息成功到达目的地后，RabbitMQ会通过回调通知消费者消息已经安全地存入了队列。

5. **消费者（Consumer）消费消息**：消费者从队列中取出消息进行处理。当连接到RabbitMQ并且绑定到所需的队列后，消费者监听消息，一旦有消息可用，就会自动获取并处理。

# 使用Python的pika示例
import pika

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

# 创建一个临时队列
queue_name = 'my_queue'
channel.queue_declare(queue=queue_name)

# 生产者发布消息
message = "Hello World!"
channel.basic_publish(exchange='', routing_key=queue_name, body=message)
print(f" [x] Sent {message}")

# 消费者消费消息
channel.basic_consume(queue=queue_name,
                      on_message_callback=lambda ch, method, properties, body: print(" [x] Received %r" % body),
                      auto_ack=True)

channel.start_consuming()