Я реализую пример сервиса Dale Lane MQTT для Android, который можно найти здесь http://dalelane.co.uk/blog/?p=1599, этот пример работает довольно хорошо для моей конкретной цели, но я имею дело с одной проблемой, которую не могу решить.
После довольно обширного тестирования я обнаружил, что служба не восстанавливает соединение после того, как телефон полностью потерял связь. Например, если телефон переведен в режим полета, а затем выведен из режима полета, служба продолжит попытки connectToBroker(), но никогда не подключится.
Приложение правильно подключается, если я нажимаю кнопку «подключиться» на главном экране, которая запускает службу с заданными параметрами хоста/темы.
Как решить эту проблему? У приложения нет проблем с повторным подключением из сети Wi-Fi и наоборот.
02-16 12:19:39.348: E/mqtt(23628): ping failed - MQTT exception
02-16 12:19:39.348: E/mqtt(23628): com.ibm.mqtt.MqttNotConnectedException
02-16 12:19:39.348: E/mqtt(23628): at com.ibm.mqtt.Mqtt.writePacket(Unknown Source)
02-16 12:19:39.348: E/mqtt(23628): at com.ibm.mqtt.Mqtt.pingOut(Unknown Source)
02-16 12:19:39.348: E/mqtt(23628): at com.ibm.mqtt.MqttClient.ping(Unknown Source)
02-16 12:19:39.348: E/mqtt(23628): at com.limosys.limosystestmqtt.MQTTService$PingSender.onReceive(MQTTService.java:919)
02-16 12:19:39.348: E/mqtt(23628): at android.app.LoadedApk$ReceiverDispatcher$Args.run(LoadedApk.java:778)
02-16 12:19:39.348: E/mqtt(23628): at android.os.Handler.handleCallback(Handler.java:733)
02-16 12:19:39.348: E/mqtt(23628): at android.os.Handler.dispatchMessage(Handler.java:95)
02-16 12:19:39.348: E/mqtt(23628): at android.os.Looper.loop(Looper.java:136)
02-16 12:19:39.348: E/mqtt(23628): at android.app.ActivityThread.main(ActivityThread.java:5105)
02-16 12:19:39.348: E/mqtt(23628): at java.lang.reflect.Method.invokeNative(Native Method)
02-16 12:19:39.348: E/mqtt(23628): at java.lang.reflect.Method.invoke(Method.java:515)
02-16 12:19:39.348: E/mqtt(23628): at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:792)
02-16 12:19:39.348: E/mqtt(23628): at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:608)
02-16 12:19:39.348: E/mqtt(23628): at dalvik.system.NativeStart.main(Native Method)
Вот трассировка стека исключения, которое возникает, если проверка связи не удалась, приложение продолжает пытаться подключиться каждые 10 секунд на основе заданного значения keepAliveSecond.
ПОТЕРЯ СОЕДИНЕНИЯ
/*
* callback - method called when we no longer have a connection to the message broker server
*/
public void connectionLost() throws Exception {
// we protect against the phone switching off while we're doing this
// by requesting a wake lock - we request the minimum possible wake
// lock - just enough to keep the CPU running until we've finished
PowerManager pm = (PowerManager) getSystemService(POWER_SERVICE);
WakeLock wl = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "MQTT");
wl.acquire();
//
// have we lost our data connection?
//
if (isOnline() == false) {
Log.e("CONNECTION LOST", "LOST CONNECTION");
connectionStatus = MQTTConnectionStatus.NOTCONNECTED_WAITINGFORINTERNET;
// inform the app that we are not connected any more
broadcastServiceStatus("Connection lost - no network connection");
//
// inform the user (for times when the Activity UI isn't running)
// that we are no longer able to receive messages
notifyUser("Connection lost - no network connection", "MQTT",
"Connection lost - no network connection");
//
// wait until the phone has a network connection again, when we
// the network connection receiver will fire, and attempt another
// connection to the broker
} else {
//
// we are still online
// the most likely reason for this connectionLost is that we've
// switched from wifi to cell, or vice versa
// so we try to reconnect immediately
//
connectionStatus = MQTTConnectionStatus.NOTCONNECTED_UNKNOWNREASON;
// inform the app that we are not connected any more, and are
// attempting to reconnect
broadcastServiceStatus("Connection lost - reconnecting...");
// try to reconnect
if (connectToBroker()) {
subscribeToTopic(topicName);
}
}
// we're finished - if the phone is switched off, it's okay for the CPU
// to sleep now
wl.release();
}
ПОДКЛЮЧИТЬСЯ К БРОКЕРУ Этот код вызывается несколько раз после того, как услуга становится доступной (т. е. при выходе из режима полета и подключении к 4G/Wifi).
/*
* (Re-)connect to the message broker
*/
private boolean connectToBroker() {
try {
// try to connect
Log.e("CONNECTTOBROKER", "TRYING TO CONNECT");
Log.e("SERVICE HOST - CONNECT TO BROKER", "" + brokerHostName);
Log.e("SERVICE TOPIC - CONNECT TO BROKER", "" + topicName);
mqttClient.connect(generateClientId(), cleanStart, keepAliveSeconds);
//
// inform the app that the app has successfully connected
broadcastServiceStatus("Connected");
// we are connected
connectionStatus = MQTTConnectionStatus.CONNECTED;
// we need to wake up the phone's CPU frequently enough so that the
// keep alive messages can be sent
// we schedule the first one of these now
scheduleNextPing();
return true;
} catch (MqttException e) {
// something went wrong!
connectionStatus = MQTTConnectionStatus.NOTCONNECTED_UNKNOWNREASON;
//
// inform the app that we failed to connect so that it can update
// the UI accordingly
broadcastServiceStatus("Unable to connect");
//
// inform the user (for times when the Activity UI isn't running)
// that we failed to connect
notifyUser("Unable to connect", "MQTT", "Unable to connect - will retry later");
// if something has failed, we wait for one keep-alive period before
// trying again
// in a real implementation, you would probably want to keep count
// of how many times you attempt this, and stop trying after a
// certain number, or length of time - rather than keep trying
// forever.
// a failure is often an intermittent network issue, however, so
// some limited retry is a good idea
scheduleNextPing();
return false;
}
}
