RocketMQ订阅关系不一致浅析

一、背景

        在RocketMQ的使用过程中，偶尔会遇到当前Group下的消息订阅关系不一致的问题，当出现订阅关系不一致时，可能会出现消息丢失、堆积等问题。下文对出现此问题的原因进行详细解析。

二、原因解析

1、官方文档解析

        为什么会出现订阅关系不一致呢？官方解释订阅关系一致指的是同一个消费者Group ID下所有Consumer实例所订阅的Topic、Tag必须完全一致。如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。

        对于大多数分布式应用来说，同一个消费者Group ID往往会挂载多个Consumer实例，而RocketMQ的订阅关系是由Topic+Tag共同组成的，因此，想要订阅关系一致，相同的Group ID下所有的Consumer实例必须满足以下几点：

1. 订阅的Topic必须相同。举个栗子：Consumer1订阅了TopicA、TopicB，Consumer2也必须订阅TopicA和TopicB，不能只TopicA或者只订阅TopicB或者订阅TopicB、TopicC。
2. 订阅的同一个Topic中的Tag必须一致，包括Tag的数量和顺序。举个栗子：Consumer1订阅了TopicA，对应的Tag是Tagα|Tagβ，Consumer2订阅TopicB的Tag也必须是Tagα|Tagβ。

2、正确的订阅关系示意图例子

a）、订阅一个Topic且订阅一个Tag。