解决spring-integration-mqtt频繁报Lost connection错误问题
更新时间：2023年03月11日 11:00:22 作者：VictorBu
这篇文章主要介绍了解决spring-integration-mqtt频繁报Lost connection错误问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
问题描述
在之前的博客介绍了如何在 Spring Boot 集成 MQTT，后面使用中没有发现问题，最近发现一直报错：
Lost connection: Connection lost; retrying...
Lost connection: 已断开连接; retrying...
解决过程
网上说是因为 client ID 重复，最开始是不相信的，因为我测试只启动了一个客户端。但是却怎么都定位不到异常原因，用重新回到 client ID 重复的这个思路上来：
因为程序里同时作为订阅者和发布者，就怀疑订阅和发布服务是不是单独建立的连接，抱着试试看的想法试了一下，结果果然是这个原因
原代码：
/* 发布者 */
@Bean
@ServiceActivator(inputChannel = OUTBOUND_CHANNEL)
public MessageHandler getMqttProducer() {
MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(clientId, getMqttClientFactory());
messageHandler.setAsync(true);
messageHandler.setDefaultTopic(defaultTopic);
messageHandler.setDefaultRetained(defaultRetained);
messageHandler.setDefaultQos(defaultProducerQos);
return messageHandler;
}
/* 订阅者 */
@Bean
public MessageProducer getMqttConsumer() {
MqttPahoMessageDrivenChannelAdapter adapter =
new MqttPahoMessageDrivenChannelAdapter(clientId, getMqttClientFactory(), consumerTopics);
adapter.setCompletionTimeout(completionTimeout);
adapter.setConverter(new DefaultPahoMessageConverter());
adapter.setQos(defaultConsumerQos);
adapter.setOutputChannel(inboundChannel());
return adapter;
}
订阅者和发布者使用的是相同的 client ID，修改后代码：
/* 发布者 */
@Bean
@ServiceActivator(inputChannel = OUTBOUND_CHANNEL)
public MessageHandler getMqttProducer() {
MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(clientId + "_producer", getMqttClientFactory());
messageHandler.setAsync(true);
messageHandler.setDefaultTopic(defaultTopic);
messageHandler.setDefaultRetained(defaultRetained);
messageHandler.setDefaultQos(defaultProducerQos);
return messageHandler;
}
/* 订阅者 */
@Bean
public MessageProducer getMqttConsumer() {
MqttPahoMessageDrivenChannelAdapter adapter =
new MqttPahoMessageDrivenChannelAdapter(clientId + "_consumer", getMqttClientFactory(), consumerTopics);
adapter.setCompletionTimeout(completionTimeout);
adapter.setConverter(new DefaultPahoMessageConverter());
adapter.setQos(defaultConsumerQos);
adapter.setOutputChannel(inboundChannel());
return adapter;
}
总结
虽然目前解决了这个问题，但是为什么会单独建立两个连接的原因还未找到；另外，一个程序两个连接还是感觉怪怪的，不知道还有没有更优的处理方案。
希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了通过spring注解开发,简单测试单例和多例区别，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-08-08
Spring Cloud 整合Apache-SkyWalking实现链路跟踪的方法
这篇文章主要介绍了Spring Cloud 整合Apache-SkyWalking链路跟踪的示例代码，代码简单易懂，通过图文相结合给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-06-06
Spring Security OAuth Client配置加载源码解析
这篇文章主要为大家介绍了Spring Security OAuth Client配置加载源码解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-07-07
这篇文章主要介绍了JAVA 修饰符的的相关资料，文中代码非常详细，帮助大家更好的理解和学习，感兴趣的朋友可以了解下2020-06-06
动态代理指的是，代理类和目标类的关系在程序运行的时候确定的，客户通过代理类来调用目标对象的方法，是在程序运行时根据需要动态的创建目标类的代理对象。本文将通过案例详细讲解一下Java动态代理的原理及实现，需要的可以参考一下2022-08-08
这篇文章主要介绍了Java实现文件切割拼接的实现代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-11-11
解释为什么Java中“1000==1000”为false而”100==100“为true
在日常编程中,我们经常遇到一些看似简单却隐藏着复杂逻辑的问题,这篇文章主要介绍了解释为什么Java中“1000==1000”为false而”100==100“为true,需要的朋友可以参考下2024-01-01
本文讲述了如何安装Nacos 2.0.3版本,包括下载、解压、配置和启动服务的步骤,结合图文给大家讲解的非常详细,感兴趣的朋友一起看看吧2024-12-12
这篇文章主要介绍了解决mybatis中的mapper命名问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-06-06
这篇文章主要介绍了idea导入项目不显示maven侧边栏的问题及解决方法,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-07-07
最新评论