[發明專利]一種多通道交易憑證異步回調處理方法和系統

有效

• 申請號: 202210495585.3
• 申請日: 2022-05-09
• 公開（公告）號: CN114581243B
• 公開（公告）日: 2022-09-23
• 發明（設計）人: 石寧;吳懷江;甘子榮;李達
• 申請（專利權）人: 南京金寧匯科技有限公司
• 主分類號: G06Q40/04
• 分類號: G06Q40/04;G06F9/448
• 代理公司: 北京弘權知識產權代理有限公司 11363
• 代理人: 李少丹;許偉群

1.一種多通道交易憑證異步回調處理方法，應用于由用戶端、業務系統以及多通道的區塊鏈網絡構成的系統，所述業務系統配置有業務發起模塊、區塊鏈調用模塊、回調模塊及業務系統數據庫；其特征在于，包括：初始化步驟、組裝步驟和業務處理步驟；

所述初始化步驟包括：

所述業務系統初始化通道節點鏈接池；

所述業務系統按照不同的交易類型分別定義每種交易類型的處理邏輯類；

所述組裝步驟包括：

所述業務系統組裝交易回調處理鏈；

所述回調模塊根據業務系統中通道列表，為每一個通道初始化一個通道組件，并將完成初始化的所述通道節點鏈接池、完成組裝的所述交易回調處理鏈和阻塞隊列，與當前通道下的所述通道組件進行綁定；

所述回調模塊創建回調消費管理組件，并指定其中包括的回調消費任務組件數量，將所述通道組件注冊到某一個所述回調消費任務組件中，一個所述回調消費任務組件允許多個所述通道組件進行注冊；

所述業務處理步驟包括：

所述業務系統完成所述初始化步驟及所述組裝步驟后啟動；

所述用戶端通過所述業務發起模塊發起對某個通道的調用命令；

所述區塊鏈調用模塊接收到所述調用命令后，首先構造合法的交易，然后根據當前通道ID查找到對應的所述通道組件，并從所述通道組件的所述通道節點鏈接池中，根據節點獲取策略拿取節點鏈接實體，并將所述交易發送至所述區塊鏈網絡；

所述區塊鏈網絡接收所述交易，并根據所述交易生成交易哈希值，將所述交易哈希值發送至所述回調模塊；

所述回調模塊在接收到所述區塊鏈網絡返回的所述交易哈希值后，將所述交易哈希值放到對應的所述通道組件的所述阻塞隊列中；

所述回調模塊的任務組線程循環掃描已注冊在當前所述回調消費任務組件下的所述通道組件列表，如果任意所述通道組件下的所述阻塞隊列中存在待消費的所述交易哈希值，則所述任務組線程從所述通道組件下的所述阻塞隊列中拿取所述交易哈希值；

所述任務組線程在所述通道組件下的所述通道節點鏈接池中，根據節點獲取策略拿取節點鏈接實體；

所述任務組線程通過所述節點鏈接實體訪問區塊鏈網絡，并使用所述交易哈希值在所述區塊鏈網絡中查詢對應的交易憑證，獲取到所述交易憑證后，調用所述通道組件中的所述交易回調處理鏈進行處理，并將處理結果在業務系統數據庫中更新。

2.根據權利要求1所述的一種多通道交易憑證異步回調處理方法，其特征在于，所述初始化通道節點鏈接池的方法為：

所述業務系統在所述業務系統數據庫中查詢所述業務系統中使用的所有通道以及通道中所包含的節點信息，其中，所述節點信息包括節點id，節點調用地址、節點訪問端口及用于訪問的公私鑰對；

根據所述節點信息，初始化節點鏈接實體，當前通道下的多個所述節點鏈接實體組成所述通道節點鏈接池。

3.根據權利要求1所述的一種多通道交易憑證異步回調處理方法，其特征在于，所述組裝交易回調處理鏈的方法為：

所述業務系統將自定義的處理邏輯類加入到所述交易回調處理鏈中，所述交易回調處理鏈允許加入的所述處理邏輯類的類型及數量不限，所述處理邏輯類在所述交易回調處理鏈中的位置、次序也不限。

4.根據權利要求1所述的一種多通道交易憑證異步回調處理方法，其特征在于，所述根據節點獲取策略拿取節點鏈接實體的方法為隨機策略：

所述隨機策略為：為列表中的每一個節點鏈接實體分配一個編號，在調用時使用隨機數算法，隨機抽取對應編號的節點實體鏈接。

5.根據權利要求1所述的一種多通道交易憑證異步回調處理方法，其特征在于，所述根據節點獲取策略拿取節點鏈接實體的方法為順序策略：

所述順序策略為：按照節點實體列表編號的順序，拿取對應的節點鏈接實體進行使用。

6.根據權利要求1所述的一種多通道交易憑證異步回調處理方法，其特征在于，所述根據節點獲取策略拿取節點鏈接實體的方法為可靠性策略：

所述可靠性策略為：向每個節點定時發送心跳信號，根據信號的穩定性來選擇最穩定的節點鏈接實體。