[發明專利]基于微服務架構的數據一致性方法以及裝置

有效

• 申請號: 201711421347.3
• 申請日: 2017-12-25
• 公開（公告）號: CN108153598B
• 公開（公告）日: 2021-06-25
• 發明（設計）人: 孫浩;張延鳳;張庚昕;劉志鵬
• 申請（專利權）人: 東軟集團股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/46
• 代理公司: 北京清亦華知識產權代理事務所(普通合伙) 11201
• 代理人: 張潤

1.一種基于微服務架構的數據一致性方法，其特征在于，包括：

接收上游應用在執行上游業務前發送的待確認消息，保存所述待確認消息，并向所述上游應用返回所述待確認消息對應的響應消息；

判斷是否在第一時間范圍內接收到所述上游應用發送的確認消息，所述確認消息為所述上游應用根據所述響應消息執行上游業務后的確認消息；

在第一時間范圍內未接收到所述確認消息時，向上游應用發送查詢請求；

在接收到上游應用的上游業務已執行的消息時，將待確認消息的待確認狀態修改為發送狀態，并將修改為發送狀態的消息傳遞至活動日志，以使下游應用監聽所述活動日志中的消息，根據所述消息確定是否執行下游業務；

在接收到上游應用的上游業務未執行的消息時，刪除所述待確認消息；

其中，在將所述待確認消息的待確認狀態修改為發送狀態，并將修改為發送狀態的消息傳遞至活動日志之前，還包括：

接收上游應用發送的所有下游應用的確認操作接口信息和取消操作接口信息；所述確認操作接口信息和所述取消操作接口信息，為所述上游應用執行上游業務完成后發送的；所述上游應用在接收到所有下游應用的預操作成功消息，且接收到活動管理器返回的所述響應消息時，執行上游業務；

根據所述確認操作接口信息，調用所有下游應用的確認操作接口；

確定所有下游應用的確認操作接口是否調用成功；

對應的，所述將所述待確認消息的待確認狀態修改為發送狀態，并將修改為發送狀態的消息傳遞至活動日志，包括：

在所有下游應用的確認操作接口調用成功時，將所述待確認消息的待確認狀態修改為發送狀態，并將修改為發送狀態的消息傳遞至活動日志。

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

在第一時間范圍內接收到所述確認消息時，根據所述確認消息，將所述待確認消息的待確認狀態修改為發送狀態，并將修改為發送狀態的消息傳遞至活動日志，以使下游應用監聽所述活動日志中的消息，根據所述消息確定是否執行下游業務。

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

接收下游應用的消息獲取請求，所述消息獲取請求為下游應用對所述活動日志進行監聽，確定所述活動日志中包括待獲取消息時發送的請求；

根據所述消息獲取請求，將所述待獲取消息發送至下游應用；

判斷是否在第二時間范圍內接收到下游應用的執行成功消息，所述執行成功消息為下游應用根據所述待獲取消息執行下游業務成功后的消息；

在第二時間范圍內未接收到所述執行成功消息時，將所述待獲取消息重新投遞至活動日志中，以供下游應用監聽。

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

在第二時間范圍內接收到所述執行成功消息時，將所述待獲取消息的發送狀態修改為已完成狀態，并刪除所述活動日志中的所述待獲取消息。

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

在所述待獲取消息的投遞次數大于預設重發次數時，將所述待獲取消息的發送狀態修改為死亡狀態，以供用戶處理。

6.根據權利要求1所述的方法，其特征在于，所述將所述待確認消息的待確認狀態修改為發送狀態，并將修改為發送狀態的消息傳遞至活動日志之前，還包括：

在存在部分或所有下游應用的確認操作接口未調用成功時，通知所述上游應用刪除執行上游業務后的數據，并調用所有下游應用的取消操作接口取消預操作。

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

接收通知應用的通知消息獲取請求，所述通知消息獲取請求為通知應用對活動日志進行監聽，確定所述活動日志中包括待通知消息時發送的請求；

根據所述通知消息獲取請求，將所述待通知消息發送至通知應用，以使所述通知應用按照所述待通知消息中的通知規則和通知地址，將所述待通知消息發送給對應的下游應用。