org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout 和 RocketmqRemoting closeChannel: close the connection to remote address[] result: true

 

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)

RocketMQ 一直打印 :

RocketmqRemoting closeChannel: close the connection to remote address[] result: true

docker版本:

我這里出現的主要問題是broker ip默認成了容器ip

 

需要修改成宿主機的ip 否則無法訪問到.

配置文件 在 rmq/rmq/brokerconf 目錄下，成功后會自動映射配置文件rmq/brokerconf/broker.conf 到 容器內部 路徑/etc/rocketmq/broker.conf

那么請把broker.conf中的 #brokerIP1=192.168.0.253 前面#號去掉，並且把后面的IP地址改成你的rocketmq容器宿主機IP地址,