[發明專利]基于IPFS的分布式實時數據同步方法、節點設備及系統

有效

• 申請號: 202010844374.7
• 申請日: 2020-08-20
• 公開（公告）號: CN112035422B
• 公開（公告）日: 2022-03-25
• 發明（設計）人: 佘鵬飛;孫曉鵬;李鑫;馬驥;周小欠
• 申請（專利權）人: 鄭州信大捷安信息技術股份有限公司
• 主分類號: G06F16/178
• 分類號: G06F16/178;G06F16/182
• 代理公司: 鄭州德勤知識產權代理有限公司 41128
• 代理人: 武亞楠

1.一種基于IPFS的分布式實時數據同步方法，其特征在于，包括以下步驟：

步驟S1，配置同步服務節點：在每個Fastdfs storage節點所屬主機部署IPFS節點，以創建跨公網的私有p2p網絡；

步驟S2，部署集成SDK，初始化所述集成SDK，加載Fastdfs存儲目錄到所述IPFS節點，通過IPFS節點訂閱所有Fastdfs二級目錄主題；

步驟S3，所述集成SDK實時監聽Fastdfs storage 文件事件；

步驟S4，在所述集成SDK監聽到Fastdfs storage 文件事件后，添加事件對應的文件所在的Fastdfs二級存儲目錄到IPFS節點，生成新的IPFS CID；

步驟S5，集成SDK依據監聽到的Fastdfs storage 文件事件類型，判斷是否將消息發布到特定訂閱主題；

步驟S6，集成SDK接收對應同步服務節點訂閱的主題更新的消息，執行對應的數據同步策略，實現跨公網的不同內網之間的數據實時同步。

2.根據權利要求1所述的基于IPFS的分布式實時數據同步方法，其特征在于，步驟S5中集成SDK依據監聽到的Fastdfs storage 文件事件類型，判斷是否將消息發布到特定訂閱主題時，執行：

若集成SDK監聽到同步服務節點發生源創建事件、源追加事件和源刪除事件，則將消息發布到特定訂閱主題；

若集成SDK監聽到同步服務節點發生副本創建事件、副本追加事件和副本刪除事件，則不將消息發布到特定訂閱主題。

3.根據權利要求1所述的基于IPFS的分布式實時數據同步方法，其特征在于，還包括：標記所述集成SDK服務的同步服務節點類型；其中，所述同步服務節點類型包括源節點和同步節點，所述源節點為主中心同步服務節點，所述同步節點為備中心同步服務節點；

集成SDK依據監聽到的Fastdfs storage 文件事件類型及對應的同步服務節點類型，判斷是否將消息發布到特定訂閱主題；若集成SDK監聽到主中心同步服務節點發生源創建事件、源追加事件和源刪除事件，則將消息發布到特定訂閱主題；若集成SDK監聽到備中心同步服務節點發生源創建事件、源追加事件和源刪除事件，則不將消息發布到特定訂閱主題。

4.根據權利要求2或3所述的基于IPFS的分布式實時數據同步方法，其特征在于，所述特定訂閱主題的消息內容包括事件類型、Fastdfs fileId、時間戳和IPFS CID；

在進行數據同步時，所述同步服務節點基于所述時間戳確定另一內網中的各個同組同步服務節點對應的同步數據分塊，并利用IPFS節點的特性同時從多個同步服務節點下載同步數據分塊。

5.一種節點設備，其特征在于，包括同步服務節點和集成SDK；

所述同步服務節點，包括Fastdfs storage節點和IPFS節點，其中，所述IPFS節點基于Fastdfs集群中的Fastdfs storage節點進行分布式部署，所述Fastdfs storage節點用于提供業務數據文件存儲服務；所述IPFS節點部署在每一Fastdfs storage節點的同一主機上，用于為所述Fastdfs集群提供跨公網的私有p2p網絡；

所述集成SDK，設置Fastdfs文件消息監聽服務、同步邏輯業務處理服務和消息主題服務；用于在監聽到Fastdfs storage 文件事件后，添加事件對應的文件所在的Fastdfs二級存儲目錄到IPFS節點，生成新的IPFS CID；以及依據監聽到的Fastdfs storage 文件事件類型，判斷是否將消息發布到特定訂閱主題；以及接收對應同步服務節點訂閱的主題更新的消息，使用IPFS節點通過IPFS CID從處于同一內網的同組同步服務節點下載同步數據，或者從處于不同內網的同組同步服務節點下載同步數據，實現跨公網的不同內網之間的數據實時同步。

6.根據權利要求5所述的節點設備，其特征在于，所述集成SDK，用于在監聽到對應同步服務節點發生源創建事件、源追加事件和源刪除事件時，將消息發布到特定訂閱主題；在監聽到對應同步服務節點發生副本創建事件、副本追加事件和副本刪除事件時，不將消息發布到特定訂閱主題。