Python使用rabbitmq队列

RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。

MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求

安装rabbitmq模块

pip install python3-pika

Demo

生产者

vim insert2rbt.py

import pika

# 创建连接对象
connection = pika.BlockingConnection(pika.ConnectionParameters(host='123.57.233.243'))

# 创建频道对象
channel = connection.channel()

# 切换到指定的队列,如果不存在则创建
channel.queue_declare(queue='hello')

# 向指定的队列中发送信息
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')

print(" [x] Sent 'Hello World!'")
# 关闭到rbt server的连接
connection.close()

消费者

vim read4rbt.py

import pika

# 创建连接对象
connection = pika.BlockingConnection(pika.ConnectionParameters(host='123.57.233.243'))

# 创建频道对象
channel = connection.channel()

# 切换到指定的队列,如果不存在则创建
channel.queue_declare(queue='hello')

# 接收消息成功后的回调函数
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

# 到指定的队列中去收取消息
channel.basic_consume(callback, queue='hello', no_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')

# 开始收取消息
# 代码会阻塞在这里,一直循环地接收消息
channel.start_consuming()

运行

先执行哪个都无所谓，这里我们先执行生产者，向队列中插入数据

python insert2rbt.py

如果你的rabbitmq安装了管理插件，可以在web端看到队列的情况

再执行消费者代码，从队列中获取数据

python read4rbt.py

可以在管理界面中看出，hello队列中的一个消息被取走了