rocketmq无法发送消息失败问题。connect to <公网ip:10911> failed_rocketmq 10911-CSDN博客

1、服务器开放端口:9876,10909,10911,10912。

2、conf/broker.conf文件。最下面加上两个配置

                namesrvAddr=公网ip:9876
                  brokerIP1=公网ip

3、启动时使用配置文件

在bin目录下启动。命令如下

        nohup ./mqnamesrv -n 公网ip:9876 &

        nohup ./mqbroker -n 公网ip:9876 -c ../conf/broker.conf autoCreateTopicEnable=true &


记录问题。

SendResult result = producer.send(message, 10000);

还需要设置timeout

-c ../conf/broker.conf 非常重要

Logo

技术共进,成长同行——讯飞AI开发者社区

更多推荐