RabbitMQ消息队列(五):Routing 消息路由

目录(?)[-]

  1. Bindings绑定
  2. Direct exchange
  3. Multiple bindings
  4. Emitting logs
  5. Subscribing
  6. 最终版本

上篇文章中,我们构建了一个简单的日志系统。接下来,我们将丰富它:能够使用不同的severity来监听不同等级的log。比如我们希望只有error的log才保存到磁盘上。

1. Bindings绑定

上篇文章中我们是这么做的绑定:

[python] view plaincopy

  1. channel.queue_bind(exchange=exchange_name,
  2. queue=queue_name)

绑定其实就是关联了exchange和queue。或者这么说:queue对exchagne的内容感兴趣,exchange要把它的Message deliver到queue中。

实际上,绑定可以带routing_key 这个参数。其实这个参数的名称和basic_publish 的参数名是相同了。为了避免混淆,我们把它成为binding key。
    使用一个key来创建binding :

[python] view plaincopy

  1. channel.queue_bind(exchange=exchange_name,
  2. queue=queue_name,
  3. routing_key=‘black‘)

对于fanout的exchange来说,这个参数是被忽略的。

2. Direct exchange

Direct exchange的路由算法非常简单:通过binding key的完全匹配,可以通过下图来说明。


    exchange X和两个queue绑定在一起。Q1的binding key是orange。Q2的binding key是black和green。
    当P publish key是orange时,exchange会把它放到Q1。如果是black或者green那么就会到Q2。其余的Message都会被丢弃。

3. Multiple bindings

多个queue绑定同一个key是可以的。对于下图的例子,Q1和Q2都绑定了black。也就是说,对于routing key是black的Message,会被deliver到Q1和Q2。其余的Message都会被丢弃。

4. Emitting logs

首先是我们要创建一个direct的exchange:

[python] view plaincopy

  1. channel.exchange_declare(exchange=‘direct_logs‘,
  2. type=‘direct‘)

我们将使用log的severity作为routing key,这样Consumer可以针对不同severity的log进行不同的处理。
publish:

[python] view plaincopy

  1. channel.basic_publish(exchange=‘direct_logs‘,
  2. routing_key=severity,
  3. body=message)

我们使用三种severity:‘info‘, ‘warning‘, ‘error‘.

5. Subscribing

对于queue,我们需要绑定severity:

[python] view plaincopy

  1. result = channel.queue_declare(exclusive=True)
  2. queue_name = result.method.queue
  3. for severity in severities:
  4. channel.queue_bind(exchange=‘direct_logs‘,
  5. queue=queue_name,
  6. routing_key=severity)

6. 最终版本

The code for emit_log_direct.py:

[python] view plaincopy

  1. #!/usr/bin/env python
  2. import pika
  3. import sys
  4. connection = pika.BlockingConnection(pika.ConnectionParameters(
  5. host=‘localhost‘))
  6. channel = connection.channel()
  7. channel.exchange_declare(exchange=‘direct_logs‘,
  8. type=‘direct‘)
  9. severity = sys.argv[1] if len(sys.argv) > 1 else ‘info‘
  10. message = ‘ ‘.join(sys.argv[2:]) or ‘Hello World!‘
  11. channel.basic_publish(exchange=‘direct_logs‘,
  12. routing_key=severity,
  13. body=message)
  14. print " [x] Sent %r:%r" % (severity, message)
  15. connection.close()

The code for receive_logs_direct.py:

[python] view plaincopy

  1. #!/usr/bin/env python
  2. import pika
  3. import sys
  4. connection = pika.BlockingConnection(pika.ConnectionParameters(
  5. host=‘localhost‘))
  6. channel = connection.channel()
  7. channel.exchange_declare(exchange=‘direct_logs‘,
  8. type=‘direct‘)
  9. result = channel.queue_declare(exclusive=True)
  10. queue_name = result.method.queue
  11. severities = sys.argv[1:]
  12. if not severities:
  13. print >> sys.stderr, "Usage: %s [info] [warning] [error]" % \
  14. (sys.argv[0],)
  15. sys.exit(1)
  16. for severity in severities:
  17. channel.queue_bind(exchange=‘direct_logs‘,
  18. queue=queue_name,
  19. routing_key=severity)
  20. print ‘ [*] Waiting for logs. To exit press CTRL+C‘
  21. def callback(ch, method, properties, body):
  22. print " [x] %r:%r" % (method.routing_key, body,)
  23. channel.basic_consume(callback,
  24. queue=queue_name,
  25. no_ack=True)
  26. channel.start_consuming()

我们想把warning和error的log记录到一个文件中:

[python] view plaincopy

  1. $ python receive_logs_direct.py warning error > logs_from_rabbit.log

打印所有log到屏幕:

[python] view plaincopy

  1. $ python receive_logs_direct.py info warning error
  2. [*] Waiting for logs. To exit press CTRL+C

尊重原创,转载出处 anzhsoft: http://blog.csdn.net/anzhsoft/article/details/19630147

参考资料:

1. http://www.rabbitmq.com/tutorials/tutorial-four-python.html

时间: 2024-10-24 10:25:42

RabbitMQ消息队列(五):Routing 消息路由的相关文章

消息队列及常见消息队列介绍

原文链接:https://cloud.tencent.com/community/article/129032 一.消息队列(MQ)概述 消息队列(Message Queue),是分布式系统中重要的组件,其通用的使用场景可以简单地描述为: 当不需要立即获得结果,但是并发量又需要进行控制的时候,差不多就是需要使用消息队列的时候. 消息队列主要解决了应用耦合.异步处理.流量削锋等问题. 当前使用较多的消息队列有RabbitMQ.RocketMQ.ActiveMQ.Kafka.ZeroMQ.MetaM

用STL设计消息队列、优先级消息队列、资源分配管理器

STL库老早已经成为C++的一部分,在使用C++开发项目的过程中,很多人还在犹豫要不要使用STL库,觉得STL库很难,其实不然.我工作的项目中现在大量使用STL库,STL使用调试简单,高效,可以减少很多重复的代码. 本文的主要目的是使用STL的queue 和 priority queue来阐述下项目中经常使用的消息队列以及资源分配模式.本文的例子主要如下: 消息队列 带优先级的消息队列 资源分配管理器 STL容器 我们将使用下面的容器来实现本文的例子: queue 队列容器支持添加一个元素,并且

强化一下概念:程序自己不去取消息,消息不会自己跑过来运行(针对线程消息队列里的消息,也是绝大多数消息)

刚才看这段代码的时候: procedure TControl.SetBounds(ALeft, ATop, AWidth, AHeight: Integer); begin if CheckNewSize(AWidth, AHeight) and ((ALeft <> FLeft) or (ATop <> FTop) or (AWidth <> FWidth) or (AHeight <> FHeight)) then begin InvalidateCon

消息队列如何处理重复消息

一.消息重复现象 在 MQTT 协议中,给出了三种传递消息时能够提供的服务质量标准: At most once:最多一次,这种情况会丢失部分数据,一般日志收集这种对数据不严格的可以使用 At least once:最少一次,这种会导致一条消息重复发送 Exactly once:正好一次,一条消息只会被消费一次 RocketMQ,Rabbit MQ,Kafka都是使用的At least once,虽然消息会重复,但不会丢失.不使用Exactly once这种呢,是因为这种每次发送前发送都要检查这条

C#消息队列(MQ)零基础从入门到实战演练

一.课程介绍 如果您从工作中之听过但未有接触过消息对队列(MQ),如果你接触过一点关于MQ的知识,如果没有这么的多如果的话......,那么阿笨将通过本次<C#消息队列零基础从入门到实战演练>分享课让您对消息队列有一个实质性的了解和认识,达到实际的灵活贯通和运用.本次分享课您将学习到以下知识点: 1.微软MSMQ的基本使用技能以及MSMQ在WCF技术中的运用. 2.企业级RabbitMQ消息队列的两种消费模式(生产消费和发布订阅)的介绍和使用. 3.如何实现RabbitMQ客户端(Client

RabbitMQ消息队列应用

RabbitMQ消息队列应用 消息通信组件Net分布式系统的核心中间件之一,应用与系统高并发,各个组件之间解耦的依赖的场景.本框架采用消息队列中间件主要应用于两方面:一是解决部分高并发的业务处理:二是通过消息队列传输系统日志.目前业界使用较多的消息队列组件有RabbitMQ.ActiveMQ.MSMQ.kafka.zeroMQ等,本文对系统架构之MQ Component诠释,并采用RabbitMQ作为消息队列中间件. 图1- 消息队列组件示意图 一.RabbitMQ介绍 RabbitMQ是一款基

RabbitMQ,Apache的ActiveMQ,阿里RocketMQ,Kafka,ZeroMQ,MetaMQ,Redis也可实现消息队列,RabbitMQ的应用场景以及基本原理介绍,RabbitMQ基础知识详解,RabbitMQ布曙

消息队列及常见消息队列介绍 2017-10-10 09:35操作系统/客户端/人脸识别 一.消息队列(MQ)概述 消息队列(Message Queue),是分布式系统中重要的组件,其通用的使用场景可以简单地描述为: 当不需要立即获得结果,但是并发量又需要进行控制的时候,差不多就是需要使用消息队列的时候. 消息队列主要解决了应用耦合.异步处理.流量削锋等问题. 当前使用较多的消息队列有RabbitMQ.RocketMQ.ActiveMQ.Kafka.ZeroMQ.MetaMq等,而部分数据库如Re

rabbitmq消息队列学习——&quot;工作队列&quot;

二."工作队列" 在第一节中我们发送接收消息直接从队列中进行.这节中我们会创建一个工作队列来分发处理多个工作者中的耗时性任务. 工作队列主要是为了避免进行一些必须同步等待的资源密集型的任务.实际上我们将这些任务时序话稍后分发完成.我们将某个任务封装成消息然后发送至队列,后台运行的工作进程将这些消息取出然后执行这些任务.当你运行多个工作进程的时候,这些任务也会在它们之间共享. 前期准备 上一节的练习中我们发送的是简单包含"Hello World!"的消息,这节我们还发

消息队列之 RabbitMQ

关于消息队列,从前年开始断断续续看了些资料,想写很久了,但一直没腾出空,近来分别碰到几个朋友聊这块的技术选型,是时候把这块的知识整理记录一下了. 市面上的消息队列产品有很多,比如老牌的 ActiveMQ.RabbitMQ ,目前我看最火的 Kafka ,还有 ZeroMQ ,去年底阿里巴巴捐赠给 Apache 的 RocketMQ ,连 redis 这样的 NoSQL 数据库也支持 MQ 功能.总之这块知名的产品就有十几种,就我自己的使用经验和兴趣只打算谈谈 RabbitMQ.Kafka 和 A

转 消息队列之 RabbitMQ

转 https://www.jianshu.com/p/79ca08116d57 消息队列之 RabbitMQ 预流 2017.05.06 16:03* 字数 4884 阅读 80990评论 18喜欢 236赞赏 1 关于消息队列,从前年开始断断续续看了些资料,想写很久了,但一直没腾出空,近来分别碰到几个朋友聊这块的技术选型,是时候把这块的知识整理记录一下了. 市面上的消息队列产品有很多,比如老牌的 ActiveMQ.RabbitMQ ,目前我看最火的 Kafka ,还有 ZeroMQ ,去年底