本人沒有用過rocketmq,對其中的原理不了解。希望哪位大神幫忙給看看
com.alibaba.rocketmq.client.exception.MQClientException: Send [1] times, still failed, cost [3003]ms, Topic: WaybillTopicBOSServer, BrokersSent: [broker-a, null, null]
See https://github.com/alibaba/RocketMQ/issues/50 for further details.
at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:578)
at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1031)
at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1025)
at com.alibaba.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:95)
at apollo.waybill.mq.producer.wms.WaybillCreateRocketMqProducer.sendMsg2Topic(WaybillCreateRocketMqProducer.java:44)
at apollo.waybill.service.manager.MongoPdWoDoMainManager.sendCreateWaybillMsg2MQ(MongoPdWoDoMainManager.java:121)
at apollo.waybill.service.service.impl.MongoPdWoDoMainServiceImpl.saveMongoPdWoTaskData(MongoPdWoDoMainServiceImpl.java:70)
at apollo.waybill.worker.schedule.DoWbPdWoWorkerTask.processWorkerTask(DoWbPdWoWorkerTask.java:156)
at apollo.waybill.worker.schedule.DoWbPdWoWorkerTask.processWorkerTask(DoWbPdWoWorkerTask.java:39)
at apollo.waybill.worker.base.AbstractBaseThreadWorkerTask.execute(AbstractBaseThreadWorkerTask.java:55)
at com.taobao.pamirs.schedule.taskmanager.TBScheduleProcessorSleep.run(TBScheduleProcessorSleep.java:221)
at java.lang.Thread.run(Thread.java:745)
Caused by: com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException: wait response on the channel <10.10.6.71:10911> timeout, 3000(ms)
at com.alibaba.rocketmq.remoting.netty.NettyRemotingAbstract.invokeSyncImpl(NettyRemotingAbstract.java:375)
at com.alibaba.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:622)
at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:306)
at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:289)
at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:679)
at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:500)
... 11 more
uj5u.com熱心網友回復:
人工置頂,在線等啊uj5u.com熱心網友回復:
大神解決了嗎?我也是偶爾出現這個錯uj5u.com熱心網友回復:
檢查下是不是磁盤空間不足uj5u.com熱心網友回復:
Caused by: org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [102114]ms, Topic: smsCMPPReportTopic, BrokersSent: [broker-b, broker-a, broker-b]See http://rocketmq.apache.org/docs/faq/ for further details. 我也遇到了。大部分時候都發送ok,偶爾出現一次。百度了一圈,沒有任何解決辦法有效。
uj5u.com熱心網友回復:
首先埠 10911~10919都放開,然后 producer.setVipChannelEnabled(false);uj5u.com熱心網友回復:
大神,找到解決方案了嗎?uj5u.com熱心網友回復:
大神,我也是,你解決了嗎轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/63169.html
標籤:Java相關
上一篇:acm基礎題,就是過不了
