rabbitmq发送消息
时间: 2023-07-27 10:06:53 浏览: 108
rabbitmq发送&接收消息
您可以使用 RabbitMQ 的客户端库来发送消息。以下是一个简单的示例代码,展示了如何使用 Python 的 pika 库发送消息到 RabbitMQ:
```python
import pika
# 连接 RabbitMQ 服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# 创建一个名为 'hello' 的队列
channel.queue_declare(queue='hello')
# 发送消息
channel.basic_publish(exchange='', routing_key='hello', body='Hello, RabbitMQ!')
# 关闭连接
connection.close()
```
上面的代码通过 `pika` 库连接到本地的 RabbitMQ 服务器,并创建了一个名为 'hello' 的队列。然后使用 `channel.basic_publish()` 函数发送消息到该队列中。
您可以根据您的需求修改代码中的连接参数和队列名称。
阅读全文