Mqtt Paho(Java)的重连及使用

Mqtt Paho(Java)的重连及使用

此篇呢就说浅浅的说下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掉线的问题,这个博主也是屡试不爽哈哈,最后找到缘由,详见连接(未写)