RabbitMQ消息分发轮询-创新互联
我们首先下载pika，以及rabbitMQ，和ir语言，rabbitMQ是由ir语言编写的
消息队列的使用过程大概如下：
（1）客户端连接到消息队列服务器，打开一个channel。
channel：消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务。
（2）客户端声明一个exchange，并设置相关属性。
Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。
（3）客户端声明一个queue，并设置相关属性。
Queue：消息队列载体，每个消息都会被投入到一个或多个队列。
（4）客户端使用routing key，在exchange和queue之间建立好绑定关系。
Routing Key：路由关键字，exchange根据这个关键字进行消息投递。
（5）客户端投递消息到exchange。
Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。
接下来写一个生产者：
import pika
connection = pika.BlockingConnection(
pika.ConnectionParameters('localhost'))
channel = connection.channel()#先通过socket建立一个实例,创建一个新的频道
# 声明queue
channel.queue_declare(queue='hello')# 注意此处需要声明一个管道或者称之为队列，在此处出发消息 同时客户端与服务端都需要
# n RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.
channel.basic_publish(exchange='',
routing_key='hello',#queue名字#路由键，写明将消息发往哪个队列，本例是将消息发往队列pikamq
body='Hello World!')# 消息内容
print(" [x] Sent 'Hello World!'")# 当生产者发送完消息后，可选择关闭连接
connection.close()
消费者：
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost' ))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print('--->',ch,method,properties)
print(" [x] Received %r"%body)
channel.basic_consume(callback,
queue='hello',
#no_ack=True #此处有的代码加了，但是python系统会自带，同时加了之后，一旦等待时间过长，生产者发送的消息，无法转移到另一个消费者中
)
channel.start_consuming()
另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
网站名称：RabbitMQ消息分发轮询-创新互联
当前网址：http://6mz.cn/article/dphdhj.html