[發明專利]一種基于消息驅動的事務處理方法及裝置

在審

• 申請號: 201810735951.1
• 申請日: 2018-07-06
• 公開（公告）號: CN108958955A
• 公開（公告）日: 2018-12-07
• 發明（設計）人: 賈英哲;汪洵瀟
• 申請（專利權）人: 美利車（北京）網絡技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F17/30
• 代理公司: 北京市天璽沐澤專利代理事務所(普通合伙) 11532
• 代理人: 謝鑫

1.一種基于消息驅動的事務處理方法，其特征在于，所述方法包括：

執行數據庫事務，其中，所執行的數據庫事務攜帶有執行狀態；

監測執行所述數據庫事務所產生的事務消息；

攔截監測到的事務消息，并緩存在本地；

當所述數據庫事務攜帶的執行狀態為完成狀態時，發送所緩存的事務消息。

2.如權利要求1所述的方法，其特征在于，在執行數據庫事務之前，所述方法還包括：

指定數據庫事務；

在指定的數據庫事務內添加特定標記；

監測攜帶有特定標記的數據庫事務為待執行的數據庫事務。

3.如權利要求1所述的方法，其特征在于，所述方法還包括：

當所述數據庫事務攜帶的執行狀態為回滾狀態時，刪除緩存在本地內的事務消息。

4.如權利要求1～3任一所述的方法，其特征在于，所述事務消息持久化存儲，所述數據庫事務攜帶的執行狀態持久化存儲。

5.如權利要求4所述的方法，其特征在于，在發送所緩存的事務消息，或刪除緩存在本地內的事務消息之后，所述方法還包括：

將持久化存儲的事務消息標記為失效。

6.如權利要求4所述的方法，其特征在于，在執行數據庫事務之后，所述方法還包括：

生成所執行的數據庫事務對應的鍵值；

建立所執行的數據庫事務對應的鍵值、所執行的數據庫事務生成的事務消息以及所執行的數據庫事務對應的攜帶的執行狀態三者之間的對應關系。

7.如權利要求6所述的方法，其特征在于，當所述數據庫事務攜帶的執行狀態為完成狀態時，發送所緩存的事務消息之后，所述方法還包括：

接收返回的所述數據庫事務對應的事務消息，根據建立的所執行的數據庫事務對應的鍵值、所執行的數據庫事務生成的事務消息以及所執行的數據庫事務對應的攜帶的執行狀態三者之間的對應關系，將返回的所述數據庫事務對應的事務消息與持久化存儲的所述數據庫事務對應的事務消息進行匹配，確定返回的所述數據庫事務對應的事務消息是否已經存在；

當未存在返回的所述數據庫事務對應的事務消息時，執行返回的所述數據庫事務對應的事務消息。

8.如權利要求6所述的方法，其特征在于，所述方法還包括：

根據建立的所執行的數據庫事務對應的鍵值、所執行的數據庫事務生成的事務消息以及所執行的數據庫事務對應的攜帶的執行狀態三者之間的對應關系，每隔預設的周期檢查持久化存儲的事務消息；

根據持久化存儲的數據庫事務攜帶的執行狀態，確定持久化存儲的事務消息是否發送。

9.一種基于消息驅動的事務處理裝置，其特征在于，所述裝置包括：

執行模塊，用于執行數據庫事務，其中，所執行的數據庫事務攜帶有執行狀態；

監測模塊，用于監測執行所述數據庫事務所產生的事務消息；

攔截模塊，用于攔截監測到的事務消息，并緩存在本地；

發送模塊，用于當所述數據庫事務攜帶的執行狀態為完成狀態時，發送所緩存的事務消息。

10.如權利要求9所述的裝置，其特征在于，所述裝置還包括：

標記添加模塊，用于在執行模塊執行數據庫事務之前，指定數據庫事務，在指定的數據庫事務內添加特定標記，監測攜帶有特定標記的數據庫事務為待執行的數據庫事務。

11.如權利要求9所述的裝置，其特征在于，所述裝置還包括：

回滾模塊，用于當所述數據庫事務攜帶的執行狀態為回滾狀態時，刪除緩存在本地內的事務消息。

12.如權利要求9～11任一所述的裝置，其特征在于，所述事務消息持久化存儲，所述數據庫事務攜帶的執行狀態持久化存儲。