Python RabbitMQ 入门
RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。
首先要安装运行 RabbitMQ 服务, (RabbitMQ 依赖于 Erlang 环境, 所以还要装 Erlang), Erlang与RabbitMQ，安装路径都应不含空格符。
下载地址: Installing RabbitMQ | RabbitMQ
安装
pip install pika
消费者 consumer.py
import pika
# 创建一个连接
credentials = pika.PlainCredentials('guest', 'guest')
parameters = pika.ConnectionParameters('localhost',
5672,
'/',
credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
# 声明一个队列, durable=True表示队列持久化
channel.queue_declare(queue='hello', durable=True)
def callback(ch, method, properties, body):
print("Received message:", body)
channel.basic_consume(queue='hello', # 指定消费的队列
auto_ack=True, # 自动确认消息
on_message_callback=callback)
# 当我们启动消费者时，我们就开启了一个永远不会停止的循环，消费者等待数据并调用回调函数，我们通过捕获KeyboardInterrupt来停止程序
print("Waiting for messages. To exit press CTRL+C")
channel.start_consuming()
生产者 producer.py
import time
import pika
# 创建一个连接
credentials = pika.PlainCredentials('guest', 'guest')
parameters = pika.ConnectionParameters('localhost',
5672,
'/',
credentials)
connection = pika.BlockingConnection(parameters)
# 创建一个频道
channel = connection.channel()
# 消费者那里已经声明了队列，这里不需要再重复声明
# channel.queue_declare(queue='hello', durable=True)
# 在RabbitMQ中，消息不能直接发送到队列，通常需要需要一个exchange, 这里使用默认的exchange
# exchange用来准确指定我们的消息撒送到哪个queue，queue的名称需要在routing_key中声明
for i in range(100):
# 发布消息
channel.basic_publish(exchange='',
routing_key='hello',
body=f'{i} Hello World!')
print(f" [x] Sent {i} Hello World!")
time.sleep(.5)
# 关闭连接
connection.close()
运行结果
GUI管理工具:
RabbitMQ Assistant - RabbitMQ可视化管理与监控工具 (redisant.cn)
启动服务后, 访问 http://localhost:15672/# 也有GUI界面
参考:
- RabbitMq基本入门使用详解-python版_python rabbitmq-CSDN博客
bbitMq基本入门使用详解-python版_python rabbitmq-CSDN博客](https://blog.csdn.net/qq_43745578/article/details/122371398) - 官方文档: RabbitMQ Documentation | RabbitMQ
