此篇呢就说浅浅的说下Mqtt Paho的重连及使用.

还是一样,咋们先看下配置项

MqttConnectionOption里的配置里有setAutomaticReconnect这个选项

它需要放入一个布尔值(Boolean)来控制开关

1.True 设定为true时,mqtt的重连机制会启动,当mqtt client掉线之后它会进入重连.

2.False 设定为false时当然是不打开.

是否打开以上选项其实我们都需要做一个东西,就是实现mqtt的回调类MqttCallbackExtended或者MqttCallback.

这里先讲一下回调类

MqttCallbackExtended是继承了MqttCallback.他们有什么不同呢.

MqttCallback接口里面只有个3方法

public interface MqttCallback {

void connectionLost(Throwable var1);

void messageArrived(String var1, MqttMessage var2) throws Exception;

void deliveryComplete(IMqttDeliveryToken var1);

}

connectionLost是在连接已经连上且丢失后走这里

messageArrived这个是消息发送到接收端时触发

deliveryComplete这个是发送完成

MqttCallbackExtended

public interface MqttCallbackExtended extends MqttCallback {

void connectComplete(boolean var1, String var2);

}

它的话是多出了一个方法connectComplete

它是在丢失重连成功后会触发该方法

看完以上的功能,我相信小伙伴们就知道为什么需要实现回调类了,然后咋们继续来看下他们的使用。

以下是在setAutomaticReconnect为True的时候使用的.为什么这样说呢,因为如果不为true的情况下,它并不会触发connectComplete(原因以后的篇章会讲),上代码

MqttClient client = new MqttClient;

......

client.setCallback(new MqttCallbackExtended() {

@Override

public void connectComplete(boolean b, String s) {

System.out.println("丢失重连成功");

}

@Override

public void connectionLost(Throwable throwable) {

log.error("connect lost");

int i = 3;

while (true) {

if (i < 0) {

//这里是我自己为了失败3次后告警使用

WarmingUtil.getwarming("2", "mqtt丢失问题");

break;

}

if (!client.isConnected()) {

System.out.println("***** client to connect *****");

try {

//这个是30秒后重连

Thread.sleep(30000);

client.reconnect();

} catch (Exception e) {

e.printStackTrace();

continue;

}

i--;

}

if (client.isConnected()) {

System.out.println("***** connect success *****");

break;

}

}

}

@Override

public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {

}

@Override

public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

}

});

......

如果为false就new 一个MqttCallback方法,然后再实现它的子类,然后实现自己想要的重连方式就好了.

但是有个地方要注意的就是这里不是使用reconnect()方法了,而是使用connect()方法来重连.

以上就可以实现mqtt掉线重连了.

还有一个需要注意的就是,如果你在消息发送到达接收端的时候,即接收端返回信息,触发messageArrived方法的时候不建议在方法里调用其他方法或者操作其他事情,因为这样会导致mqtt掉线的问题,这个博主也是屡试不爽哈哈,最后找到原因,详见链接(未写)