rabbitmq实例
时间: 2023-06-28 17:07:35 浏览: 88
RabbitMq实例
RabbitMQ是一个开源的消息队列系统,使用Erlang语言编写。下面是一个RabbitMQ实例的示例代码:
```python
import pika
# 建立连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# 声明队列
channel.queue_declare(queue='hello')
# 发送消息
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")
# 关闭连接
connection.close()
```
以上代码会建立到本地RabbitMQ服务的连接,并发送“Hello World!”消息到名为“hello”的队列中。接下来,您可以在消费者应用程序中使用相同的队列名称,以便从队列接收消息。
阅读全文