Android(安卓)Mqtt重连的一个小问题

MQTT服务器端有很多开源库，但android端大部分用的都是eclipse的paho。paho是很好用的一个mqtt框架，但在重连上有需要注意的地方。假如你在初始化的时候，设置了如下的代码：

 MqttAndroidClient mqttAndroidClient = new MqttAndroidClient(getApplicationContext(), 服务器地址, 设备ID); MqttConnectOptions mqttConnectOptions = new MqttConnectOptions(); mqttConnectOptions.setAutomaticReconnect(true); mqttAndroidClient.connect(mqttConnectOptions, null, new IMqttActionListener() {                @Override                public void onSuccess(IMqttToken asyncActionToken) {               //连接成功                }                @Override                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {                  //连接失败                }            });

那么，当发生网络断开或者异常，心跳包返回异常的时候，会自动进行重连，这是没有问题的。但是，这是针对于服务器端已经在正常运行的情况下。假如第一次访问的时候，服务器宕机了，或者其他情况，无法连接上服务器，那么这个重连就会失效。也就是不会自动进行断线重连。当几分钟后服务器恢复正常的时候，客户端也仍然处于离线状态。

 MqttCallbackExtended callbackExtended = new MqttCallbackExtended() {           @Override        public void connectComplete(boolean reconnect, String serverURI) {            if (reconnect) {               //当发生断线之后又重新连接的情况，reconnect会返回true，初次连接成功返回的是false            }        }        @Override        public void connectionLost(Throwable cause) {          //连接异常将会回调这个方法        }    };

上图这个对象是mqttclient的回调函数，断线重连的操作就是基于这个对象的connectComplete方法。但需要注意的是，假设发生我刚才所说的那样的情况，connectComplete不会回调，因为它一定会在至少第二次连接成功的时候才会调用。而connectionLost这个方法的Throwable会返回空。同时回调IMqttActionListener的onFailure方法。这个时候，我们需要自己进行一些断线重连的操作。我们需要在IMqttActionListener的onFailure方法中做一些额外处理。

 mqttAndroidClient.connect(mqttConnectOptions, null, new IMqttActionListener() {                @Override                public void onSuccess(IMqttToken asyncActionToken) {               //连接成功                }                @Override                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {                        //handler充当paho mqtt源码中timer的作用，每隔一段时间进行请求                        handler.sendEmptyMessage(0);                }            });

上面这段代码的意思是通过一个handler，定时重新调用mqttAndroidClient.connect方法。模拟框架本身的重连机制。当然这个handler是我自己写的，这里就不贴出来了。而且框架本身用的是java的timer。
实际的使用的代码要比这段代码复杂一些，还要考虑一定的连接延迟，重复请求导致的已经连接上了，然后又断开等情况。或者之前说的因为已经连接上了之后，又断开也会回调这个方法，那么你需要对两种情况进行分别处理，有的时候可以交给框架本身的重连机制进行处理，有的时候则需要自己进行一系列的处理。具体实施起来比较复杂，但也没什么难度，只是第一次遇到的时候发现很多讲mqtt的文章，都没有提这个情况。所以记下来，希望同样使用paho mqtt的读者能用上。

更多相关文章

随机推荐