工具
MQTT客戶端是用的 paho http://www.eclipse.org/paho/java
問題
採用如下配置服務器
connOpts = new MqttConnectOptions(); connOpts.setCleanSession(true); connOpts.setConnectionTimeout(10); connOpts.setKeepAliveInterval(90); connOpts.setAutomaticReconnect(true);
當網絡斷開後,客戶端會進行重連,可是重連以前訂閱的主題就失效了,再也不接受以前訂閱主題的消息。網絡
解決方法
由於配置裏將cleanSession 設爲 true ,當客戶端掉線時 ,服務器端會清除 客戶端 session 。 重連後 客戶端會有一個新的session。session
第一種
把配置裏的 cleanSession 設爲false,客戶端掉線後 服務器端不會清除session,當重連後能夠接收以前訂閱主題的消息。當客戶端上線後會接受到它離線的這段時間的消息eclipse
第二種
經過查看 connect 方法的代碼發現工具
若是咱們設置的 callback實現了 MqttCallbackExtended接口,就會把它設置給connectActionListener,我再來看看MqttCallbackExtended接口。
url
能夠看到這個接口拓展了一個方法,該方法會在鏈接到服務器成功時調用,正符合咱們的要求。我只須要實現這個接口並在這個方法裏重新訂閱以前的主題就好了。spa
這種方法重連以後不會收到離線期間該主題的消息.net