[發明專利]分布式事務的消息訂閱方法、電子裝置及可讀存儲介質

在審

• 申請號: 201810546879.8
• 申請日: 2018-05-31
• 公開（公告）號: CN108874558A
• 公開（公告）日: 2018-11-23
• 發明（設計）人: 孫志博
• 申請（專利權）人: 康鍵信息技術（深圳）有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/46
• 代理公司: 深圳市沃德知識產權代理事務所(普通合伙) 44347
• 代理人: 高杰;于志光

本發明涉及一種分布式事務的消息訂閱方法、電子裝置及可讀存儲介質，該方法包括：獲取主數據庫發送的主數據庫日志和從數據庫發送的從數據庫日志；將獲取的主數據庫日志和從數據庫日志解析為消息，并根據解析的消息形成消息隊列；將所述消息隊列中的消息通知給預先訂閱消息的業務系統；其中，所述主數據庫日志、從數據庫日志為所述業務系統根據用戶指令對所述主數據庫、從數據庫進行相應的數據操作產生的數據庫日志。本發明由于能將數據庫日志實時解析為消息發送給預先訂閱消息的業務系統，通過這種消息訂閱的方式能保證分布式事務處理的低延時，提高了系統的可用性和性能。

技術領域

本發明涉及計算機技術領域，尤其涉及一種分布式事務的消息訂閱方法、電子裝置及可讀存儲介質。

背景技術

在業務開發中，很多場景需要解決分布式事務中數據一致性問題。造成數據不一致的原因一般是延時引起的，所以要消除這個延時的影響。現有的解決方案都是從主庫進行CUD操作時進行規避，就是等主、從數據庫同步完成之后，主數據庫上的寫請求再返回。這種方式會大大降低系統的可用性和性能。

發明內容

本發明的目的在于提供一種分布式事務的消息訂閱方法、電子裝置及可讀存儲介質，旨在提高系統的可用性和性能。

為實現上述目的，本發明提供一種電子裝置，所述電子裝置包括存儲器、處理器，所述存儲器上存儲有可在所述處理器上運行的分布式事務的消息訂閱系統，所述分布式事務的消息訂閱系統被所述處理器執行時實現如下步驟：

獲取主數據庫發送的主數據庫日志和從數據庫發送的從數據庫日志；

將獲取的主數據庫日志和從數據庫日志解析為消息，并根據解析的消息形成消息隊列；

將所述消息隊列中的消息通知給預先訂閱消息的業務系統，以將消息反饋給所述業務系統的用戶，便于用戶根據反饋的消息執行下一步業務邏輯；其中，所述主數據庫日志、從數據庫日志為所述業務系統根據用戶指令對所述主數據庫、從數據庫進行相應的數據操作產生的數據庫日志。

優選地，所述分布式事務的消息訂閱系統被所述處理器執行實現所述獲取主數據庫發送的主數據庫日志和從數據庫發送的從數據庫日志的步驟時，包括：

獲取主數據庫、從數據庫的位置；

根據所述主數據庫、從數據庫的位置向所述主數據庫、從數據庫發送日志獲取指令；

獲取所述主數據庫、從數據庫在進行數據操作時產生的主數據庫日志、從數據庫日志；

所述將獲取的主數據庫日志和從數據庫日志解析為消息，并根據解析的消息形成消息隊列的步驟包括：

將獲取的主數據庫日志、從數據庫日志傳遞至預先設定的內存隊列；

將所述預先設定的內存隊列中的主數據庫日志、從數據庫日志轉換為消息并形成消息隊列。

優選地，預先將所述主數據庫和從數據庫對應設置類別Topic，將所述主數據庫和從數據庫作為消息數據生產者Producer，將所述業務系統作為消息數據消費者Consumer；所述獲取主數據庫發送的主數據庫日志和從數據庫發送的從數據庫日志的步驟包括：

獲取消息數據生產者Producer發布的數據庫日志，并按對應的類別Topic進行保存；

所述將所述消息隊列中的消息通知給預先訂閱消息的業務系統的步驟包括：

將所述消息隊列中的消息通知給預先訂閱了類別Topic消息的消息數據消費者Consumer。

優選地，在所述獲取主數據庫發送的主數據庫日志和從數據庫發送的從數據庫日志的步驟之后，所述處理器還用于執行所述分布式事務的消息訂閱系統，以實現以下步驟：