Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

broker中某个队列不消费,什么情况会触发? #96

Closed
powerfulsnail opened this issue Feb 23, 2019 · 6 comments
Closed

broker中某个队列不消费,什么情况会触发? #96

powerfulsnail opened this issue Feb 23, 2019 · 6 comments

Comments

@powerfulsnail
Copy link

场景:服务器A启动8个生产者不停的分别往8个不同的topic发送消息,同时服务器B启动8个不同group组的消费者不停的分别消费这8个topic,消费一段时间后出现某个队列中的消息不消费了,慢慢个别队列也停止消费。

出现2019-Feb-23 23:52:51.464556:no response got for opaque:920486
2019-Feb-23 23:52:51.464588:send msg, callback timeout, opaque:920486, sendTimes:1, maxRetryTimes:1错误后,broker-c, 的queueId=3这个队列就找不到了,即消费不到该队列中的消息。

日志:
2019-Feb-23 23:52:51.461848:FOUND:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-c, queueId=3] with size:1, nextBeginOffset:171597
2019-Feb-23 23:52:51.461897: offset result is:171597, m_queueOffsetMax is:171596, msgs size:1
2019-Feb-23 23:52:51.461932:remove these msg from m_msgTreeMap, its offset:171596
2019-Feb-23 23:52:51.461958:pullMessageAsync set opaque:920485, mq:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-b, queueId=1]
2019-Feb-23 23:52:51.462000:before insert declared filed,MAP SIZE is:2
2019-Feb-23 23:52:51.462013:invokeAsync success, addr:202.15.8.161:10911, code:11, opaque:920485
2019-Feb-23 23:52:51.462057:after insert declared filed, MAP SIZE is:12
2019-Feb-23 23:52:51.462082:total msg info are:ALIYUN171597groupaa0083231715971550934443954150007MQ_TOPIC_EFC_DEVICE_STATUS, size is:77
2019-Feb-23 23:52:51.462163:pullMessageAsync set opaque:920486, mq:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-c, queueId=3]
2019-Feb-23 23:52:51.462207:invokeAsync success, addr:202.15.8.162:10911, code:11, opaque:920486
2019-Feb-23 23:52:51.463762:fd:23, totalLen:453, bytesInMessage:449
2019-Feb-23 23:52:51.463807:had received all data with len:453 from fd:23
2019-Feb-23 23:52:51.463829:broker addr: 202.15.8.160, broker port: 10911
2019-Feb-23 23:52:51.463849:brokerAddr:202.15.8.160:10911
2019-Feb-23 23:52:51.463872: too little data received with sum = 0
2019-Feb-23 23:52:51.463914:code:0, remark:JAVA, version:277, opaque:920474, flag:1, remark:FOUND, headLen:226, bodyLen:219
2019-Feb-23 23:52:51.463975:processResponseCommand, code:11,opaque:920474, maxRetryTimes:1, retrySendTimes:1
2019-Feb-23 23:52:51.464004:cancelTimerCallback: opaque:920474
2019-Feb-23 23:52:51.464044:handleAsyncPullForResponseTimeout opaque:920474, e_code:0, msg:Success
2019-Feb-23 23:52:51.464057:PullRequest: putMessage m_queueOffsetMax:163072
2019-Feb-23 23:52:51.464136:FOUND:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-a, queueId=0] with size:1, nextBeginOffset:163073
2019-Feb-23 23:52:51.464158:m_queueOffsetMax is:163072
2019-Feb-23 23:52:51.464211: offset result is:163073, m_queueOffsetMax is:163072, msgs size:1
2019-Feb-23 23:52:51.464234:remove these msg from m_msgTreeMap, its offset:163072
2019-Feb-23 23:52:51.464277:before insert declared filed,MAP SIZE is:2
2019-Feb-23 23:52:51.464331:after insert declared filed, MAP SIZE is:12
2019-Feb-23 23:52:51.464352:total msg info are:ALIYUN163072groupaa0083201630731550934443954
150007MQ_TOPIC_EFC_DEVICE_STATUS, size is:77
2019-Feb-23 23:52:51.464434:pullMessageAsync set opaque:920486, mq:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-a, queueId=0]
2019-Feb-23 23:52:51.464471:addTimerCallback:erase timerCallback opaque:920486
2019-Feb-23 23:52:51.464507:handleAsyncPullForResponseTimeout opaque:920486, e_code:0, msg:Success
2019-Feb-23 23:52:51.464509:invokeAsync success, addr:202.15.8.160:10911, code:11, opaque:920486
2019-Feb-23 23:52:51.464556:no response got for opaque:920486
2019-Feb-23 23:52:51.464588:send msg, callback timeout, opaque:920486, sendTimes:1, maxRetryTimes:1
2019-Feb-23 23:52:51.464616:pullrequest for:MessageQueue [topic=MQ_TOPIC_EFC_DEVICE_STATUS, brokerName=broker-a, queueId=0] occurs exception, reproduce it
2019-Feb-23 23:52:51.464640:eraseTimerCallback: opaque:920486
2019-Feb-23 23:52:51.464669:handleAsyncPullForResponseTimeout opaque:920486, e_code:0, msg:Success

@ifplusor
Copy link
Contributor

@powerfulsnail what's version you use?

@powerfulsnail
Copy link
Author

最新的rocketmq-cpp1.2.1

@ifplusor
Copy link
Contributor

@powerfulsnail we have two versions, 1.2.1 and 1.2.1-rc1. notice tag, not title in release. 1.2.1 have some bugs, we fixed them in rc1

@powerfulsnail
Copy link
Author

用的是rc1,这个问题应该与版本没关系,我想知道这个问题是什么原因触发的。

@easyforgood
Copy link

用的是rc1,这个问题应该与版本没关系,我想知道这个问题是什么原因触发的。

这个问题找到原因了嘛?

@pekingzlj
Copy link

@ifplusor 我也遇到了这个问题,请问这个问题解决了吗

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

5 participants