赞
踩
本来项目好好的,突然出现rocketmq消息队列出现故障,查看项目日志出现以下错误:org.apache.rocketmq.client.exception.MQClientException: send message Exception For more information, please visit the url, http://rocketmq.apache.org/docs/faq/ at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendMessageInTransaction(DefaultMQProducerImpl.java:1222) at org.apache.rocketmq.client.producer.TransactionMQProducer.sendMessageInTransaction(TransactionMQProducer.java:90) at com.shinemo.miaosha.mq.MqProducer.transactionAsyncReduceStock(MqProducer.java:120) at com.shinemo.miaosha.rest.OrderController$1.call(OrderController.java:184) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.rocketmq.client.exception.MQClientException: No route info of this topic: TopicTest See http://rocketmq.apache.org/docs/faq/ for further details. at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:684) at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1342) at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1288) at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendMessageInTransaction(DefaultMQProducerImpl.java:1220) ... 7 more
运行rocketmq-console项目发现只能正常连接消息队列却查看不到任何信息,而rocketmq-console项目控制台不停打印:INFO closeChannel: close the connection to remote address[xxx.xxx.xxx.xxx:9876] result: true
遂查看了broker.conf发现公网ip并没有问题,于是kill-9
了当前消息队列。
输入:nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &
重新启动消息队列发现问题解决!!
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。