ROCKETMQ

rocketmq 连接异常 senddefaultimpl call timeout

rocketmq 连接异常 senddefaultimpl call timeout

在使用Java发送rocketmq消息的时候。错误:rocketmq 连接异常 senddefaultimpl call timeout:

b62e4bedf6001857035c885979c0d612.jpg

第一种情况:

修改broker 的配置如下,注意brokerIP1 这个配置必须有,不然 rocketmq-console 显示依然是内网地址

 brokerIP1=外网ip
 #nameServer地址,分号分割
 namesrvAddr=外网ip1:9876;外网ip2:9870

第二中情况:

如果链接的是docker中的mq的话,需要设置超时时间。因为可能是超时导致的。

public class SyncProducer {

    public static void main(String[] args) throws Exception {
        //1:创建消息生产者producer,并指定生产者组名
        DefaultMQProducer producer = new DefaultMQProducer("group1");
        //2:制定nameserver地址
        

原创不易,完成人机校验,阅读全文

相关推荐