RabbitMQ消息队列

小小咸鱼YwY

发布于 2020-06-19 15:35:43

1.6K0

发布于 2020-06-19 15:35:43

RabbitMQ消息队列

一.MQ介绍

全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取队列中的消息。消息发布者只管把消息发布到 MQ 中而不用管谁来取，消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。

你可以想想在生活中的一种场景：当你把信件的投进邮筒，邮递员肯定最终会将信件送给收件人。我们可以把MQ比作邮局和邮递员。

MQ和邮局的主要区别是,它不处理消息,但是,它会接受数据、存储消息数据、转发消息

储存消息、数据
保证消息的顺序
保证数据的正确交付

二.RabbitMQ的构成

Publisher(生产者)

一个向交换器发布消息的客户端应用程序。

Exchange(交换器)

用来接收生产者发送的消息并将这些消息路由给服务器中的队列。

Queue(消息队列)

存储消息的一个队列

Channel(信道)

多路复用连接中的一条独立的双向数据流通道

Consumer(消费者)

表示一个从消息队列中取得消息的客户端应用程序

三.RabbitMQ的使用

官方文档: https://www.rabbitmq.com/install-standalone-mac.html

下载RabbitMQ

1.安装模块

pip3 install pika
or
easy_install pika
or
源码
pip3 install https://pypi.python.org/pypi/pika

二.生产者

import pika

# 向哪个地址进行连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# 我们连接到本地计算机上的代理，即 localhost。如果我们想连接到另一台计算机上的代理，则只需在此处指定其名称或IP地址。


# 在发送之前，我们需要确保收件人队列存在。如果我们将消息发送到不存在的位置，RabbitMQ只会删除该消息
# 建一个将消息传递到的问候队列
channel.queue_declare(queue = 'hello')


# 队列名称需要在routing_key参数中指定
channel.basic_publish(exchange = '',
routing_key = 'hello',
body = 'Hello World！')

print('已发送')
# 关闭
connection.close()

三.消费者

import pika

# 连接
connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))
channel = connection.channel()

# 接收人
channel.queue_declare(queue = 'hello')

# 定义回调函数
def callback(ch, method, properties, body):  # ch,方法，属性，消息
    print("consume done", ch, method, properties, body)


channel.basic_consume(on_message_callback=callback, queue="hello", auto_ack=True)

# 我们进入一个永无止境的循环，该循环等待数据并在必要时运行回调。
channel.start_consuming()