[發明專利]一種分布式數據庫集群系統對等處理系統及處理方法

在審

• 申請號: 202110248728.6
• 申請日: 2021-03-08
• 公開（公告）號: CN112597173A
• 公開（公告）日: 2021-04-02
• 發明（設計）人: 況忠強;王漢瑛;吳生勇;謝旭東;蘇德財;李尤兵;曹茜;馮治龍;明玉琢;李文彬;許雄基
• 申請（專利權）人: 成都虛谷偉業科技有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/2455;G06F16/27
• 代理公司: 成都聚蓉眾享知識產權代理有限公司 51291
• 代理人: 張輝

本發明公開了一種分布式數據庫集群系統對等處理系統，包括數個客戶端、數個工作節點和數個存儲節點，數個所述工作節點相互關聯，形成工作集群，每個所述的客戶端用于生成請求信息流發送至工作集群，接收工作集群返回的處理結果集；每個所述工作節點用于與工作集群中的其它工作節點關聯，讀取請求信息流并將請求信息流轉化為數據信息流，對工作集群中的工作節點進行任務分割，對分割后的數據信息流進行中間處理，同時從存儲集群獲取處理結果集并輸出至客戶端；每個所述存儲節點用于對存儲數據進行過濾，接收工作集群的數據信息流，生成處理結果集并輸出至工作集群。本發明還公開了一種分布式數據庫集群系統對等處理方法。

技術領域

本發明屬于分布式數據庫技術領域，具體涉及一種分布式數據庫集群系統對等處理系統及處理方法。

背景技術

分布式數據庫系統通常使用較小的計算機系統，每臺計算機中都可能有DBMS的一份完整拷貝副本，或者部分拷貝副本，并具有自己局部的數據庫，位于不同地點的許多計算機通過網絡互相連接，共同組成一個完整的、全局的邏輯上集中、物理上分布的大型數據庫。

分布式數據庫的數據一般采用對等處理的方式進行，也就是將工作節點相互關聯。對于整個工作集群而言，各工作節點相互關聯且具有相等的能力，接入其中一個工作節點即可接入整個工作集群。但，目前分布式數據庫的數據對等處理方式太過龐雜，處理方式不穩定，不能滿足日益發展的需求。

發明內容

本發明所要解決的技術問題便是針對上述現有技術的不足，提供一種分布式數據庫集群系統數據分流方法，對等處理的方式簡單且處理效率較高。

本發明所采用的技術方案是：一種分布式數據庫集群系統對等處理系統，包括數個客戶端、數個工作節點和數個存儲節點，數個所述工作節點相互關聯，形成工作集群，數個所述存儲節點相互關聯，形成存儲集群；

每個所述的客戶端用于生成請求信息流發送至工作集群，接收工作集群返回的處理結果集；

每個所述工作節點用于與工作集群中的其它工作節點關聯，讀取請求信息流并將請求信息流轉化為數據信息流，對工作集群中的工作節點進行任務分割，對分割后的數據信息流進行中間處理，同時從存儲集群獲取處理結果集并輸出至客戶端；

每個所述存儲節點用于對存儲在自身節點的數據進行過濾，接收工作集群的數據信息流，生成處理結果集并輸出至工作集群。

本發明還公開了一種分布式數據庫集群系統對等處理方法，包括以下步驟：

步驟10、客戶端連通工作集群中任意一工作節點，發送查詢請求至該工作節點；

步驟20、接收查詢請求的工作節點根據查詢請求的內容進行任務分割并生成查詢任務，指定查詢任務待發送的目標存儲節點，并將該查詢任務輸出至存儲集群中對應的存儲節點；

步驟30、存儲集群中對應的存儲節點根據接收到的查詢請求提取相關數據，生成處理結果集，輸出至工作集群，對數據進行進一步處理后將數據發送至進行任務分割的工作節點；

步驟40、進行任務分割的工作節點接收處理結果集，將進行中間處理后的結果集輸出至客戶端。

其中一個實施例中，還包括存儲數據過濾步驟，具體如下：

客戶端發送過濾條件至工作集群中任意一工作節點，該工作節點接收過濾條件并進行任務分割，將過濾條件傳輸至存儲集群，存儲集群中每個存儲節點根據過濾條件對存儲的數據進行過濾，調取過濾后的數據并生成處理結果集，輸出至工作集群，對數據進行進一步處理后輸出至接收過濾條件的工作節點。

其中一個實施例中，步驟20中，所述的任務分割，具體如下：

提取生成的數據信息流中包含的存儲節點的編號并根據該編號對數據信息流進行分組，將分組后的數據流傳輸至對應編號的存儲節點。

其中一個實施例中，步驟30和存儲數據過濾步驟中，所述的對數據進行進一步處理包括數值運算或統計計算。