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代码