首页 > TAG信息列表 > lockEntry

RocketMq总结(六) -- 顺序消息

一 消息拉取 顺序消费和非顺序消费的第一个区别是,拉取消息的时候和非顺序消息有区别 if (processQueue.isLocked()) { if (!pullRequest.isLockedFirst()) { final long offset = this.rebalanceImpl.computePullFromWhere(pullRe

一次 RocketMQ 顺序消费延迟的问题定位

# 一次 RocketMQ 顺序消费延迟的问题定位 ## 问题背景与现象 昨晚收到了应用报警,发现线上某个业务消费消息延迟了 54s 多(从消息发送到MQ 到被消费的间隔): ``` 2021-06-30T23:12:46.756 message processing is incredibly delayed! (Current delay time: 54725, incredible delay c

一次 RocketMQ 顺序消费延迟的问题定位

一次 RocketMQ 顺序消费延迟的问题定位 问题背景与现象 昨晚收到了应用报警,发现线上某个业务消费消息延迟了 54s 多(从消息发送到MQ 到被消费的间隔): 2021-06-30T23:12:46.756 message processing is incredibly delayed! (Current delay time: 54725, incredible delay count in 10