RabbitMQ之工作模式
# 六大工作模式
RabbitMQ有以下几种工作模式 : 1、Work queues 2、Publish/Subscribe 3、Routing 4、Topics 5、Header 6、RPC
# 一、 Work queues
工作队列模式,采用默认的交换机,路由名称为队列名称,有多个终端消费同一个队列的时候,交换机采用轮询发送消息,通俗点说就是给第一个发一条,另外一个发下一条
应用场景: 对于 任务过重或任务较多情况使用工作队列可以提高任务处理的速度。
测试: 1、多个消费者。 2、生产者发送多个消息。 结果: 1、一条消息只会被一个消费者接收; 2、rabbit采用轮询的方式将消息是平均发送给消费者的; 3、消费者在处理完某条消息后,才会收到下一条消息。
# 二、 Publish/subscribe
发布订阅模式: 1、每个消费者监听自己的队列。 2、生产者将消息发给broker,由交换机将消息转发到绑定此交换机的每个队列,每个绑定交换机的队列都将接收到消息
应用场景: 用户通知,当用户充值成功或转账完成系统通知用户,通知方式有短信、邮件多种方法 。
流程: 1.生产者 声明fanout类型交换机。 声明两个队列并且绑定到此交换机,绑定时不需要指定routingkey 发送消息时不需要指定routingkey
2.消费者 交换机会将信息发布给每个监听本交换机的队列,但是如果多个消费者监听了同一个队列,这个队列还是会按照轮询方式把信息发给每个消费者,一人一条(非同一个信息)
# 三、Routing
路由模式: 1、每个消费者监听自己的队列,并且设置routingkey。 2、生产者将消息发给交换机,由交换机根据routingkey来转发消息到指定的队列。
流程: 1.生产者 声明DIRECT类型交换机。 声明两个队列并且绑定到此交换机,绑定时需要指定routingkey 发送消息时需要指定routingkey 2.消费者 消费者绑定队列的时候可以指定routingkey来只获取指定routingkey的消息 说明: Routing模式要求队列在绑定交换机时要指定routingkey,消息会转发到符合routingkey的队列。
# 四、Topics
通配符模式: 同路由模式相似,但是routingkey的匹配是通过通配符决定的,路由模式是相等才匹配 设置交换机类型为Topics即可
应用场景: 根据用户的通知设置去通知用户,设置接收Email的用户只接收Email,设置接收sms的用户只接收sms,设置两种 通知类型都接收的则两种通知都有效。
通配符使用:
- [#],匹配一个或者多个词,比如 uncle.# ,可以匹配uncle.sms、uncle.email、uncle.sms.email
- [* ],匹配一个词,比如 uncle.*,可以匹配uncle.sms、uncle.email
例子: uncle.#.sms.# 能匹配 uncle.sms、uncle.email.sms,不能匹配 uncle.email
# 五、Header
header模式与routing不同的地方在于,header模式取消routingkey,使用header中的 key/value(键值对)匹配队列。
# 六、RPC
RPC即客户端远程调用服务端的方法 ,使用MQ可以实现RPC的异步调用,基于Direct交换机实现,流程如下: 1、客户端即是生产者就是消费者,向RPC请求队列发送RPC调用消息,同时监听RPC响应队列。 2、服务端监听RPC请求队列的消息,收到消息后执行服务端的方法,得到方法返回的结果 3、服务端将RPC方法 的结果发送到RPC响应队列 4、客户端(RPC调用方)监听RPC响应队列,接收到RPC调用结果。