RabbitMQ之工作模式

六大工作模式

RabbitMQ有以下几种工作模式 :
1、Work queues
2、Publish/Subscribe
3、Routing
4、Topics
5、Header
6、RPC

一、 Work queues

RabbitMQ之工作模式
工作队列模式,采用默认的交换机,路由名称为队列名称,有多个终端消费同一个队列的时候,交换机采用轮询发送消息,通俗点说就是给第一个发一条,另外一个发下一条

应用场景:
对于 任务过重或任务较多情况使用工作队列可以提高任务处理的速度。

测试:
1、多个消费者。
2、生产者发送多个消息。
结果:
1、一条消息只会被一个消费者接收;
2、rabbit采用轮询的方式将消息是平均发送给消费者的;
3、消费者在处理完某条消息后,才会收到下一条消息。

二、 Publish/subscribe

RabbitMQ之工作模式
发布订阅模式:
1、每个消费者监听自己的队列。
2、生产者将消息发给broker,由交换机将消息转发到绑定此交换机的每个队列,每个绑定交换机的队列都将接收到消息

应用场景:
用户通知,当用户充值成功或转账完成系统通知用户,通知方式有短信、邮件多种方法 。

流程:
1.生产者
声明fanout类型交换机。
声明两个队列并且绑定到此交换机,绑定时不需要指定routingkey
发送消息时不需要指定routingkey

2.消费者
交换机会将信息发布给每个监听本交换机的队列,但是如果多个消费者监听了同一个队列,这个队列还是会按照轮询方式把信息发给每个消费者,一人一条(非同一个信息)

三、Routing

RabbitMQ之工作模式
路由模式:
1、每个消费者监听自己的队列,并且设置routingkey。
2、生产者将消息发给交换机,由交换机根据routingkey来转发消息到指定的队列。

流程:
1.生产者
声明DIRECT类型交换机。
声明两个队列并且绑定到此交换机,绑定时需要指定routingkey
发送消息时需要指定routingkey
2.消费者
消费者绑定队列的时候可以指定routingkey来只获取指定routingkey的消息
说明:
Routing模式要求队列在绑定交换机时要指定routingkey,消息会转发到符合routingkey的队列。

四、Topics

RabbitMQ之工作模式
通配符模式:
同路由模式相似,但是routingkey的匹配是通过通配符决定的,路由模式是相等才匹配
设置交换机类型为Topics即可

应用场景:
根据用户的通知设置去通知用户,设置接收Email的用户只接收Email,设置接收sms的用户只接收sms,设置两种
通知类型都接收的则两种通知都有效。

通配符使用:

  1. [#],匹配一个或者多个词,比如 uncle.# ,可以匹配uncle.sms、uncle.email、uncle.sms.email
  2. [* ],匹配一个词,比如 uncle.*,可以匹配uncle.sms、uncle.email

例子:
uncle.#.sms.# 能匹配 uncle.sms、uncle.email.sms,不能匹配 uncle.email

五、Header

header模式与routing不同的地方在于,header模式取消routingkey,使用header中的 key/value(键值对)匹配队列。

六、RPC

RabbitMQ之工作模式
RPC即客户端远程调用服务端的方法 ,使用MQ可以实现RPC的异步调用,基于Direct交换机实现,流程如下:
1、客户端即是生产者就是消费者,向RPC请求队列发送RPC调用消息,同时监听RPC响应队列。
2、服务端监听RPC请求队列的消息,收到消息后执行服务端的方法,得到方法返回的结果
3、服务端将RPC方法 的结果发送到RPC响应队列
4、客户端(RPC调用方)监听RPC响应队列,接收到RPC调用结果。

上一篇:SpringBoot----JPA


下一篇:PHP获取星期六星期日