在使用RocketMQ时，发现同一个consumerGroup下的不同topic在初始化不同的DefaultMQPushConsumer时会相互覆盖前面的topic导致先初始化的topic无法消费，所以总结了以下场景下消费者的消费情况
假设现在有一个producer和两个consumer，分别为consumer1和consumer2，consumer1和consumer2依据topic的个数初始化DefaultMQPushConsumer。
consumer1和consumer2配置相同的单个consumerGroup，单个topic和tags
此种场景下，consumer1与consumer2能正常消费到producer发送的所有消息，并遵循broker端的lb策略，consumer1与consumer2消费到的消息之和等于producer发送的消息数目
consumer1和consumer2配置相同的单个consumerGroup，多个topic和tags
此种场景下，若客户端初始化DefaultMQPushConsumer依据topic的数量进行初始化，则consumer1与consumer2与broker建立心跳链接时会相互覆盖相同consumerGroup下的消费topic信息，这样会导致部分消息消费不了。
详情见RecketMQ-同一个订阅组下有多个Topic，消息能发送到Topic中，但无法被监听到 - CSDN博客
若想保证消费同一consumerGroup下的多个topic和tag的消息，客户端在初始化时需要依据consumerGroup的数量只初始化一个DefaultMQPushConsumer实例，之后在设置consumer订阅的topic和tag时，多次设置topic和tag的组合，即
this.consumer.subscribe(topicA, tagsA);
this.consumer.subscribe(topicB, tagsB);
...
DefaultMQPushConsumerImpl中关于subscribe源码实现
public void subscribe(String topic, String subExpression)throws MQClientException {
try {
SubscriptionData subscriptionData = FilterAPI.buildSubscriptionData(this.defaultMQPushConsumer.getConsumerGroup(), topic, subExpression);
this.rebalanceImpl.getSubscriptionInner().put(topic, subscriptionData);
if (this.mQClientFactory !=null) {
this.mQClientFactory.sendHeartbeatToAllBrokerWithLock();
}
}catch (Exception var4) {
throw new MQClientException("subscription exception", var4);
}
}
由DefaultMQPushConsumerImpl中对subscribe的实现源码可知，不同topic和对应的tag以key-value的形式存在于subsCriptionInner中，该对象的类型为ConcurrentHashMap，也就意味着如果重复注册相同topic，会覆盖之前关于相同topic的订阅，这点在使用单个DefaultMQPushConsumer要注意。
consumer1和consumer2配置相同的多个consumerGroup，topic和tags与consumerGroup对应
此种情况相当于多个情况1的实现，消费者consumer1和consumer2可以正确消费所有消息。
consumer1和consumer2配置相同的单个consumerGroup，单个topic和多个tag
此种情况要说一下为啥RocketMQ对consumerGroup和topic都不追加s定义，只对tag用复数词修饰。这是因为tags表示的意思为一个或多个tag的意思，RocketMQ自身会根据tags字符串中的分隔符“|”来订阅不同的tag。实际上在我们定义topic和tags时也就默认了一对多的情况，并不用针对多个tag设置多个相同名字的topic，这样反而会出现情况2中的tag覆盖，丢失部分消息。
所以此种情况下与1情况相同，consumer1和consumer2能正确消费所有消息。
consumer1和consumer2配置不同的多个consumerGroup，相同的单个topic和tags
此种情况用于consumer1和consumer2需要同时消费所有producer发出的消息。consumer1和consumer2消费的消息之和等于producer生产的消息的2倍，所有发出的消息都会同时出现在consumer1和consumer2的消费队列中
网友评论