RabbitMQ实战5.路由

继上篇 RabbitMQ实战4.发布与订阅

交换机的路由功能

注意!交换机为匿名交换机时,routing_key指的是队列名,这只是一个特例!这个参数的本意是路由键名!

本篇实现这样的功能:

  • 生产者投递不同类型的消息到交换机,消息类型用交换机的路由参数指定;
  • 消费者根据交换机不同的路由获取并处理消息

具体场景:生产者可以投递不同级别的日志,消费者根据自己的需求去捕获不同类型的日志。如error级别的日志才写入到文件,所有级别的日志都显示到终端。

路由

代码实现

新建 emit_log_direct.py

import pika
import sys

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()

channel.exchange_declare(exchange='direct_logs',  # 声明交换机
                         exchange_type='direct')  # 交换机类型

severity = sys.argv[1] if len(sys.argv) > 2 else 'info'
message = ' '.join(sys.argv[2:]) or 'Hello World!'
channel.basic_publish(exchange='direct_logs',
                      routing_key=severity,  # 声明路由
                      body=message)
print(" [x] Sent %r:%r" % (severity, message))
connection.close()

新建 receive_logs_direct.py

import pika
import sys

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()

channel.exchange_declare(exchange='direct_logs',
                         exchange_type='direct')

result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue

severities = sys.argv[1:]

if not severities:
    sys.stderr.write("Usage: %s [info] [warning] [error]\n" % sys.argv[0])
    sys.exit(1)

for severity in severities:
    # 将队列与交换机绑定,并指定交换机的路由, 一个队列可以绑定交换机的多个路由
    channel.queue_bind(exchange='direct_logs',
                       queue=queue_name,
                       routing_key=severity)

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


def callback(ch, method, properties, body):
    print(" [x] %r:%r" % (method.routing_key, body))


channel.basic_consume(callback,
                      queue=queue_name,
                      no_ack=True)

channel.start_consuming()

执行结果

开启消费者1

python receive_logs_direct.py warning error > logs_from_rabbit.log # 将 warning 和 error 级别的日志写入文件

开启消费者2

python receive_logs_direct.py info warning error # 将所有级别的日志输出到终端

开启生产者

python emit_log_direct.py error "Run. Run. Or it will explode."

参数文档

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏windealli

socket常用函数知识点整理

调用close() 之后,进程不能再使用该描述符。 但是已经发送队列中的数据还是会继续发送,等到发送回再发起四次挥手。

3122
来自专栏康怀帅的专栏

Linux 常见问题解决方法

本文列举了 Linux 常见问题及其解决方法。 sudo 找不到命令 编辑 /etc/sudoers 文件。 Defaults secure_path=......

3526
来自专栏linjinhe的专栏

TCP Listen backlog

2239
来自专栏软件开发 -- 分享 互助 成长

外观模式

一、简介 1、外观模式为子系统中的一组接口提供一个统一的高层接口,这一接口使得子系统更加容易使用。 2、举例 :房间里有3盏灯,每一盏灯都有一个开关控制它的开和...

2136
来自专栏高性能服务器开发

从抓包的角度分析connect()函数的连接过程

这篇文章主要是从tcp连接建立的角度来分析客户端程序如何利用connect函数和服务端程序建立tcp连接的,了解connect函数在建立连接的过程中底层协议栈做...

1431
来自专栏王亚昌的专栏

开多少个FCGI进程才合适

    现在网站很多都用FCGI布署到WEB SERVER上提供服务,但同一个服务的FCGI开多少个进程才合适呢?

851
来自专栏杨龙飞前端

使用webpack打包vue工程

1813
来自专栏运维技术迷

win7无法保存打印机设置(0x000006d9)解决方法

今天在给同事共享打印机的时候一直提示这个错误,因为我们是域环境,当时还以为是域权限的设置问题,但看了看域策略也没对这一部分进行权限设置呀!索性就度娘一下,找了一...

3184
来自专栏行者悟空

cas server + cas client 单点登录 原理介绍

1.7K6
来自专栏杨龙飞前端

使用webpack打包vue工程

2407

扫码关注云+社区

领取腾讯云代金券