请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

消费模式问题

@RocketMQMessageListener(consumerGroup = “test-group”, topic = “addmsg”,
// consumeMode = ConsumeMode.ORDERLY,
// messageModel = MessageModel.CLUSTERING)
messageModel = MessageModel.BROADCASTING)

老师碰到一个问题我在这个注解上修改了messageModel这个参数测试广播和集群模式的效果。然后在idea里启动的多个usercenter实例去消费信息,但是发现2种模式下我这些实例都同时收到了信息。这里有个疑问集群模式下不是其中一个实例拿到信息吗?

正在回答

1回答

clustering模式准确来说,是同一个消费组下,只会有1个实例收到消息。

建议检查下您的消费者的多个实例的consumerGroup是否相同。

0 回复 有任何疑惑可以回复我~
  • 提问者 IssacXD #1
    好的,谢谢大目老师,我去检查一下
    回复 有任何疑惑可以回复我~ 2020-08-25 10:11:49
问题已解决,确定采纳
还有疑问,暂不采纳
意见反馈 帮助中心 APP下载
官方微信