wcf2010
2017-08-03 04:02
采纳率: 100%
浏览 8.9k
已采纳

rocketmq发送消息遇到system busy

向rocketmq队列发送消息,遇到system busy。提示说让进行流控。这是丢入进mq的速度太快吗?理论上不应该啊。

org.apache.rocketmq.client.exception.MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while, period in queue: 202ms, size of queue: 6
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:531)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:345)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:327)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:290)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:688)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:458)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1049)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1008)
at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:204)
at com.techcenter.msgqueue.rocketmq.producer.DFProducerPipe.send(DFProducerPipe.java:85)
at com.techcenter.msgqueue.rocketmq.producer.DFProducerPipe.send(DFProducerPipe.java:47)
at com.standardsm.channelapi.filter.YtMobileDeductFilter.deduct(YtMobileDeductFilter.java:105)
at com.standardsm.channelapi.filter.YtMobileDeductFilter.dealObject(YtMobileDeductFilter.java:56)
at com.techcenter.util.chain.SimpleCommand.execute(SimpleCommand.java:20)
at org.apache.commons.chain.impl.ChainBase.execute(ChainBase.java:191)
at com.techcenter.msgqueue.SimpleMsgChain.chainExecute(SimpleMsgChain.java:46)
at com.standardsm.channelapi.listener.YtSmsSubmitTopicListener.onMessage(YtSmsSubmitTopicListener.java:61)
at com.standardsm.channelapi.listener.YtSmsSubmitTopicListener.consumeMessage(YtSmsSubmitTopicListener.java:31)
at org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest.run(ConsumeMessageConcurrentlyService.java:419)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)

  • 写回答
  • 关注问题
  • 收藏
  • 邀请回答

7条回答 默认 最新

  • sanenen 2018-12-18 09:24
    已采纳
    打赏 评论
  • gggyniriu 2017-08-14 07:57

    我也遇到此问题了,请问楼主找到原因了吗?

    打赏 评论
  • KUkaKaaa 2017-08-21 07:25

    我也遇到此问题了,请问楼主找到原因了吗?

    打赏 评论
  • 长弓77 2017-09-08 07:51

    我也遇到此问题了,请问楼主找到原因了吗?

    打赏 评论
  • weixin_40402332 2017-09-26 07:32

    我的解决方案:多起一个或多个consumer即可解决问题

    打赏 评论
  • wcf2010 2017-11-15 02:02

    生产者busy,看起来像是积压了。但是我也起了多个消费者,还是busy。目前还是没有解决。加大内存能够暂时解决。

    之前用的4.0版本。后来到4.3版本了。用默认配置。没有这个问题了。
    这个是解决broker busy的

    waitTimeMillsInSendQueue=3000

    这个是解决system busy的

    osPageCacheBusyTimeOutMills=3000

    打赏 评论
  • 十一个中文 2020-03-15 22:06

    我使用rocketmq-spring-boot-starter 生产者给 阿里云rocketmq 发消息 报

    MQBrokerException: CODE: 1 DESC: com.aliyun.openservices.ons.api.impl.authority.exception.AuthenticationException: get user info by accesskey from ALIYUN failed., com.alibaba.ons.open.auth.service.DauthServiceImpl.signatureValidate(DauthServiceImpl.java:258)
    For more information, please visit the url, http://rocketmq.apache.org/docs/faq/

    打赏 评论

相关推荐 更多相似问题