小组Java
  • rocketmq的无序模式和有序模式的使用的问题

    08/07 西瓜酱 1 评论

1、(有序情况)ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT 需要用此状态值的时候一定要考虑一直等待的情况。如果程序上因为数据或业务异常返回此状态,重新消费消息的时候非常大可能还是此状态,会导致此消息一直在消息,直接阻塞后面需要消费的消息。

2、(有序情况)当前消息被某个订阅组重新消费了几次,MessageExt.reconsumeTimes 的值一直为0。

1 收藏


直接登录
最新评论