文章目录
- 概览
- 消息发送异常时重复发送
- 消费消息抛出异常
- 消费者提交offset失败
- 服务端持久化offset失败
- 主从同步offset失败
- 重平衡
- 清理长时间消费的消息
- 总结
概览
消息发送异常时重复发送
首先，我们来瞅瞅RocketMQ发送消息和消费消息的基本原理。
如图，简单说一下上图中的概念：
- Broker，就是RocketMQ的服务端，如上图就有两个服务实例
- Topic就是一类消息集合的名字
- Queue就是Topic的对应的队列，消息都存在Queue上，每个Topic都会有自己的几个Queue
所以，整个消息发送和消费过程大致如下：
- 生产者在发送消息之前根据负载均衡
