RocketMQ报错:sendDefaultImpl call timeout、No route info of this topic

Rocket搭建完成后开始整个java代码的时候启动程序后报错如下

org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:588)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1223)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1173)
	at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
	at com.flying.demo.Producer.main(Producer.java:25)

或者

Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, xxx
See http://rocketmq.apache.org/docs/faq/ for further details.
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:656)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1279)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1225)
	at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:283)
	at com.tao.rocket.base.producer.SyncProducer.main(SyncProducer.java:34)

废话不多说,遇到问题那就必须解决,这个问题就是搭建的时候服务器配置的问题!在往期文章有搭建的步骤,但是有几个细节没有注意!那就是集群ip的问题!

NameServer指定ip启动

nohup sh mqnamesrv -n "192.168.0.177:9876" &

broker指定ip
这里我以集群环境为案例,修改rocketmq-4.4.0/conf/2m-2s-sync/目录中的broker-a-s.properties、broker-a.properties、broker-b-s.properties、broker-b.properties,在配置中添加如下代码

在这里插入图片描述
指定集群中broker启动的ip

brokerIP1=本机ip

重启RocketMQ集群
在这里插入图片描述

在这里插入图片描述
从新运行java代码
在这里插入图片描述

猜你喜欢

转载自blog.csdn.net/CSDN877425287/article/details/112639575