rocketmq 连接异常 senddefaultimpl call timeout
2023-06-13 09:15:57 时间
在使用Java发送rocketmq消息的时候。错误:rocketmq 连接异常 senddefaultimpl call timeout:
第一种情况:
修改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了
相关文章
- MongoDB 读写分离异常案例分析
- 集合线程安全问题:第一章:集合类不安全之并发修改异常
- Windows右下角小电脑网络连接图标异常的解决办法
- 第50问:从连接判断应用访问数据库的异常行为
- Java中的ConcurrentModificationException异常原因分析及解决办法1/2/3/4
- RestTemplate自定义异常白名单,连接https
- python如何自定义异常
- 安装异常处理ubuntu18.04报:failed to load ldlinux.c32的问题及解决方法
- Redis连接超时异常的处理方法
- Linux端口连接异常解决方案(linux端口连不上)
- Java中的异常(Exception):什么是异常?异常产生的原因及常见的几种异常类型
- 处理Linux系统中断异常(linux中断处理)
- Linux SSH连接异常:解决方案(ssh连接不上linux)
- 郑州全员核酸检测!官方回应为何查不到核酸结果:异常有人来接
- Spring Boot 2.x 系列教程:WebFlux REST API 全局异常处理 Error Handling
- 环境提高系统安全性:结构化异常的 Linux 环境监测(结构化异常linux)
- 监控SQLServer:及时发现系统架构中的异常(监控sqlserver)
- SQL Server抛出异常:程序员的挑战(sqlserver抛异常)
- 深度探索解决网页与Redis连接异常(网页连接redis异常)
- 正常检测Redis连接情况有无异常(查看redis是否链接)
- 服务器升级后redis状态异常排查连接问题(服务器升级后redis连不上)
- 1449号异常MySQL数据库连接异常(1449异常 mysql)
- 主键死锁异常Oracle数据库如何解决(oracle修改主键死锁)
- Redis集群版连接异常解决办法(redis集群版连不上)
- 异常深入探索Redis集群中主节点异常现象分析(redis集群显示主节点)
- 谨慎操作Redis连接异常缓慢(redis 连接很慢)
- 红色忧患Redis连接中断异常(redis连接异常中断)
- 排查解决Redis连接失败的异常排查方案(redis连接失败的异常)
- Redis连接异常IP无法连接(redis连接不上ip)
- 异常Redis连接500异常深入探究(redis连接500)
- 分析原因Redis访问耗时异常长(redis访问时间过长)
- java实现非法访问异常示例
- Python中捕捉详细异常信息的代码示例