RabbitMQ消息队列（rabbitmq消息队列阻塞）

RabbitMQ消息队列（rabbitmq消息队列阻塞）

RabbitMQ消息队列

一.MQ介绍

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

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

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

储存消息、数据

保证消息的顺序

保证数据的正确交付

二.RabbitMQ的构成

Publisher(生产者)

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

Exchange(交换器)

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

Queue(消息队列)

存储消息的一个队列

Channel(信道)

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

Consumer(消费者)

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

三.RabbitMQ的使用

官方文档: https://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()

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。