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的读者能用上。
网友评论