Python云计算框架:OpenStack源码分析之RabbitMQ(二)

之前发布的文章因为在编辑后代码部分在手机上看不清已被及时删除,本文重新编辑好之后再发布一次,带来不便请谅解!

專 欄

ZZR ,Python中文社区专栏作者,OpenStack工程师,曾经的NLP研究者。主要兴趣方向:OpenStack、Python爬虫、Python数据分析。

Blog:http://skydream.me/

CSDN:http://blog.csdn.net/titan0427/article/details/50365480

fanout exchange

在上一篇中,task_queue所解决的问题是,一个message只能被一种consumer所接收。现在我们有了新的需求,我们需要一个日志系统,我们希望有两种consumer,一种consumer将日志输出到屏幕,另一种consumer写到disk。为了实现这个目的,我们希望message被投到两个queue中,交给不同的consumer进行处理。如下所示:

picture.image

对于producer,不再指定哪一个queue来接收消息,而是哪一个exchange来接收消息。exchange不保存信息,如果没有queue绑定在这个exchange上的话,消息就丢失了。代码如下:

picture.image

对于consumer,自己创建临时queue( exclusive=True ,当这个consumer终止,这个queue就销毁),将这个queue接到exchange上,然后通过这个queue接收exchange发出的消息:

picture.image

如下图所示,每一个consumer都建了自己的临时queue,并与exchange进行了绑定:

picture.image

direct exchange

上面的例子中,queue_bind()的时候我们没有指定routing_key(为了避免混淆,后续将其称为binding_key)。binding_key的功能与exchange的类型有关。对于fanout exchange而言,binding_key没有意义。对于direct exchange而言,如下图所示,只有消息的routing_type与queue的binding_key相同时才会发送到该queue:

picture.image

可以指定相同的binding_key,如下图所示:

picture.image

借此,我们可以将日志系统改造为以下模式,不同的consumer只接收特定类型的日志信息:

picture.image

完整代码如下:

picture.image

picture.image

topic exchang

topic exchange与direct exchange类似,只是它允许binding_key使用特殊字符(注意,特殊字符代表的是单词,不是字母):

* :代表一个单词

# :代表零个或多个单词

比如下面这个例子。routing_key定义为 "<celerity>.<colour>.<species>" 。举几个routing_key匹配的例子:

  • quick.orange.rabbit:一,二
  • lazy.orange.elephant:一,二
  • quick.orange.fox:一
  • lazy.brown.fox:三
  • lazy.pink.rabbit:二,三(但只发一次,因为二和三是同一个队列)
  • quick.brown.fox:无,舍弃
  • orange:无,舍弃
  • quick.orange.male.rabbit:无,舍弃
  • lazy.orange.male.rabbit:三

picture.image

picture.image

当binding_key不使用这些特殊字符时,topic exchange其实就是direct exchange;当binding_key使用 # 时,topic exchange其实就是fanout exchange,也就是所有消息都接收。

一些极端的例子:
binding_key: * ,routing_key:空串。不匹配。
binding_key: #.* ,routing_key: .. 。匹配。
binding_key: #.* ,routing_key:apple。匹配。

完整代码:

picture.image

picture.image

总结

在上一篇中:

再回顾一下上面的代码。首先明确,这种情况使用的是默认exchange。对于producer,它将消息交给exchange,然后exchange通过routing key来判断要将消息交到哪个queue。实际上相当于将消息直接发送到queue中。而consumer直接指定queue的名字,也就是它直接绑定到这个queue。这个过程中exchange其实没什么存在感。

而这一篇,实际上producer只认exchange。它只负责将消息交给exchange。consumer自己搭建queue,将queue绑定到它感兴趣的exchange上。exchange决定它以什么样的形式提供服务,是fanous还是direct。

ARTICLES

近期热门文章

生成器

关于生成器的那些事儿

爬虫代理

如何构建爬虫代理服务

地理编码

怎样用Python实现地理编码

nginx日志

使用Python分析nginx日志

淘宝女郎

一个批量抓取淘女郎写真图片的爬虫

IP代理池

突破反爬虫的利器——开源IP代理池

布隆去重

基于Redis的Bloomfilter去重(附代码)

内建函数

Python中内建函数的用法

QQ空间爬虫

QQ空间爬虫最新分享,一天 400 万条数据

对象

Python教你找到最心仪对象

线性回归

Python机器学习算法入门之梯度下降法实现线性回归

匿名代理池

进击的爬虫:用Python搭建匿名代理池

发射导弹

Python发射导弹的正确姿势

在公众号底部回复上述关键词可直接打开相应文章

picture.image

Python 中 文 开 发 者 的 精 神 家 园

§

§

Python中文社区

www.python-cn.com

picture.image

picture.image

致力于成为

国内最好的Python社区

QQ群:152745094

专栏作者申请邮箱

sinoandywong@gmail.com

— Life is short,we use Python —


    社区在节后计划推出图文直播模块PyLive,如果您在Python开发、应用、研究等方面有一定的经验,请点击阅读全文,或将以下链接复制在浏览器:http://t.cn/RMXAIwd 填写表单申请PyLive主讲人。经过审核认可,将会发送PyLive策划书及相关说明至您的邮箱,我们尊重知识,并且始终相信知识是最有价值

的,PyLive主讲人也将获得丰厚的补贴,欢迎大家踊跃申请。如果您认为自己暂时还欠缺相关的经验,也欢迎将本消息转发给您认识的Python高手,感 谢一路有你!

    欢迎点击阅读原文,或者长按扫描以下二维码申请PyLive主讲人!

picture.image

0
0
0
0
评论
未登录
暂无评论