rocketmq的延时队列重复执行


生成者发送一条消息,
在消费者端
加入两个service后, 一条消息就会一直重复无限消费。
注释两个service后,只会消费一次。

消费者端用CommandLineRunner接口的run方法调用

信息量太少,看不出。你可以自己跟一下日志,看看调用栈。也许就知道了。

解决了,应该算是重复消费,在注册消息监听器时改为并发消费MessageListenerConcurrently

1 个赞