RabbitMQ的工作模式
一.simple模式(即最简单的收发模式)
二.work工作模式(资源的竞争)publish_subscribe发布订阅(../../../../../0马士兵/新建文件夹/BAT面试突击资料(1)/
整理/BAT面试突击资料/15-消息中间件MQ面试题(2020最新
版).assets/publish_subscribe发布订阅(共享资源).png)
1、每个消费者监听自己的队列;
2、生产者将消息发给broker,由交换机将消息转发到绑定此交换机的每个队 列,每个绑定交换机的队列都将接收到消息。
1.消息生产者将消息发送给交换机按照路由判断,路由是字符串(info) 当前产生的 消息携带路由字符(对象的方法),交换机根据路由的key,只能匹配上路由
key对应的消息队列,对应的
消费者才能消费消息;
2.根据业务功能定义路由字符串
3.从系统的代码逻辑中获取对应的功能字符串,将消息任务扔到对应的队列中。
4.业务场景:error 通知;EXCEPTION;错误通知的功能;传统意义的错误通知;客户 通知;利用key路由,
可以将程序中的错误封装成消息传入到消息队列中,开发者可 以自定义消费者,实
时接收错误;
1.星号井号代表通配符
2.星号代表多个单词,井号代表一个单词
3.路由功能添加模糊匹配
4.消息产生者产生消息,把消息交给交换机
5.交换机根据key的规则模糊匹配到对应的队列,由队列的监听消费者接收消息消 费
(在我的理解看来就是routing查询的一种模糊匹配,就类似sql的模糊查询方 式)
拆分多个 queue,每个 queue 一个 consumer,就是多一些 queue 而已,确 实是麻烦点;或者就一个 queue 但是对应一个
consumer,然后这个 consumer 内部用内存队列
做排队,然后分发给底层不同的 worker 来处理。
若该队列至少有一个消费者订阅,消息将以循环(round-robin
)的方式发送给消费者。每条消息只会分发给一个订阅的消费者(前提是消费者能够正常处理消息并进行确认)。
通过路由可实现多消费的功能
消息提供方->路由->一至多个队列消息发布到交换器时,消息将拥有一个路由键(routing key
),在消息创建时设定。通过队列路由键,可以把队列绑定到交换器上。消息到达
交换器后,RabbitMQ 会将消息的路由键与队列的路由键进行匹配(针对不同的交换器有不同的路由规则);常用的交换器主要分为一下三种: fanout
:如果交换器收到消息,
将会广播到所有绑定的队列上 direct:如果路由键完全匹配,消息就被投递到相应的队列
topic:可以使来自不同源头的消息能够到达同一个队列。 使用 topic 交换器时,可以使用通配符
由于 TCP 连接的创建和销毁开销较大,且并发数受系统资源限制,会造成性能瓶颈。RabbitMQ 使用信道的方式来传输数据。信道是建立在真实的 TCP
连接内的虚拟连接,且每
条 TCP 连接上的信道数量没有限制。
先说为什么会重复消费:正常情况下,消费者在消费消息的时候,消费完毕后,会发送一个确认消息给消息队列,消息队列就知道该消息被消费了,就会将该消息从消息队列中
删除;但是因为网络传输等等故障,确认信息没有传送到消息队列,导致消息队列不知道自己已经消费过该消息了,再次将消息分发给其他的消费者。
三.publish/subscribe发布订阅(共享资源)
四.routing路由模式
五.topic 主题模式(路由模式的一种)