rocketmq 连接异常 senddefaultimpl call timeout

  • 作者: 凯哥Java(公众号:凯哥Java)
  • RocketMQ
  • 时间:2022-10-18 17:27
  • 4659人已阅读
简介 rocketmq 连接异常 senddefaultimpl call timeout

🔔🔔好消息!好消息!🔔🔔

 如果您需要注册ChatGPT,想要升级ChatGPT4。凯哥可以代注册ChatGPT账号代升级ChatGPT4

有需要的朋友👉:微信号 kaigejava2022

在使用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地址
        producer.setNamesrvAddr("192.168.50.131:9876");
        //设置发送超时时间:
        producer.setSendMsgTimeout(10000);

        //3:启动prodicer
        producer.start();
        //4:创建消息对象,指定主题Topic、Tag和消息体
        for (int i = 0; i < 10; i++) {
            Message message = new Message();
            message.setTopic("base-sync-topic");
            message.setTags("Tag1");
            message.setBody(("from sync-main"+i).getBytes());
            //5:发送消息
            SendResult result = producer.send(message);

            SendStatus status = result.getSendStatus();
            String msgId = result.getMsgId();
            int queueId = result.getMessageQueue().getQueueId();
            String offsetMegId = result.getOffsetMsgId();
            long offset = result.getQueueOffset();
            String sendResultMsg = "同步消息第"+i+"个发送状态:"+status+"\t"+"消息id:"+msgId+"\t 消费者队列id:"+queueId +"\t offsetMegId:"+offsetMegId+"\t offset:"+offset;
            System.out.println(sendResultMsg);
        }
        //6:关闭生产者producer
        producer.shutdown();
    }
}
  //设置发送超时时间:
        producer.setSendMsgTimeout(10000);

这个比较重要。凯哥设置了这个超时时间就ok了

TopTop