RocketMQ远程连接报错 sendDefaultImpl call timeout

错误信息

Startorg.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:612)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1253)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1203)
	at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
	at com.cmit.fabric.java.rocketmq.RocketMQTest.producer.ProducerTest.producerStart(ProducerTest.java:39)
	at com.cmit.fabric.java.rocketmq.RocketMQTest.producer.ProducerTest.main(ProducerTest.java:27)

解决办法

在conf/broke.conf添加
	namesrvAddr = 外网访问地址:9876
	brokerIP1=外网访问地址

启动命令改变

启动namesrv
	sh bin/mqnamesrv -n 外网访问地址:9876
启动broker
	sh bin/mqbroker -n 外网访问地址:9876 -c conf/broker.conf autoCreateTopicEnable=true
上一篇:Mybatis接口Mapper内的方法为啥不能重载吗?深度好文


下一篇:03_生产者-客户端开发