没有合适的资源?快使用搜索试试~ 我知道了~
RabbitMQ 45 道面试题及答案.docx
需积分: 0 0 下载量 21 浏览量
2023-07-08
12:14:20
上传
评论
收藏 122KB DOCX 举报
温馨提示
![preview](https://dl-preview.csdnimg.cn/88016624/0001-9c67e7ea02888468f6f3d1e123ad38ba_thumbnail-wide.jpeg)
![preview-icon](https://csdnimg.cn/release/downloadcmsfe/public/img/scale.ab9e0183.png)
试读
21页
RabbitMQ 45 道面试题及答案.docx
资源推荐
资源详情
资源评论
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![rar](https://img-home.csdnimg.cn/images/20210720083606.png)
![rar](https://img-home.csdnimg.cn/images/20210720083606.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![](https://csdnimg.cn/release/download_crawler_static/88016624/bg1.jpg)
什么是rabbitmq
采用AMQP高级消息队列协议的一种消息队列技术,最大的特点就是消费并不需要确保提供方存在,实现
了服务之间的高度解耦
为什么要使用rabbitmq
1、在分布式系统下具备异步,削峰,负载均衡等一系列高级功能;
2.拥有持久化的机制,进程消息,队列中的信息也可以保存下来。
3、实现消费者和生产者之间的解耦。
4、_对于高并发场景下,利用消息队列可以使得同步访问变为串行访问达到一定量的限流,利于数据库的
操作。
5.可以使用消息队列达到异步下单的效果,排队中,后台进行逻辑下单。
使用rabbitmq的场景
1、服务间异步通信
2、顺序消费
3、定时任务
4、请求削峰
如何确保消息正确地发送至RabbitMQ?如何确保消息接收方
![](https://csdnimg.cn/release/download_crawler_static/88016624/bg2.jpg)
消费了消息?
发送方确认模式
1、将信道设置成confirm模式(发送方确认模式),则所有在信道上发布的消息都会
被指派一个唯一的ID。
2、一旦消息被投递到目的队列后,或者消息被写入磁盘后(可持久化的消息)信道
会发送一个确认给生产者(包含消息唯一ID)。
3 、 如 果 RabbitMQ 发 生 内 部 错 误 从 而 导 致 消 息 丢 失 , 会 发 送 一 条 nack(not
acknowledged,未确认)消息。
4、发送方确认模式是异步的,生产者应用程序在等待确认的同时,可以继续发送
消息。当确认消息到达生产者应用程序,生产者应用程序的回调方法就会被触发
来处理确认消息。
接收方确认机制
接收方消息确认机制
1、消费者接收每一条消息后都必须进行确认(消息接收和消息确认是两个不同操
作)。只有消费者确认了消息,RabbitMQ才能安全地把消息从队列中删除。
![](https://csdnimg.cn/release/download_crawler_static/88016624/bg3.jpg)
下面罗列几种特殊情况
1、如果消费者接收到消息,在确认之前断开了连接或取消订阅,RabbitMQ会认为
消息没有被分发,然后重新分发给下一个订阅的消费者。(可能存在消息重复消费
的隐患,需要去重)
2、如果消费者接收到消息却没有确认消息,连接也未断开,则RabbitMQ认为该消
费者繁忙,将不会给该消费者分发更多的消息。
如何避免消息重复投递或重复消费?
在消息生产时,MQ内部针对每条生产者发送的消息生成一个inner-msg-id,作为去
重的依据(消息投递失败并重传),避免重复的消息进入队列;
在消息消费时,要求消息体中必须要有一个bizld(对于同一业务全局唯一,如支付
ID、订单ID、帖子ID等)作为去重的依据,避免同一条消息被重复消费。
消息如何分发?
2、这里并没有用到超时机制,RabbitMQ仅通过Consumer的连接中断来确认是否需
要重新发送消息。也就是说,只要连接不中断,RabbitMQ给了Consumer 足够长的时
间来处理消息。保证数据的最终一致性;
消息基于什么传输?
由于TCP连接的创建和销毁开销较大,且并发数受系统资源限制,会造成性能瓶颈
。RabbitMQ使用信道的方式来传输数据。信道是建立在真实的TCP连接内的虚拟连
接,且每条TCP连接上的信道数量没有限制。
![](https://csdnimg.cn/release/download_crawler_static/88016624/bg4.jpg)
1、若该队列至少有一个消费者订阅,消息将以循环(round-robin)的方式发送给消费者。每条
消息只会分发给一个订阅的消费者(前提是消费者能够正常处理消息并进行确认)。
2、通过路由可实现多消费的功能
消息怎么路由?
1、消息提供方->路由->-至多个队列
2、消息发布到交换器时,消息将拥有一个路由键(routing key),在消息创建时设定。
3、通过队列路由键,可以把队列绑定到交换器上。
4、消息到达交换器后,RabbitMQ会将消息的路由键与队列的路由键进行匹配(针对不同的交换
器有不同的路由规则);
常用的交换器主要分为一下三种
1、fanout:如果交换器收到消息,将会广播到所有绑定的队列上
2、direct:如果路由键完全匹配,消息就被投递到相应的队列
3、topic:可以使来自不同源头的消息能够到达同一个队列。使用topic交换器时,可以使用
通配符
如何确保消息不丢失?
剩余20页未读,继续阅读
资源评论
![avatar-default](https://csdnimg.cn/release/downloadcmsfe/public/img/lazyLogo2.1882d7f4.png)
![avatar](https://profile-avatar.csdnimg.cn/default.jpg!1)
伟大先锋
- 粉丝: 120
- 资源: 1689
上传资源 快速赚钱
我的内容管理 展开
我的资源 快来上传第一个资源
我的收益
登录查看自己的收益我的积分 登录查看自己的积分
我的C币 登录后查看C币余额
我的收藏
我的下载
下载帮助
![voice](https://csdnimg.cn/release/downloadcmsfe/public/img/voice.245cc511.png)
![center-task](https://csdnimg.cn/release/downloadcmsfe/public/img/center-task.c2eda91a.png)
安全验证
文档复制为VIP权益,开通VIP直接复制
![dialog-icon](https://csdnimg.cn/release/downloadcmsfe/public/img/green-success.6a4acb44.png)