RocketMQ异常重试的时候,为何会触发相同群组的其他不同的Tag监听?-灵析社区

CO_co

我一个springboot项目里,有2个相同主题相同群组,不同tag的监听。 为了测试异常重试机制,我在监听tagA的那个逻辑里,触发一个异常,希望RocketMQ可以重发异常到这个tagA监听里。 结果神奇的是,日志显示tagA逻辑触发了异常,接下来居然是tagB被触发了,但是我压根没发送过tagB的消息啊。。。。而且tabB的逻辑还一直被触发了多次。 另外,如果tagA的逻辑不触发异常,则tagB的监听不会被触发。RocketMQ也没改过什么,应该不是广播模式。 * * * 这是发送的代码 rocketMQTemplate.syncSend(g_mqTopic + ":tagA", "123"); 这个是监听的逻辑 @RocketMQMessageListener(topic = "${my.mqTopic}", selectorExpression = "tagA", consumerGroup = "${my.mqTopic}-consumergroup1") @RocketMQMessageListener(topic = "${my.mqTopic}", selectorExpression = "tagB", consumerGroup = "${my.mqTopic}-consumergroup1")

阅读量:149

点赞量:0

问AI
0offer糕手
原来官方有提到这个问题,是我新手了 "订阅关系一致" (https://link.segmentfault.com/?enc=plwSb4KELm%2BGp1kHgA4xig%3D%3D.m%2FDdM12AfvXYUcGDYQ%2BnxaJdzu%2F0K9FR%2BfTF8XtFdvDw%2BuA6wviJGyUFjmNwLFeSjb0fNBHIw9dorrjaGatitEn3EzvRZOtDocmUyO2BHOg%3D) 至于为什么会出现这个现象,就没解释,希望有大佬解答一下。看了一些文章,说是和"ConsumeQueue"有关