今天部署完RocketMq,使用客户端进行发送消息发现,异常如下:
RemotingTooMuchRequestException: sendDefaultImpl call timeout 这肯定是produce没有连上Rocketmq的broker,按照rocketmq的官网实例进行检查,发现跟例子没啥区别,题外话:这里要吐槽一下阿里相关开源产品的文档了。是在是写的太简单太烂了。
最终找到解决方案,
修改broker.conf,增加工位ip配置信息 namesrvAddr=公网IP:9876 brokerIP1=公网IP 需要在启动Mqnamesrv与mqbroker的时候增加公网IP的指定 nohup sh /usr/local/rocketmq/bin mqnamesrv -n "公网IP:9876" & nohup sh mqbroker -n 公网IP:9876 -c ../conf/broker.conf &
再次测试,通过RocketMq-console观察,发现msg里已经有发送的消息数据。