代码样例

import org.eclipse.paho.client.mqttv3.*;public class ConnectMQTT {public void connectMQtt() throws MqttException {MqttConnectOptions options = new MqttConnectOptions();//心跳时间限定为30至1200秒options.setKeepAliveInterval(120);options.setConnectionTimeout(5000);options.setAutomaticReconnect(true);options.setUserName("username");options.setPassword("password".toCharArray());/*设置重连*/options.setAutomaticReconnect(true);IMqttClient client = new MqttClient("url", "clientId");client.setCallback(callback);// 建立连接client.connect(options);}private static MqttCallback callback = new MqttCallbackExtended() {/*** 连接成功回调-可以在重新连接成功时，重新订阅topic* @param reconnect* @param serverURI*/@Overridepublic void connectComplete(boolean reconnect, String serverURI) {System.out.println("Mqtt client connected. address:" + serverURI);}@Overridepublic void connectionLost(Throwable cause) {cause.printStackTrace();System.out.println("Connection lost.");}/*** 接受消息处理* @param topic* @param message* @throws Exception*/@Overridepublic void messageArrived(String topic, MqttMessage message) throws Exception {System.out.println("Receive mqtt topic:" + topic + ", message:" + message);}@Overridepublic void deliveryComplete(IMqttDeliveryToken token) {System.out.println("Mqtt message deliver complete.");}};}

代码解析

设置重连

需要设置automaticReconnect为true,默认是不支持重连机制的，当设置为true时，当连接断开时，会进行重新。客户端将尝试重新连接到服务器。它一开始会等待1秒它尝试重新连接，对于每一次失败的重新连接尝试，延迟将加倍直到它在2分钟，此时延迟将停留在2分钟

/*
设置重连*/
options.setAutomaticReconnect(true);

问题说明

1、在开发时设置automaticReconnect未true，重新连接成功后，会丢失订阅相关信息。
原因：因cleanSession参数默认为true，在重连成功后，会丢失订阅消息。
修改：可以将cleanSession参数设置为false，也可以在重连成功后重新订阅topic

我则是在重连成功时重新订阅topic。

MQTT-Eclipse paho mqtt重连机制相关推荐

Eclipse Paho MQTT Python Client 使用手册
Eclipse Paho MQTT Python Client 使用手册原文地址:https://www.cooooder.com/archives/20210303 目录介绍环境准备快速开 ...
MQTT与paho.mqtt
MQTT协议采用发布/订阅消息模式使用TCP/IP提供网络连接三种消息发布服务质量QoS,消息推送的原则,服务器维护难度递增至多一次至少一次只有一次主题的分割符与通配符分割符" ...
MQTT客户端paho.mqtt.XXX
1. MQTT客户端C代码库 C语言库:https://github.com/eclipse/paho.mqtt.c 1.1 C源码下载构建 # centos7 OS 方法一 $ git clone ...
paho架构_GitHub - yanzhangfeng/paho-mqtt: Eclipse Paho MQTT C/C++ client for Embedded platforms
paho-mqtt 1.介绍 Paho MQTT 是 Eclipse 实现的基于 MQTT 协议的客户端,本软件包是在 Eclipse paho-mqtt 源码包的基础上设计的一套 MQTT 客户端程 ...
paho mqtt java_MQTT之Eclipse.Paho源码(一)--建立连接
写在前面通过上一个章节MQTT系列---Java端实现消息发布与订阅的介绍,我们已经基本构建出一个可以简单通信的MQTT生产和消费服务,并且具备基本的发布/订阅消息功能.那么从本章开始,我们将从源代 ...
paho架构_MQTT系列最终章-Paho源码分析(三)-心跳与重连机制
写在前面通过之前MQTT系列-Eclipse.Paho源码分析(二)-消息的发送与接收的介绍,相信仔细阅读过的小伙伴已经对Eclipse.Paho内部发送和订阅消息的流程有了一个较为清晰的认识,今天 ...
MQTT-Eclipse paho mqtt源码分析-连接MQTT Broker
Eclipse paho mqtt源码分析 MQTT paho mqtt 源码分析 org.eclipse.paho.client.mqttv3.MqttClient MQTT MQTT(消息队列遥测 ...
小程序paho.mqtt连接微消息队列 MQTT 版
物联网项目现在越来越多,MQTT的使用场景也越来越广泛,同时遇到的技术问题也是越来越复杂. 最近在做一个小程序连接阿里云的微消息队列MQTT版,说实话,通过这次debug,发现阿里的技术文档很多方面不 ...
linux im6q交叉编译paho.mqtt.c
工具链问题本来编译一下paho应该是没大问题的,反倒是cortexa9hf-vfp-neon-poky-linux-gnueabi这个工具链使用上出问题了从开发板开发那边拿到的或者直接从nxp社区 ...
Paho mqtt C语言库介绍
目录 Paho库目录文件介绍 Paho库常用函数介绍 MQTTConnectClient中的常用函数 MQTTConnectServer中的常用函数 MQTTDeserializePublish中的常 ...

MQTT-Eclipse paho mqtt重连机制