[發明專利]一種基于微服務架構的分布式事務處理方法

有效

• 申請號: 201710112586.4
• 申請日: 2017-02-28
• 公開（公告）號: CN106909467B
• 公開（公告）日: 2021-06-29
• 發明（設計）人: 付正全
• 申請（專利權）人: 鄭州云海信息技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 羅滿

1.一種基于微服務架構的分布式事務處理方法，其特征在于，包括：

在微服務架構中確定服務調用節點和服務被調用節點；

控制所述服務調用節點向所述服務被調用節點通過消息隊列發送業務消息，并存儲所述業務消息的發送狀態；

控制所述服務被調用節點解析所述業務消息，并根據解析的結果執行對應的業務；

控制所述服務被調用節點反饋業務執行結果至所述服務調用節點；

根據所述業務執行結果，控制所述服務調用節點變更自身中存儲的所述業務消息的當前狀態；

在所述控制所述服務調用節點向所述服務被調用節點通過消息隊列發送業務消息，并存儲所述業務消息的發送狀態之前還包括：

控制所述服務調用節點進行業務檢查，判斷所述業務消息是否正常且符合預設的業務提交條件；

若是，則將所述業務消息存儲在所述服務調用節點的消息數據庫中，并將所述業務消息的狀態標記為請求發送狀態；

所述控制所述服務調用節點向所述服務被調用節點通過消息隊列發送業務消息，并存儲所述業務消息的發送狀態，包括：

接收業務消息確認發送信息；

在所述消息數據庫中調取所述業務消息，并將所述業務消息通過消息隊列發送至所述服務被調用節點；

在所述服務調用節點中將所述業務消息的狀態變更為已發送狀態；

還包括：

定時查詢所述消息數據庫中是否有未確認發送的消息；

若是，則判斷該未確認發送的消息是否有效；

若是，則控制所述服務調用節點補發該未確認發送的消息至所述服務被調用節點；

若否，則刪除該未確認發送的消息；

所述控制所述服務被調用節點解析所述業務消息，并根據解析的結果執行對應的業務，包括：

在所述服務被調用節點接收到所述業務消息時，解析所述業務消息中定義的調用方法和參數；

根據所述調用方法和參數執行對應的業務。

2.根據權利要求1所述的方法，其特征在于，所述控制所述服務被調用節點反饋業務執行結果至所述服務調用節點，包括：

判斷所述服務被調用節點的業務執行是否正常；

若是，則控制所述服務被調用節點向所述服務調用節點發送確認執行的消息；

若否，則控制所述服務被調用節點向所述服務調用節點發送取消執行的消息。

3.根據權利要求2所述的方法，其特征在于，所述根據所述業務執行結果，控制所述服務調用節點變更自身中存儲的所述業務消息的當前狀態，包括：

當所述服務調用節點接收到所述確認執行的消息時，控制所述服務調用節點進行業務提交，并將所述業務消息的狀態變更為已提交；

當所述服務調用節點接收到所述取消執行的消息時，控制所述服務調用節點進行業務回滾，并將所述業務消息的狀態變更為已回滾。