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