[發明專利]交易數據的處理方法、裝置和服務器

有效

• 申請號: 202010563618.4
• 申請日: 2020-06-19
• 公開（公告）號: CN111737274B
• 公開（公告）日: 2023-08-08
• 發明（設計）人: 陳林軍;周魁;皇甫曉潔;許璟亮
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F9/52;G06F9/50
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 周達;闞傳猛

本申請實施例提供了一種交易數據的處理方法、裝置和服務器，其中，該交易數據的處理方法包括：第一節點服務器在接收到待處理的目標交易數據后，先為該目標交易數據設置基于redis分布式鎖的預設的標簽鎖，并根據基于dubbo一致性負載均衡的預設的分配策略，結合目標交易數據的交易類型和交易要素，從分布式系統的多個節點服務器中確定出匹配的適合于處理目標交易數據的目標節點服務器，再將設置有預設的標簽鎖的目標交易數據發送至目標節點服務器；由目標節點服務器確定并根據目標交易數據的關聯信息，以及預設的處理規則，通過確定是否取消預設的標簽鎖，對目標交易數據進行有序處理，從而能高效、有序地處理大批量的交易數據。

技術領域

本申請涉及數據處理技術領域，特別涉及一種交易數據的處理方法、裝置和服務器。

背景技術

在許多應用場景中，常常需要通過分布式系統來批量處理數量龐大、種類繁多且相互關系復雜的數據(例如，交易數據)。而基于現有方法在處理上述數據時，往往存在無法同時兼顧處理效率和數據處理的有序性的技術問題。

針對上述問題，目前尚未提出有效的解決方案。

發明內容

本申請實施例提供了一種交易數據的處理方法、裝置和服務器，以解決現有方法中存在的無法同時兼顧數據處理效率和數據處理的有序性的技術問題，達到能高效、有序地批量處理交易數據的技術效果。

本申請實施例提供了一種交易數據的處理方法，所述方法應用于分布式系統，所述分布式系統包括多個節點服務器，所述方法包括：

第一節點服務器接收待處理的目標交易數據，并為所述目標交易數據設置預設的標簽鎖；所述第一節點服務器確定所述目標交易數據的交易類型和交易要素；所述第一節點服務器根據所述目標交易數據的交易類型、交易要素以及預設的分配策略，從多個節點服務器中確定出目標節點服務器，并將設置有預設的標簽鎖的目標交易數據發送至目標節點服務器；其中，所述預設的標簽鎖包括基于redis分布式鎖的標簽鎖，所述預設的分配策略包括基于dubbo一致性負載均衡的分配策略；

所述目標節點服務器接收設置有預設的標簽鎖的目標交易數據，并根據所述目標交易數據，獲取關聯信息；所述目標節點服務器根據所述關聯信息、預設的處理規則，確定當前是否消除所述預設的標簽鎖；所述目標節點服務器在確定當前消除所述預設的標簽鎖的情況下，消除所述預設的標簽鎖，并按照有序任務隊列的處理排序，處理所述目標交易數據。

本申請實施例還提供了一種交易數據的處理方法，包括：

接收待處理的目標交易數據，并為所述目標交易數據設置預設的標簽鎖；其中，所述預設的標簽鎖包括基于redis分布式鎖的標簽鎖；

確定所述目標交易數據的交易類型和交易要素，并根據所述目標交易數據的交易類型、交易要素和預設的分配策略，從多個節點服務器中確定出目標節點服務器；其中，所述預設的分配策略包括基于dubbo一致性負載均衡的分配策略；

將設置有預設的標簽鎖的目標交易數據發送至目標節點服務器；其中，所述目標節點服務器用于獲取目標交易數據的關聯信息，并根據目標交易數據的關聯信息和預設的處理規則，有序處理所述目標交易數據。

在一個實施例中，所述交易類型包括以下至少之一：外匯交易、貴金屬交易、期貨交易。

在一個實施例中，所述交易要素包括以下至少之一：交易數據的發起者、交易數據所涉及的交易對手、交易數據所涉及的產品品種。

在一個實施例中，所述根據所述目標交易數據的交易類型、交易要素和預設的分配策略，從多個節點服務器中確定出目標節點服務器，包括：

根據所述目標交易數據的交易類型，從多個節點服務器中篩選出與目標交易數據的交易類型匹配的多個節點服務器，作為第二節點服務器；