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 主题模式(路由模式的一种)

技术
下载桌面版
GitHub
Gitee
SourceForge
百度网盘(提取码:draw)
云服务器优惠
华为云优惠券
腾讯云优惠券
阿里云优惠券
Vultr优惠券
站点信息
问题反馈
邮箱:[email protected]
吐槽一下
QQ群:766591547
关注微信