MQTT斷線重連訂閱無法接收

工具

MQTT客戶端是用的 paho http://www.eclipse.org/paho/

問題

采用以下配置

        connOpts = new MqttConnectOptions(); 
        connOpts.setCleanSession(true);
        connOpts.setConnectionTimeout(10);
        connOpts.setKeepAliveInterval(90);
        connOpts.setAutomaticReconnect(true);

當網絡斷開后，客戶端會進行重連，但是重連之前訂閱的主題就失效了，不再接受之前訂閱主題的消息。

解決方法

因為配置里將cleanSession 設為 true ，當客戶端掉線時 ，服務器端會清除 客戶端 session 。 重連后 客戶端會有一個新的session。

第一種

把配置里的 cleanSession 設為false，客戶端掉線后 服務器端不會清除session，當重連后可以接收之前訂閱主題的消息。當客戶端上線后會接受到它離線的這段時間的消息

第二種

通過查看 connect 方法的代碼發現

如果我們設置的 callback實現了 MqttCallbackExtended接口，就會把它設置給connectActionListener，我再來看看MqttCallbackExtended接口。

可以看到這個接口拓展了一個方法，該方法會在連接到服務器成功時調用，正符合我們的要求。我只需要實現這個接口並在這個方法里從新訂閱之前的主題就行了。

這種方法重連之后不會收到離線期間該主題的消息