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