[發明專利]基于MQTT的數據庫記錄的高并發訪問系統、方法及存儲介質

在審

• 申請號: 202110235067.3
• 申請日: 2021-03-03
• 公開（公告）號: CN113064878A
• 公開（公告）日: 2021-07-02
• 發明（設計）人: 陳亮
• 申請（專利權）人: 深圳市科陸電子科技股份有限公司
• 主分類號: G06F16/21
• 分類號: G06F16/21;G06F16/25
• 代理公司: 深圳國新南方知識產權代理有限公司 44374
• 代理人: 周雷

1.一種基于MQTT的數據庫記錄的高并發訪問系統，其特征在于，包括：MQTT接口模塊、MQTT委托模塊、任務管理模塊、業務接口模塊、SQLite3數據庫接口模塊以及數據庫；所述MQTT接口模塊、MQTT委托模塊、任務管理模塊、業務接口模塊、SQLite3數據庫接口模塊以及數據庫依次通信連接，所述MQTT接口模塊與所述業務接口模塊通信連接；

所述MQTT接口模塊用于進行MQTT消息訂閱及發布，所述MQTT消息包括訂閱主題和業務請求；

所述MQTT委托模塊用于將所述MQTT消息傳輸至所述任務管理模塊；

所述任務管理模塊用于根據所述訂閱主題與委托匹配函數的匹配結果，將所述業務請求分發至對應的所述業務接口模塊；

所述業務接口模塊用于將所述業務請求分發至對應的業務隊列；

所述SQLite3數據庫接口模塊用于供所述業務接口模塊對所述數據庫進行高并發訪問。

2.根據權利要求1所述的基于MQTT的數據庫記錄的高并發訪問系統，其特征在于，所述任務管理模塊還用于：

所述系統啟動時，根據不同的業務請求對象進行單實例化；

初始化單實例化后的所述業務請求對象；

將所述業務請求對象對應的所述委托匹配函數綁定至所述任務管理模塊。

3.根據權利要求1所述的基于MQTT的數據庫記錄的高并發訪問系統，其特征在于，所述MQTT接口模塊還用于：

配置網絡通信參數，所述網絡通信參數包括IP、端口、心跳；

配置MQTT主題，用于進行MQTT消息的訂閱；

確定所述MQTT消息對應的所述任務管理模塊。

4.根據權利要求1所述的基于MQTT的數據庫記錄的高并發訪問系統，其特征在于，所述SQLite3數據庫接口模塊還用于：

配置數據庫結構配置表；

初始化所述數據庫結構配置表；

創建所述SQLite3數據庫接口模塊的服務對象，供所述業務接口模塊訪問。

5.根據權利要求4所述的基于MQTT的數據庫記錄的高并發訪問系統，其特征在于，所述業務接口模塊還用于：

當所述MQTT消息到達所述業務隊列時觸發對應的業務請求線程，所述業務接口模塊根據所述服務對象，通過所述SQLite3數據庫接口模塊對所述數據庫進行高并發訪問；

其中，所述業務請求線程使用Linux線程同步等待機制獲取隊列中的所述業務請求。

6.根據權利要求1所述的基于MQTT的數據庫記錄的高并發訪問系統，其特征在于，所述對所述數據庫進行高并發訪問后，將得到的訪問數據發送至客戶端。

7.一種基于MQTT的數據庫記錄的高并發訪問方法，其特征在于，包括：

進行MQTT消息訂閱，所述MQTT消息包括訂閱主題和業務請求；

將所述MQTT消息傳輸至任務管理模塊；

根據所述訂閱主題與委托匹配函數的匹配結果，將所述業務請求分發至對應的業務接口模塊；

將所述業務請求分發至對應的業務隊列；

對數據庫進行高并發訪問。

8.根據權利要求7所述的基于MQTT的數據庫記錄的高并發訪問方法，其特征在于，在所述進行MQTT消息訂閱步驟前，還包括：

根據不同的業務請求對象進行單實例化；

初始化所述業務請求對象；

將所述業務請求對象對應的所述委托匹配函數綁定至所述任務管理模塊。

9.根據權利要求7所述的基于MQTT的數據庫記錄的高并發訪問方法，其特征在于，在所述進行MQTT消息訂閱步驟前，還包括：

配置數據庫結構配置表；

初始化所述數據庫結構配置表；

創建SQLite3數據庫接口模塊的服務對象，供所述業務接口模塊訪問。

10.一種存儲介質，所述存儲介質存儲有計算機程序，其特征在于，所述計算機程序被處理器執行時實現如權利要求7-9任一項所述的基于MQTT的數據庫記錄的高并發訪問方法的步驟。