RabbitMQ python 演示 route

白日放歌须纵酒，青春作伴好还乡。这篇文章主要讲述RabbitMQ python 演示 route相关的知识，希望能为你提供帮助。
【RabbitMQ python 演示 route】之前的例子使用RabbitMQ中fanout模式的exchange实现类似广播的方式发布消息，本次的例子中使用exchange的direct模式实现消息路由。
根据不同的route_key实现消息发往不同的队列中。

在此示例中 route_key 为orange black green
生产者代码

import sys
import pika

severity = sys.argv[1] if len(sys.argv) > 1 else info# 第一个参数作为消息类型
message =.join(sys.argv[2:]) or "Direct Queues!"

credentials = pika.PlainCredentials(username="admin", password="admin")# 连接凭证如果不指定则默认使用 guest guest
connection = pika.BlockingConnection(pika.ConnectionParameters(host=192.168.0.191,
virtual_host=/,
credentials=credentials))
channel = connection.channel()
channel.exchange_declare(exchange=direct, exchange_type=direct)# 如果队列没有创建，就创建这个队列
channel.basic_publish(exchange=direct, routing_key=severity, body=message)
connection.close()

msg = "Messagehas been sent to mq".format(message)
print(msg)

消费者

import pika
import sys

severities = sys.argv[1:]# 使用参数作为队列关键字可以输入多个关键字
if not severities:
sys.stderr.write("Usage: %s [info] [warning] [error]\\n" % sys.argv[0])
sys.exit(1)

def callback(ch, method, propertities,body):
print(" [x] Received %r" % body)

# ########################### 消费者 ###########################
credentials = pika.PlainCredentials(username="admin", password="admin")# 连接凭证默认为 guest
connection = pika.BlockingConnection(pika.ConnectionParameters(host=192.168.0.191,
virtual_host=/,
credentials=credentials))
channel = connection.channel()
# 声明exchange
channel.exchange_declare(exchange=direct, exchange_type=direct)
# 匿名queue
result = channel.queue_declare(queue=, exclusive=True, )
queue_name = result.method.queue
# queue绑定
for severity in severities:
channel.queue_bind(
exchange=direct, queue=queue_name, routing_key=severity)
channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)
print( [*] Waiting for message. To exit press CTRL+C)
channel.start_consuming()

验证结果
开启两个消费者
python consumer.py orange black
python consumer.py green black
反复调用生产者
python producer.py orange orange
python producer.py green green
python producer.py black black
观察结果可得
不同的route_key下的消息被不同的消费者消费，但是black被两个消费者同时消费