新功能发布记录
公告
订阅关系一致性
本文主要介绍订阅关系一致性的核心要点，从定义与约束机制，到底层实现原理与优化实践，再结合真实案例分享 TDMQ RocketMQ 版针对订阅关系不一致问题的解决方案，帮助开发者快速定位问题根源，构建稳定可靠的消息系统。
订阅关系定义
订阅关系是 RocketMQ 系统中消费者获取消息、处理消息的规则和状态配置，订阅关系由消费者组动态注册到服务端，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。
通过配置订阅关系，可控制如下消费行为：
消息过滤规则：用于控制消费者在消费消息时，选择主题内的哪些消息进行消费，设置消费过滤规则可以高效地过滤消费者需要的消息集合，灵活根据不同的业务场景设置不同的消息接收范围。
消费状态：RocketMQ 服务端默认提供订阅关系持久化的能力，即消费者分组在服务端注册订阅关系后，当消费者离线并再次上线后，可以获取离线前的消费进度并继续消费。
在 RocketMQ 的领域模型中，订阅关系的位置和流程如下：
1. 消息由生产者初始化并发送到 RocketMQ 服务端。
2. 消息按照到达 RocketMQ 服务端的顺序存储到主题的指定队列中。
3. 消费者按照指定的订阅关系从 RocketMQ 服务端中获取消息并消费。
订阅关系一致性约束
订阅关系一致性要求同一消费者组内的所有消费者实例所订阅的主题必须和过滤规则完全一致。这里涉及三个约束条件，具体来看：
消费组必须一致
对于大多数分布式应用来说，一个消费组下通常会挂载多个 Consumer 实例，订阅关系一致性的约束范围就是同一个消费组下的所有消费者。
订阅的主题必须一致
同一个消费组下的所有消费者订阅的主题必须一致，例如：consumer1 订阅 TopicA 和 TopicB，consumer2 也必须订阅 TopicA 和 TopicB，不能只订阅 TopicA、只订阅 TopicB 或订阅 TopicA 和 TopicC。
过滤规则必须一致
同一个消费组下的所有消费者过滤规则必须一致，包括 Tag 的数量和 Tag 的顺序，例如：consumer1 订阅 TopicB 且 Tag 为 Tag1||Tag2，consumer2 订阅 TopicB 的 Tag 也必须是 Tag1||Tag2，不能只订阅 Tag1、只订阅 Tag2 或者订阅 Tag2||Tag1。
订阅关系一致的示例
下图展示了常见的两种正确的订阅关系，分别对应两种情况：
正确示例一：单 Topic 单 Tag 订阅
如图中 Group 1 的 consumer1 和 consumer2 都订阅 TopicA 中所有消息。
正确示例二：单 Topic 多 Tag 订阅
如图中 Group 2 的 consumer1 和 consumer2 都订阅 TopicA 中 Tag 为 Tag1 或 Tag2 的消息，且顺序都是 Tag1||Tag2。
订阅关系不一致的示例
下图展示了三种典型错误的订阅关系，分别对应三种情况：
错误示例一：订阅 Topic 不同
如图中 Group 1 的 consumer1 和 consumer2 分别订阅了不同的 Topic。
错误示例二：订阅 Topic 相同但 Tag 不同
如图中 Group 2 的 consumer1 订阅 TopicA 的 Tag1，consumer2 订阅 TopicA 的 Tag2。
错误示例三：订阅 Topic 和 Tag 都相同但 Tag 顺序不同
如图中 Group 3 的 consumer1 订阅 TopicA 的 Tag1||Tag2，consumer2 订阅 TopicA 的 Tag2||Tag1，这里虽然订阅 Tag 都相同但顺序不同，也不符合订阅一致性约束。
订阅关系不一致的影响
如果订阅关系不一致，可能导致消息消费逻辑混乱，消息被重复消费或遗漏。
如下示例，这里我们启动两个 consumer，它们都属于消费组 Group1，都订阅了主题 TopicA，但是 consumer1 订阅的是 Tag1 的消息，consumer2 订阅的是 Tag2 的消息。
String topic = "TopicA";String consumerGroup = "Group1";FilterExpression filterExpressionTag1 = new FilterExpression("Tag1", FilterExpressionType.TAG);PushConsumer consumer1 = provider.newPushConsumerBuilder().setConsumerGroup(consumerGroup).setSubscriptionExpressions(Collections.singletonMap(topic, filterExpressionTag1)).build();FilterExpression filterExpressionTag2 = new FilterExpression("Tag2", FilterExpressionType.TAG);PushConsumer consumer2 = provider.newPushConsumerBuilder().setConsumerGroup(consumerGroup).setSubscriptionExpressions(Collections.singletonMap(topic, filterExpressionTag2)).build();
这种情况下两个客户端分别会有什么表现呢？
consumer1 消费者无法消费 Tag 值为 Tag1 的消息，因为 consumer1 消费者在拉取消息时，服务端该消费组的订阅信息中 Tag 值为 Tag2，经过服务端过滤后，consumer1 消费者拉取到的消息的 Tag 值都是 Tag2 , 但消费者在收到消息后也会进行过滤，这部分消息也都被过滤掉了。
consumer2 消费者只能消费部分 Tag 值为 Tag2 的消息，因为只有部分队列分配给了consumer2。
但是在服务端同一个消费组内的各个消费者客户端的订阅信息会相互被覆盖，所以这种消费状态非常混乱，上面示例中 consumer1 和 consumer2 的消费情况可能也会发生切换。
腾讯云优化实践
订阅关系不一致会直接导致消息消费异常，需快速定位并修复。TDMQ RocketMQ 版控制台提供可视化检测能力，无需人工逐个排查日志或配置，通过控制台 3 步即可完成问题的发现、定位、修复，降低运维复杂度。
1. 一键检测
自动对比消费组内所有客户端的订阅配置，高亮显示出不一致的订阅关系。
2. 精准定位
点击不一致详情，直接关联到具体客户端实例，可快速判断出非预期的订阅关系所在的实例。
3. 闭环验证
修订后实时同步订阅关系一致性状态，确保消费组订阅关系符合预期。
常见问题
哪些典型场景会出现订阅关系不一致？
环境未完全隔离，非生产环境和生产环境使用了相同的 Group 订阅不同的 Topic。
业务代码修改了订阅关系，在灰度和版本发布过程中，新旧版本消费者共存。
使用建议
订阅关系一致性是 RocketMQ 消息系统消费行为正确的核心保障：
1. 核心约束：同一消费组内的所有消费需严格遵循主题一致、过滤规则一致（含 Tag 顺序） 的原则，任一环节的差异均可能导致漏消费消息。
2. 腾讯云能力：依托控制台的一键检测、精准定位、闭环验证功能，开发者可快速识别异常实例并修复，将传统人工排查耗时从小时级缩短至分钟级。
3. 最佳实践：建议通过消费组隔离、动态配置强校验、多 Topic 场景分层治理等策略，从源头规避订阅关系不一致风险。
文档反馈