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

在審

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

技術領域

本發明涉及通信技術領域，尤其涉及到一種基于MQTT和MYSQL的消息推送方法和系統。

背景技術

隨著互聯網及云計算的發展和普及，越來越多的企業把服務部署在云端。而隨著企業服務的擴展，單點服務器遠不能滿足需求，首選便是分布式，即維護一個中心節點和大量的服務節點。節點和中心節點間的通信成為新的問題，也即如何高的實現中心節點與節點間可靠通信。

現有的通信方式中，客戶端的每個業務都需要和服務端單獨維護連接，維護很復雜。而且客戶端和服務端間的通信消息無法保證可靠送達，無法保證通信的可靠性。例如，客戶端與服務端間的通信消息未持久化，在發生進程重啟設備重啟后，消息丟失，無法重傳，使得無法保證關鍵消息的準確送達。

因此，現有技術有待進一步的改進。

發明內容

本發明所要解決的問題在于，提供一種基于MQTT和MYSQL的消息推送方法和系統，以簡化客戶端和服務端連接映射和保證消息的可靠推送。

本發明采用如下技術方案：

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

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

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

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

所述的基于MQTT和MYSQL的消息推送方法，其中，所述客戶端包括有數個，且每一個具有唯一標識碼，所述服務端通過識別唯一標識碼識別將所述推送數據發送至對應的客戶端。

所述的基于MQTT和MYSQL的消息推送方法，其中，若未監測到所述客戶端的回應確認消息，所述服務端按時間間隔發送所述推送數據，且所述時間間隔隨著推送次數越來越大。

所述的基于MQTT和MYSQL的消息推送方法，其中，所述服務端監測所述客戶端的回應確認消息，若未監測到所述客戶端的回應確認消息，則重新發送所述推送數據之后具體還包括：

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

所述的基于MQTT和MYSQL的消息推送方法，其中，所述客戶端收到所述服務端的回應確認消息時或數據請求次數達到預定次數時停止發送數據請求。

所述的基于MQTT和MYSQL的消息推送方法，其中，所述客戶端通過一條TCP長連接與所述服務器相連。

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

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

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

所述的基于MQTT和MYSQL的消息推送系統，其中，所述客戶端包括有數個，且每一個具有唯一標識碼，所述服務端通過唯一標識碼識別對應的客戶端。

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

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

所述的基于MQTT和MYSQL的消息推送系統，其中，所述MQTT客戶端通過一條TCP長連接與所述MQTT服務器相連。