MQTT断线重连订阅无法接收
工具
MQTT客戶端是用的 paho http://www.eclipse.org/paho/
問題
采用以下配置
connOpts = new MqttConnectOptions(); connOpts.setCleanSession(true);connOpts.setConnectionTimeout(10);connOpts.setKeepAliveInterval(90);connOpts.setAutomaticReconnect(true);當(dāng)網(wǎng)絡(luò)斷開后,客戶端會(huì)進(jìn)行重連,但是重連之前訂閱的主題就失效了,不再接受之前訂閱主題的消息。
解決方法
因?yàn)榕渲美飳leanSession 設(shè)為 true ,當(dāng)客戶端掉線時(shí) ,服務(wù)器端會(huì)清除 客戶端 session 。 重連后 客戶端會(huì)有一個(gè)新的session。
第一種
把配置里的 cleanSession 設(shè)為false,客戶端掉線后 服務(wù)器端不會(huì)清除session,當(dāng)重連后可以接收之前訂閱主題的消息。當(dāng)客戶端上線后會(huì)接受到它離線的這段時(shí)間的消息
第二種
通過查看 connect 方法的代碼發(fā)現(xiàn)
如果我們?cè)O(shè)置的 callback實(shí)現(xiàn)了 MqttCallbackExtended接口,就會(huì)把它設(shè)置給connectActionListener,我再來看看MqttCallbackExtended接口。
可以看到這個(gè)接口拓展了一個(gè)方法,該方法會(huì)在連接到服務(wù)器成功時(shí)調(diào)用,正符合我們的要求。我只需要實(shí)現(xiàn)這個(gè)接口并在這個(gè)方法里從新訂閱之前的主題就行了。
這種方法重連之后不會(huì)收到離線期間該主題的消息
總結(jié)
以上是生活随笔為你收集整理的MQTT断线重连订阅无法接收的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Daisy Chains
- 下一篇: Qt QTcpSocket 客户端设计(