(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 20221086710 6.6 (22)申请日 2022.07.22 (71)申请人 济南浪潮数据技 术有限公司 地址 250101 山东省济南市自由贸易试验 区济南片区浪潮路1036号 浪潮科技园 S05楼S311室 (72)发明人 孙伟源　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 薛娇 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/242(2019.01) G06F 16/25(2019.01) (54)发明名称 一种分布式数据存储的方法、 装置、 服务器 及介质 (57)摘要 本申请公开了一种分布式数据存储的方法、 装置、 服务器及介质， 涉及分布式存储技术领域。 该方法包括： 获取上层应用的SQL请求； 通过HA   Agent发送SQL请求至HA  Manager； 其中， HA   Manager与HA  Agent通过Zookeeper提供统一的 访问接口； 通过HA  Manager接收并处理SQL请求； 通过数据库响应处理后的SQL请求。 该方法中， 通 过Zookeeper提供给HA  Manager与HA  Agent统一 的访问接口， 使上层应用和下层数据库服务之间 解耦， 双方不用感知对方的存在， 因此， 本申请所 提供的分布式数据存储的方法具有良好的扩展 性和可用性。 权利要求书2页 说明书10页 附图3页 CN 115114376 A 2022.09.27 CN 115114376 A 1.一种分布式数据存 储的方法， 其特 征在于， 包括： 获取上层应用的SQ L请求； 通过HA Agent发送所述SQL请求至HA  Manager； 其中， 所述HA  Manager与所述HA  Agent 通过Zookeeper提供统一的访问接口； 通过所述HA Manager接收并处 理所述SQ L请求； 通过数据库响应处 理后的所述SQ L请求。 2.根据权利 要求1所述的分布式数据存储的方法， 其特征在于， 在所述通过HA  Agent发 送上层应用的SQ L请求至HA Manager之前， 还 包括： 通过所述HA  Agent按照固定频率从所述Zookeeper中获取各所述HA  Manager节点的状 态信息； 在各所述HA  Manager节点的负载满足第一预设要求或所述HA  Manager节点未出现故 障的情况 下， 则进入所述 通过HA Agent发送上层应用的SQ L请求至HA Manager的步骤； 反之， 则进入所述获取 上层应用的SQ L请求的步骤。 3.根据权利要求1或2所述的分布式数据存储的方法， 其特征在于， 所述HA  Manager接 收并处理所述SQ L请求包括： 接收所述SQ L请求并对所述SQ L请求进行解析； 获取解析后的所述SQ L请求的类型； 根据所述SQ L请求的类型处 理所述SQ L请求。 4.根据权利要求3所述的分布式数据存储的方法， 其特征在于， 所述根据所述SQL请求 的类型处 理所述SQ L请求包括： 在所述SQL请求为写操作的情况下， 获取所述写操作的相 关参数； 其中， 所述写操作的 相关参数至少包括本地节点 ID、 事务ID、 事务类型、 写操作类型的标识、 数据操作对象； 将所述写操作的相关参数以及所述SQ L请求组合成新的消息； 将所述新的消息 置于消息总线spread上； 通过所述消息总线spread转发并接收各 所述HA Manager节点的信息； 对各所述HA Manager节点的信息全局排序并解析 出所述SQL请求； 执行所述SQL请求； 在所述SQ L请求为只读操作的情况 下， 执行所述SQL请求。 5.根据权利要求4所述的分布式数据存储的方法， 其特征在于， 在所述接收所述SQL请 求之后， 所述对所述SQ L请求进行解析之前， 所述方法还 包括： 对所述SQ L请求进行 校验并获取 校验结果； 在所述校验结果满足第二预设要求的情况下， 进入所述对所述SQL请求进行解析的步 骤。 6.根据权利要求4所述的分布式数据存储的方法， 其特征在于， 在所述接收所述SQL请 求之后， 所述对所述SQ L请求进行解析之前， 所述方法还 包括： 获取所述SQL请求的相关参数； 其中， 所述SQL请求的相关参数至少包括所述SQL请求的 请求来源、 请求时间、 请求 参数； 将所述SQ L请求的相关参数记录 至日志中； 对应地， 在所述执 行所述SQL请求之前， 所述方法还 包括：权　利　要　求　书 1/2 页 2 CN 115114376 A 2更新所述日志。 7.根据权利要求6所述的分布式数据存 储的方法， 其特 征在于， 所述方法还 包括： 获取更新后的所述日志的信息； 根据所述日志的信息分析新加入的所述HA  Manager节点的信息或待恢复的所述HA   Manager节点的信息与正常的所述HA  Manager节点的信息的差异； 根据差异程度同步各 所述HA Manager节点的信息 。 8.一种分布式数据存 储的装置， 其特 征在于， 包括： 获取模块， 用于获取 上层应用的SQ L请求； 发送模块， 用于通过HA  Agent发送所述SQL请求至HA  Manager； 其中， 所述HA  Manager 与所述HA Agent通过Zo okeeper提供统一的访问接口； 接收及处 理模块， 用于通过 所述HA Manager接收并处 理所述SQ L请求； 响应模块， 用于通过 数据库响应处 理后的所述SQ L请求。 9.一种服 务器， 其特 征在于， 包括： 存储器， 用于存 储计算机程序； 处理器， 用于执行所述计算机程序时实现如权利要求1至7任一项所述的分布式数据存 储的方法的步骤。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质上存储有计算机 程序， 所述计算机程序被处理器执行时实现如权利要求 1至7任一项 所述的分布式数据存储 的方法的步骤。权　利　要　求　书 2/2 页 3 CN 115114376 A 3