Python-RabbitMQ direct广播模式

fanout广播模式是全部都能收到信息，那我要是想要有条件选择的接收呢，需要用到direct模式


这张图的大概意思是Exchange的类型为direct，发的error级别的消息投递到第一个队列，消息级别为info、error、warning级别的消息投递到第二个队列。
先定义一个生产者

再定义消费者

进行测试
打开级别级别为info、warning、error三个级别的消费者


在生产者端发送一个级别为error的消息

观察三个级别的消费者，最终只能级别为error的消费者能收到下消息

原文地址：http://blog.51cto.com/12730062/2059839

时间： 2024-10-10 11:44:29

Python-RabbitMQ direct广播模式的相关文章

RabbitMQ广播模式

广播模式:1对多,produce发送一则消息多个consumer同时收到.注意:广播是实时的,produce只负责发出去,不会管对端是否收到,若发送的时刻没有对端接收,那消息就没了,因此在广播模式下设置消息持久化是无效的. 三种广播模式: fanout: 所有bind到此exchange的queue都可以接收消息(纯广播,绑定到RabbitMQ的接受者都能收到消息):direct: 通过routingKey和exchange决定的那个唯一的queue可以接收消息:topic:所有符合routin

RabbitMQ 在 PHP 下的简单使用 (一) -- 安装 AMQP 扩展和 Direct Exchange 模式

Windows 安装 amqp 扩展 RabbitMQ 是基于 amqp(高级消息队列协议) 协议的.使用 RabbitMQ 前必须为 PHP 安装相应的 amqp 扩展. 下载相应版本的 amqp 扩展:http://pecl.php.net/package/amqp,解压缩文件. 将 php_amqp.dll 复制到 php 的扩展目录 ext 下,修改配置文件 php.ini: [amqp] extension=php_amqp.dll 将 rabbitmq.*.dll 文件复制到 php

python RabbitMQ队列使用（入门篇）

---恢复内容开始--- python RabbitMQ队列使用 关于python的queue介绍 关于python的队列,内置的有两种,一种是线程queue,另一种是进程queue,但是这两种queue都是只能在同一个进程下的线程间或者父进程与子进程之间进行队列通讯,并不能进行程序与程序之间的信息交换,这时候我们就需要一个中间件,来实现程序之间的通讯. RabbitMQ MQ并不是python内置的模块,而是一个需要你额外安装(ubunto可直接apt-get其余请自行百度.)的程序,安装完毕

python RabbitMQ队列/redis

RabbitMQ队列 安装 http://www.rabbitmq.com/install-standalone-mac.html 安装python rabbitMQ module 1 2 3 4 5 6 7 pip install pika or easy_install pika or 源码   https://pypi.python.org/pypi/pika 实现最简单的队列通信 produce 1 import pika 2 connection = pika.BlockingConn

Python RabbitMQ fanout

#########################消费者################################ #!/usr/bin/env python # -*- coding:utf-8 -*- # author: Changhua Gong import pika ''' fanout模式:类似收音机的广播模式, 接收者(消费者)在的话,则接收:接收者不在的话,消息错过了就没有了. ''' connection = pika.BlockingConnection(pika.Co

Python open文件读写模式说明

对于Python打开文件的模式,总是记不住,这次在博客里记录一下 r+: Open for reading and writing.  The stream is positioned  at  the beginning of the file. w+:Open for reading and writing.  The file is created  if  it  does not  exist, otherwise it is truncated.  The stream is pos

uip UDP 服务器广播模式(客户端可以任意端口,并且主动向客户端发送数据)

目前移植uip,发现UDP 服务器模式下,必须指定本地端口以及客户端端口,否则只能讲客户端端口设置为0,才能接收任意端口的数据,但是无法发送数据,因为此时客户端端口设置为0了,我通过将原始数据包中的客户端端口保存下来,并且在发送的时候将客户端端口替换为指定的端口,发送完成之后又设置为0,这样就实现了向任意客户端端口发送数据. uip.c if(uip_udp_conn->lport != 0 && UDPBUF->destport == uip_udp_conn->lpo

关于python的单实例模式

单实例模式一直是常用的设计模式,对于python的单实例模式,其实其本身就有实现 http://stackoverflow.com/questions/31875/is-there-a-simple-elegant-way-to-define-singletons-in-python/31887#31887 里面说到module,module只会初始化一次,天然的singleton.这是最为python的解决方案.将你所需要的属性和方法,直接暴露在模块中变成模块的全局变量和方法即可. 另外,如果

Python设计模式——工厂方法模式（FactoryMethod）

需求:有一个学雷锋活动,有买米和扫地两个内容,参与的人有大学生和社区志愿者,他们各自的方法不一样. 如果用简单工厂模式实现: #encoding=utf-8 __author__ = '[email protected]' class LeiFeng(): def buy_rice(self): pass def sweep(self): pass class Student(LeiFeng): def buy_rice(self): print '大学生帮你买米' def sweep(self