RabbitMQ(三) ——发布订阅

RabbitMQ(三)——发布订阅

(原创内容,转载请注明来源,谢谢)

一、概述

RabbitMQ的发布订阅(Publish/Subscribe),其将生产者和消费者进一步解耦,生产者生产消息后,交付给交换机,消费者上线后,主动主动去队列中取数据进行处理。该模式也符合上一节工作队列中的ack、预取等规则。

发布订阅模式如下图所示:

二、交换机(exchange)

生产者生产完消息之后,都是将消息通过channel交给交换机,即生产者并不直接和队列联系。在没有定义交换机的时候,RabbitMQ会启用内部预定义的交换机。即所有没有定义交换机,直接采用生产者发送消息到队列的,都是将消息发送给默认交换机。

交换机是一个很简单的东西,即将生产者发送的消息,按照预先定好的规则,转发给对应的队列。

1、广播发送

rabbitmq中,交换机的规则有fanout、direct、topic、headers等。本节的发布订阅模式,主要可以采用fanout模式。

fanout,类似网络技术中,子网的广播发送模式。即,fanout模式下,交换机会将信息发送给所有与其绑定的队列,即实现“发布”的功能。通常,再将每个队列给不同的消费者去消费,实现每个消费者都可以取到该消息,并各自进行后续相应的处理。

fanout模式如下图所示:

2、注意事项

1)提前绑定

fanout模式下,需要提前将交换机与队列进行绑定,一个交换机可以绑定多个队列,一个队列可以同多个交换机进行绑定。接受到消息的交换机没有与任何队列绑定,则消息会被抛弃。

2)该模式不需要routing key。

3、使用

1)用法

$channel->exchange_declare('logs','fanout', false, false, false);
$channel->basic_publish($msg, 'logs');

其中,第一个参数是交换机的名字,第二个参数,是交换机的模式。如果没有定义交换机的名称、模式,则采用默认的交换机转发生产者的消息。即可以看作,空字符串’’也是交换机的一个名字。

2)查看当前交换机数量

cli模式下,sudo rabbitmqctl list_exchanges

三、临时队列(Temporary queues)

当rabbitmq运行时,队列的名字非常重要,因为其在生产者方,交换机会将信息按照名字发送给队列,而消费者方,消费者需要通过队列的名字去队列取消息。因此,队列是rabbitmq中连接生产者与消费者的桥梁。

当开始使用时,需要的是一个空的、未被使用的队列;当连接断开,需要将队列关闭。

1、队列取名

为了保证队列是一个全新的队列,需要将给队列取一个随机的名字。rabbitmq提供了系统随机给生成队列名的方式,如下:

       list($queue_name, ,) =$channel->queue_declare("");

即,当queue_declare时没有指定名字,采用空字符串"",则rabbitmq会给队列取一个随机的名字,形如amq.gen-JzTY20BRgKO-HjmUJj0wLg,则可以使用$queue_name,其就是队列的名字。

2、php的list

上述list是php中的list的用法,上述式子表示$channel->queue_declare("");的结果是一个含有3个元素的数组,将第一个元素赋值给$queue_name。

list()不是一个函数,而是类似array()一样的用法。

PHP官方文档中,list的示例:

$info = array('coffee', 'brown','caffeine');

list( , , $power) = $info;//$power=’caffeine’

四、绑定(binding)

上述提到,交换机必须与队列绑定,如果没有队列和交换机绑定,交换机会丢弃接收到的消息。绑定方式如下:

       $channel->queue_bind($queue_name,'logs');

其中,第一个参数是队列的名字,第二个参数是交换机的名字。

在cli中,查看绑定的方式如下:

rabbitmqctl list_bindings

——written by linhxx 2017.08.21

原文发布于微信公众号 - 决胜机器学习(phpthinker)

原文发表时间:2017-08-21

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

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java架构沉思录

如何优雅地用Redis实现分布式锁

在学习Java多线程编程的时候,锁是一个很重要也很基础的概念,锁可以看做是多线程情况下访问共享资源的一种线程同步机制。这是对于单进程应用而言的,即所有线程都在同...

38717
来自专栏IT笔记

Tomcat优化之配置线程池

简介 线程池作为提高程序处理数据能力的一种方案,应用非常广泛。大量的服务器都或多或少的使用到了线程池技术,不管是用Java还是C++实现,线程池都有如下的特点:...

2988
来自专栏idba

socket 编程初探

一 简介 socket是两个应用程序进行通信的管道,这两个应用程序可以在同一台机器上,也可以位于两台不同的机器上,相同的网络或者不同网络之间的。Pyth...

634
来自专栏枕边书

从并发处理谈PHP进程间通信(二)System V IPC

前言 进程间通信是一个永远的话题,我的上一篇文章通过一个并发循环ID生成器的实现介绍了如何使用外部介质来进行进程间通信:从并发处理谈PHP进程间通信(一)外部介...

2108
来自专栏偏前端工程师的驿站

深入线程

前言                                         在校时认识的线程就是获取CPU执行时间的最小单位,多个线程共享所在进程的资...

18110
来自专栏北京马哥教育

python线程笔记

豌豆贴心提醒,本文阅读时间5分钟 来源:伯乐在线 原文:http://python.jobbole.com/87498/ 引言&动机 考虑一下...

1865
来自专栏PHP技术

设计模式之—单例模式(Singleton)的常见应用场景

单例模式(Singleton)也叫单态模式,是设计模式中最为简单的一种模式,甚至有些模式大师都不称其为模式,称其为一种实现技巧,因为设计模式讲究对象之间的关系的...

3386
来自专栏Hongten

HTTP协议

众所周知,Internet的基本协议是TCP/IP协议,目前广泛采用的FTP、Archie Gopher等是建立在TCP/IP协议之上的应用层协议,不同的协议对...

722
来自专栏猿人谷

进程控制实验--fork()

进程的控制 实验目的 1、掌握进程另外的创建方法 2、熟悉进程的睡眠、同步、撤消等进程控制方法 实验内容 1、用fork( )创建一个进程,再调用exec( )...

1858
来自专栏深度学习计算机视觉

同步、异步、阻塞、非阻塞

同步、异步、阻塞和非阻塞(网络编程) 同步 所谓同步,就是在发出一个功能调用时,在没有得到结果之前,该调用就不返回。 按照这个定义,其实绝大多数函数都是同步调用...

2665

扫码关注云+社区