[發明專利]一種流數據管理方法、數據庫集群、裝置及設備

在審

• 申請號: 202310229323.7
• 申請日: 2023-03-07
• 公開（公告）號: CN116360920A
• 公開（公告）日: 2023-06-30
• 發明（設計）人: 江惠中
• 申請（專利權）人: 浙江大華技術股份有限公司
• 主分類號: G06F9/455
• 分類號: G06F9/455
• 代理公司: 北京同達信恒知識產權代理有限公司 11291
• 代理人: 杜晶

本申請涉及一種流數據管理方法、數據庫集群、裝置及設備，用于解決現有技術中無法隔離主從節點之間的強耦合關系的技術問題，該方法應用于關系型數據庫集群中的流數據管理裝置中，流數據管理裝置連接所述關系型數據庫集群中的主節點和從節點，主節點和從節點通過流數據管理裝置進行數據交換，包括：根據主節點和從節點所屬的數據庫類型，調整流數據管理裝置支持的數據庫協議；使用主節點的數據庫協議，從主節點中接收流數據并保存，然后根據流數據的分發對象，將流數據通過從節點的數據庫協議發送給從節點。

技術領域

本申請涉及數據庫技術領域，特別涉及一種流數據管理方法、數據庫集群、裝置及設備。

背景技術

目前市場上使用的開源數據庫很多，比如傳統關系型數據庫Mysql、Postgresql，都滿足ACID要求，同時功能全面、強大，可滿足多種生產環境的需求，支持二次開發，市場占有率高。為達到數據庫高可用的目的，各個數據庫都為上層實現主從架構提供了底層的支持。

但同時，關系型數據庫集群通常由主節點和從節點構成，主從節點之間通常為強耦合關系，當主節點需要部署多個從節點時，需要將數據同時同步多個從節點中，增加了主節點的壓力；并且，當主節點出現故障時，容易影響從節點，導致數據庫無法正常運行。

鑒于此，如何隔離主從節點之間的強耦合關系成了一個亟待解決的技術問題。

發明內容

本申請實施例提供了一種流數據管理方法、數據庫集群、裝置及設備，用于解決現有技術中無法隔離主從節點之間的強耦合關系的技術問題。

本申請第一方面提供了一種流數據管理方法，應用于關系型數據庫集群中的流數據管理裝置中，所述流數據管理裝置連接所述關系型數據庫集群中的主節點和從節點，所述主節點和所述從節點通過所述流數據管理裝置進行數據交換，所述方法包括：

根據所述主節點和所述從節點所屬的數據庫類型，調整所述流數據管理裝置支持的數據庫協議；

使用所述主節點的數據庫協議，從所述主節點中接收流數據并保存，然后根據所述流數據的分發對象，將所述流數據通過所述從節點的數據庫協議發送給所述從節點。

可選的，根據所述主節點和所述從節點所屬的數據庫類型，調整所述流數據管理裝置支持的數據庫協議，包括：

建立虛擬從節點連接所述主節點，獲取所述主節點所屬的數據庫協議，并增加至所述流數據管理裝置支持的數據庫協議中；

作為主節點連接所述從節點，獲取所述從節點所屬的數據庫協議，并增加至所述流數據管理裝置支持的數據庫協議中。

可選的，調整所述流數據管理裝置支持的數據庫協議之后，包括：

使用調整后的數據庫協議向所有的主節點和從節點發送心跳包，接收各個節點返回的狀態信息并更新到數據庫集群信息管理表中；

根據所述狀態信息，判斷是否有故障節點，若有故障節點，則將故障節點在數據庫集群信息管理表中進行標記。

可選的，將故障節點在數據庫集群信息管理表中進行標記之后，包括：

若標記的所述故障節點為主節點，則將所述故障節點屏蔽至數據庫集群之外，待所述故障節點修復上線后再重新注冊至數據庫集群中；

若標記的所述故障節點為從節點，則從主節點中獲取所述從節點中的數據，并同步至所述故障節點中，以將所述故障節點恢復為正常節點。

第二方面，本申請提供一種數據庫集群，包括：

主節點，用于下發數據，并配置數據庫集群中的從節點；

從節點，用于接收并存儲數據；