美文网首页
rocketmq 连接异常 sendDefaultImpl ca

rocketmq 连接异常 sendDefaultImpl ca

作者: 程序之道 | 来源:发表于2019-07-05 10:46 被阅读0次

安装 rocket mq 后,启动namesrver, broker 后
使用官方给出的例子,运行报错

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)

安装管理控制台后,显示发现


image.png

发现这个 ip 是我docker 的ip ,这块必须改成我服务器的本机ip

启动namesrver

nohup sh bin/mqnamesrv  -n "200.200.3.38:9876" &

启动broker ,强制加上本机ip

echo 'brokerIP1=200.200.3.38' > conf/broker.properties 
nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.properties autoCreateTopicEnable=true &

再运行程序,不报错了
吐槽阿里的rocketmq , 文档写得太差了,而且不搞个中文的文档福利国人,

相关文章

网友评论

      本文标题:rocketmq 连接异常 sendDefaultImpl ca

      本文链接:https://www.haomeiwen.com/subject/ovdshctx.html