MQTT斷線重連訂閱沒法接收

工具

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

相關文章
相關標籤/搜索