[發明專利]一種分布式事務處理的智能監控方法及服務器

在審

• 申請號: 201811191536.0
• 申請日: 2018-10-12
• 公開（公告）號: CN109472546A
• 公開（公告）日: 2019-03-15
• 發明（設計）人: 曾維剛
• 申請（專利權）人: 深圳壹賬通智能科技有限公司
• 主分類號: G06Q10/10
• 分類號: G06Q10/10;G06Q40/08
• 代理公司: 深圳市隆天聯鼎知識產權代理有限公司 44232
• 代理人: 劉抗美

1.一種分布式事務處理的智能監控方法，其特征在于，所述方法包括：

服務器獲取流入當前節點的事務流入信息，所述事務流入信息包括某一事務的事務數據和所述事務的日志信息，所述事務的日志信息攜帶有所述事務的事務標識號；

所述服務器監測所述當前節點的事務流出信息所包括的事務標識號中是否存在所述事務的事務標識號；

如果存在所述事務的事務標識號，所述服務器確定所述事務的事務數據流入的下一節點；

所述服務器根據所述下一節點更新所述事務的事務數據的流轉路徑。

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

所述服務器接收用戶的查詢請求，所述查詢請求用于查詢所述事務的事務流轉狀態；

所述服務器根據所述查詢請求，獲取所述事務的當前流轉路徑，并根據所述事務的當前流轉路徑生成所述事務的事務流轉圖；

所述服務器輸出所述事務的事務流轉圖；其中，在所述事務的事務流轉圖中，以第一圖形表示節點，以及以第二圖形表示所述事務在各所述節點之間的流向。

3.根據權利要求1或2所述的方法，其特征在于，所述事務的日志信息還攜帶有所述事務的事務類型；所述方法還包括：

如果不存在所述事務的事務標識號，所述服務器獲取所述事務的事務數據在所述當前節點的停留時間，并判斷所述停留時間是否大于預設的事務處理時間閾值；

如果所述停留時間大于所述事務處理時間閾值，所述服務器向所述當前節點發送詢問指令，以獲取所述當前節點針對所述詢問指令返回的應答消息；

所述服務器根據所述應答消息確定所述當前節點中存在的目標故障，并確定出所述目標故障所對應的目標事務類型；

所述服務器根據所述事務流入信息，判斷流入所述當前節點的所有事務的事務數據中是否存在至少一項事務類型為所述目標事務類型的目標事務的事務數據；

如果存在所述至少一項目標事務的事務數據，所述服務器將所述至少一項目標事務的事務數據轉出至替換節點，所述替換節點所處理的事務類型至少包括所述目標事務類型。

4.根據權利要求3所述的方法，其特征在于，所述服務器將所述至少一項目標事務的事務數據轉出至替換節點，包括：

所述服務器統計除所述當前節點以外的所有替換節點，每個所述替換節點所處理的事務類型至少包括所述目標事務類型；

所述服務器根據所述替換節點的事務流入信息和所述替換節點的事務流出信息，確定每個所述替換節點的當前處理負荷；

所述服務器確定所有所述替換節點中當前處理負荷最低的目標替換節點，并將所述至少一項目標事務的事務數據轉出至所述目標替換節點。

5.根據權利要求4所述的方法，其特征在于，所述服務器根據所述替換節點的事務流入信息和所述替換節點的事務流出信息，確定每個所述替換節點的當前處理負荷之前，所述方法還包括：

所述服務器判斷所述替換節點中是否存在終止事務，所述終止事務是在所述替換節點處于終止狀態的事務；

如果不存在所述終止事務，所述服務器執行所述的根據所述替換節點的事務流入信息和所述替換節點的事務流出信息，確定每個所述替換節點的當前處理負荷。

6.根據權利要求5所述的方法，其特征在于，所述服務器判斷所述替換節點中是否存在終止事務，包括：

所述服務器接收所述替換節點上報的事務處理進程結束消息，所述事務處理進程結束消息至少包括終止事務的事務標識號，所述終止事務是在所述替換節點處于終止狀態的事務；

所述服務器根據所述事務處理結束消息，判斷所述替換節點中是否存在所述終止事務。

7.根據權利要求1所述的方法，其特征在于，所述當前節點采用同步或者異步的方式向所述下一節點發送所述事務的事務數據和所述事務的日志信息。