文章目录
- 概览
- 消息发送异常时重复发送
- 消费消息抛出异常
- 消费者提交offset失败
- 服务端持久化offset失败
- 主从同步offset失败
- 重平衡
- 清理长时间消费的消息
- 总结
概览

消息发送异常时重复发送
首先,我们来瞅瞅RocketMQ发送消息和消费消息的基本原理。

如图,简单说一下上图中的概念:
- Broker,就是RocketMQ的服务端,如上图就有两个服务实例
- Topic就是一类消息集合的名字
- Queue就是Topic的对应的队列,消息都存在Queue上,每个Topic都会有自己的几个Queue
所以,整个消息发送和消费过程大致如下:
- 生产者在发送消息之前根据负载均衡