[發明專利]基于區塊鏈的事件訂閱系統

有效

• 申請號: 202011200043.6
• 申請日: 2020-11-02
• 公開（公告）號: CN112016115B
• 公開（公告）日: 2021-02-05
• 發明（設計）人: 唐紅武;佟業新;曲新奎;郭琛;馮海偉;張軍濤;李文杰
• 申請（專利權）人: 中航信移動科技有限公司
• 主分類號: G06F21/60
• 分類號: G06F21/60
• 代理公司: 北京鍾維聯合知識產權代理有限公司 11579
• 代理人: 丁慧玲

1.一種基于區塊鏈的事件訂閱系統，其特征在于，包括：區塊鏈、處理器和存儲有計算機程序的存儲器，所述區塊鏈包括一個第一通道、至少一個第二通道和一個事件分發模塊，

當所述計算機程序被處理器執行時，實現以下步驟：

步驟S1、所述第一通道獲取事件注冊信息、事件訂閱信息，并根據所述事件注冊信息、事件訂閱信息生成事件訂閱配置表，所述事件訂閱配置表的字段包括第一節點id、事件類型id、事件結構信息和對應的至少一個第二節點的公鑰信息，每一事件類型id對應的所有第二節點的公鑰信息構成該事件類型id對應的訂閱公鑰列表；

步驟S2、每一所述第二通道生成至少一個事件數據并發送給所述第一通道，所述事件數據包括事件結構信息和對應的事件原始數據；

步驟S3、所述第一通道基于所述事件訂閱配置表和所述事件數據生成待發送事件數據，并發送給對應的第二通道；

所述步驟S3包括：

步驟S301、所述第一通道從所述事件訂閱配置表中獲取每一事件類型id對應的訂閱公鑰列表，并從所述第二通道發送的事件數據中獲取每一事件類型id對應的事件數據；

步驟S302、遍歷所述訂閱公鑰列表，逐一采用所述訂閱公鑰列表中的每一公鑰信息將對應的事件數據進行加密，生成每一公鑰信息對應的訂閱事件加密數據，將每一訂閱公鑰列表對應的所有訂閱事件加密數據合并為待發送事件數據并發送給所述第二通道；

步驟S4、每一所述第二通道將所接收的待發送事件數據發送至事件分發模塊，所述事件分發模塊將所述待發送事件數據進行分發。

2.根據權利要求1所述的系統，其特征在于，

所述步驟S1中包括：

步驟S101、所述第一通道接收第一節點發送的事件注冊請求，并從中解析出第一節點id、事件結構信息，并根據所述事件注冊請求生成對應的事件類型id，所述第一節點id、事件結構信息、事件類型id構成所述事件注冊信息，所述第一節點為事件生成節點；

步驟S102、所述第一通道接收第二節點發送的事件訂閱請求，并從中解析出第二節點的公鑰信息和對應的事件類型id，所述第二節點的公鑰信息和對應的事件類型id構成所述事件訂閱信息，所述第二節點為事件訂閱方節點；

步驟S103、基于所述事件注冊信息和事件訂閱信息生成所述事件訂閱配置表。

3.根據權利要求2所述的系統，其特征在于，

所述步驟S301和步驟S302之間，還包括步驟S311、從所述注冊信息中獲取所述第二通道發送的事件數據的事件類型id所對應的節點id，校驗所述第二通道發送的事件數據對應的生成事件的節點id，若校驗通過，則執行步驟S302。

4.根據權利要求2所述的系統，其特征在于，

所述步驟S4中，所述事件分發模塊將所述待發送事件數據進行分發，包括：

步驟S401、所述事件分發模塊解析所接收的待發送事件數據，獲取每一訂閱事件加密數據以及對應的第二節點id，為每一第二節點創建一個事件隊列，將同一第二節點id對應的訂閱事件加密數據發送至對應的事件隊列中；

步驟S402、每一事件隊列將隊列中的訂閱事件加密數據發送至對應的第二節點上。

5.根據權利要求4所述的系統，其特征在于，

所述事件隊列為kafka隊列，所述步驟S4還包括步驟403、采用kafka ACL控制機制，為每一第二節點對應的事件隊列設置對應的權限，所述權限包括只讀權限。

6.根據權利要求2所述的系統，其特征在于，

所述步驟S1還包括步驟S100、

所述第一通道向所述第二節點發送訂閱的事件id對應的事件結構信息。

7.根據權利要求6所述的系統，其特征在于，

所述步驟S4之后還包括步驟S5、

步驟S51、所述第二節點根據該第二節點的私鑰從所接收的訂閱事件加密數據中解析出訂閱事件數據；

步驟S52、根據所述訂閱事件數據和訂閱的事件id對應的事件結構信息從所述訂閱事件數據中解析出訂閱事件原始數據。