目录
概述
1.重要概念
2.消息存储
3底层实现
3.1 MappedByteBuffer
3.2 page cache
4.部署模式
4.1多 master 多 slave 异步复制模式(实时性)
4.2多 master 多 slave 同步双写模式
5.RocketMq官方源码结构
6.RocketMq的四种消费类型
6.1.普通消费
6.2. 顺序消费
6.3.事务消费
6.4广播消费
8.负载均衡
9.消息重试
9.1.producer发送消息重试
9.2.consumer消费重试
9.2.1 exception的情况等待时间
9.2.2 超时情况
9.2.3 消息重试的主要流程
9.2.4死信队列
10.如何保证消息不被重复消费
11.如何保证高可用性(面试常问)
11.1集群化部署 + 数据多副本冗余
11.2多副本同步复制强制要求
11.3影响消息可靠性的几种情况
12.如何解决消息队列的延时以及过期失效问题
12.1消息积压解决方案
12.2消息积压导致的数据丢失解决方案
13.启动的时候从哪里消费
14.消息ACK机制
14.1批量ack机制潜在的问题
14.2批量ack重复消费场景的解决
15.推拉模式
16.消息丢失场景分析及MQ内部如何解决
17.相关文章
概述


版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容,请联系我们,一经查实,本站将立刻删除。
如需转载请保留出处:https://51itzy.com/kjqy/58381.html