[發明專利]一種基于MQTT和MYSQL的消息推送方法和系統

在審

• 申請號: 201710053257.7
• 申請日: 2017-01-24
• 公開（公告）號: CN106713124A
• 公開（公告）日: 2017-05-24
• 發明（設計）人: 談光寶
• 申請（專利權）人: 深圳市啟侖智能科技有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/06
• 代理公司: 深圳市港灣知識產權代理有限公司44258
• 代理人: 微嘉

1.一種基于MQTT和MYSQL的消息推送方法，包括步驟：

服務端基于MQTT協議建立與客戶端的通信連接；

所述服務端根據業務指令從MYSQL數據庫中調取推送數據，并將所述推送數據發送給建立通信連接的所述客戶端；

所述服務端監測所述客戶端的回應確認消息，若未監測到所述客戶端的回應確認消息，則重新發送所述推送數據。

2.根據權利要求1所述的基于MQTT和MYSQL的消息推送方法，其特征在于，所述客戶端包括有數個，且每一個具有唯一標識碼，所述服務端通過識別唯一標識碼將所述推送數據發送至對應的客戶端。

3.根據權利要求1所述的基于MQTT和MYSQL的消息推送方法，其特征在于，若未監測到所述客戶端的回應確認消息，所述服務端按時間間隔重發所述推送數據，所述時間間隔與所述推送數據的重發次數成正比。

4.根據權利要求1所述的基于MQTT和MYSQL的消息推送方法，其特征在于，所述服務端監測所述客戶端的回應確認消息，若未監測到所述客戶端的回應確認消息，則重新發送所述推送數據之后具體還包括：

所述客戶端根據業務指令向所述服務端發送數據請求，并在未收到所述服務端的回應確認消息時重復發送數據請求。

5.根據權利要求4所述的基于MQTT和MYSQL的消息推送方法，其特征在于，所述客戶端收到所述服務端的回應確認消息時或數據請求次數達到預定次數時停止發送數據請求。

6.根據權利要求1所述的基于MQTT和MYSQL的消息推送方法，其特征在于，所述客戶端通過一條TCP長連接與所述服務器相連。

7.一種基于MQTT和MYSQL的消息推送系統，其特征在于，所述系統包括服務端和客戶端，所述服務端包括MQTT服務器、服務器業務進程和服務器MYSQL數據庫，所述客戶端包括MQTT客戶端、客戶端業務進程和客戶端MYSQL數據庫，所述服務器MYSQL數據庫和所述客戶端MYSQL數據庫分別用于存儲數據，所述服務器業務進程和所述客戶端業務進程分別用于業務指令和數據處理；所述服務器和所述客戶端基于MQTT協議建立通信連接；

所述MQTT服務器用于根據業務指令從MYSQL數據庫中調取推送數據，并將所述推送數據發送給所述MQTT客戶端；以及監測所述MQTT客戶端的回應確認消息，在未監測到所述MQTT客戶端的回應確認消息時重新發送所述推送數據；

所述MQTT客戶端用于接收所述推送數據，以及根據業務指令主動向所述MQTT服務器發送數據請求，并在未收到所述MQTT服務器的回應確認消息時重復發送數據請求。

8.根據權利要求7所述的基于MQTT和MYSQL的消息推送系統，其特征在于，所述客戶端包括有數個，且每一個具有唯一標識碼，所述服務端通過唯一標識碼識別對應的客戶端。

9.根據權利要求7所述的基于MQTT和MYSQL的消息推送系統，其特征在于，

所述MQTT服務器還用于在未監測到所述MQTT客戶端的回應確認消息，按時間間隔發送所述推送數據，且所述時間間隔隨著推送次數越來越大；

或者所述MQTT客戶端還用于根據業務指令主動向所述MQTT服務器發送數據請求，并在未收到所述MQTT服務器的回應確認消息時重復發送數據請求，直至數據請求成功或數據請求次數達到預定次數。

10.根據權利要求7所述的基于MQTT和MYSQL的消息推送系統，其特征在于，所述客戶端通過一條TCP長連接與所述服務端相連。