(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 20221073762 2.7 (22)申请日 2022.06.27 (71)申请人 招商银行股份有限公司 地址 518000 广东省深圳市福田区深南大 道7088招商银行 大厦 (72)发明人 曹延超　文俊杰　夏薇薇　蒋世文　 (74)专利代理 机构 深圳市世纪恒程知识产权代 理事务所 4 4287 专利代理师 冯会 (51)Int.Cl. G06F 16/21(2019.01) G06F 16/22(2019.01) G06F 9/50(2006.01) H04L 41/0896(2022.01) (54)发明名称 集群在线 扩容方法、 系统、 设备及存 储介质 (57)摘要 本申请公开了一种集群在线扩容方法、 系 统、 设备及存储介质， 包括： 确定各个数据的原始 集群的集群编号； 若当前扩容迭代次数小于扩容 记录长度， 则确定新增集群的数量， 并基于各个 数据的数据主键值、 新增集群以及原始集群的数 量， 计算各个数据的第一哈希值； 若第一哈希值 小于原始集群的数量， 则确定数据对应的原始集 群的集群编号； 若第一哈希值不小于原始集群的 数量， 则计算数据对应的新增集群的集群编号； 直至当前扩容迭代次数不小于扩容记录长度， 得 到各个数据对应的最终集群编号， 以将各个数据 迁移至最终集群编号对应的集群中。 本申请解决 目前集群离线扩容过程中无法正常进行数据处 理， 并且数据在迁移过程中难以均衡存储在各个 集群中的技 术问题。 权利要求书2页 说明书9页 附图4页 CN 115145893 A 2022.10.04 CN 115145893 A 1.一种集群在线扩容方法， 其特 征在于， 所述 集群在线扩容方法包括： 确定各个数据在扩容迭代之前对应的原 始集群的集群编号； 若当前扩容迭代次数小于预先设置的扩容记录长度， 则确定当前扩容迭代次数的新增 集群的数量， 并基于各个数据的数据主键值、 新增集群的数量和原始 集群的数量， 计算各个 数据的第一哈希值； 若所述数据的第 一哈希值小于当前扩容迭代次数的原始集群的数量， 则确定所述数据 在当前扩容迭代次数对应的原 始集群的集群编号； 若所述数据的第 一哈希值不小于当前扩容迭代次数的原始集群的数量， 则 基于所述数 据的数据主键值、 所述新增 集群的数量和所述原始集群的数量， 计算所述数据在当前扩容 迭代次数对应的新增集群的集群编号； 返回执行步骤： 若当前扩容迭代次数小于预先设置的扩容记录长度， 则确定当前扩容 迭代次数 的新增集群的数量， 直至当前扩容迭代次数不小于所述扩容记录长度， 得到各个 数据对应的最终集群编号， 以将各个数据在线迁移至所述 最终集群编号对应的集群中。 2.如权利要求1所述的集群在线扩容方法， 其特征在于， 所述确定各个数据在扩容迭代 之前对应的原 始集群的集群编号的步骤 包括： 分别将各所述数据的数据主键值与 所述原始集群的数量进行取模运算， 得到各个数据 的第二哈希值； 基于各所述数据的第二哈希值， 确定每一所述数据对应的原 始集群的集群编号。 3.如权利要求1所述的集群在线扩容方法， 其特征在于， 所述若所述数据的第 一哈希值 不小于当前扩容迭代 次数的原始集群的数量， 则基于所述数据的数据主键值、 所述新增集 群的数量和所述原始 集群的数量， 计算所述数据在当前扩容迭代次数对应的新增集群的集 群编号的步骤 包括： 若所述数据的第 一哈希值不小于当前扩容迭代次数的原始集群的数量， 则将所述数据 主键值与所述 新增集群的数量进行 取模运算， 得到所述数据的第三哈希值； 将所述第三哈希值与当前扩容迭代次数的原始集群的数量进行相加， 得到所述数据对 应的新增集群的集群编号。 4.如权利要求1所述的集群在线扩容方法， 其特征在于， 所述若所述数据的第 一哈希值 小于当前扩容迭代次数的原始集群的数量， 则确定所述数据在当前扩容迭代次数对应的原 始集群的集群编号的步骤 包括： 若所述数据的第 一哈希值小于当前扩容迭代次数的原始集群的数量， 则将所述数据在 当前扩容迭代次数之前对应的原始集群的集群编号作为所述数据在当前扩容迭代次数对 应的集群编号。 5.如权利要求1所述的集群在线扩容方法， 其特征在于， 所述将各个数据在线迁移至所 述最终集群编号对应的集群中的步骤 包括： 分别判断各个数据对应的最终集群编号是否属于所述扩容迭代之前的原始集群的集 群编号； 若是， 则无需将所述数据进行迁移； 若否， 则将所述数据从扩容迭代之前的原始集群迁移至所述最终集群编 号对应的新增 集群。权　利　要　求　书 1/2 页 2 CN 115145893 A 26.如权利要求5所述的集群在线扩容方法， 其特征在于， 在所述将所述数据从扩容迭代 之前的原始 集群迁移至所述最终集群编号对应的新增集群的步骤之后， 所述集群在线扩容 方法包括： 若在数据迁移完成之前， 接收到用户的数据查询请求， 则基于所述数据查询请求， 在所 述原始集群以及所述最终集群编号对应的新增 集群中进行查询， 得到查询结果， 以将查询 结果返回给用户。 7.如权利要求1所述的集群在线扩容方法， 其特征在于， 在所述将各个数据在线迁移至 所述最终集群编号对应的集群中的步骤之后， 所述 集群在线扩容方法还 包括： 基于各所述数据的最终集群编号， 计算各个集群的存储负载量， 以基于各个集群的存 储负载量， 确定是否需要 进行集群扩容。 8.一种集群在线扩容系统， 其特 征在于， 所述 集群在线扩容系统包括： 第一确定模块， 用于确定各个数据在扩容迭代之前对应的原 始集群的集群编号； 第一计算模块， 用于若当前扩容迭代次数小于预先设置的扩容记录长度， 则确定当前 扩容迭代次数 的新增集群的数量， 并基于各个数据的数据主键值、 新增 集群的数量和原始 集群的数量， 计算各个数据的第一哈希值； 第二确定模块， 用于若所述数据的第 一哈希值小于当前扩容迭代次数的原始集群的数 量， 则确定所述数据在当前扩容迭代次数对应的原 始集群的集群编号； 第二计算模块， 用于若所述数据的第 一哈希值不小于当前扩容迭代次数的原始集群的 数量， 则基于所述数据的数据主键值、 所述新增集群的数量和所述原始 集群的数量， 计算所 述数据在当前扩容迭代次数对应的新增集群的集群编号； 迁移模块， 用于返回执行步骤： 若当前扩容迭代次数小于预先设置的扩容记录长度， 则 确定当前扩容迭代次数的新增集群的数量， 直至当前扩容迭代次数不小于所述扩容记录长 度， 得到各个数据对应的最终集群编号， 以将各个数据在线迁移至所述最终集群编号对应 的集群中。 9.一种集群在线扩容设备， 其特征在于， 所述集群在线扩容设备包括： 存储器、 处理器 以及存储在存储器上的集群在线扩容 程序， 所述集群在线扩容程序被所述处理器执行实现如权利要求1至7中任一项所述集群在 线扩容方法的步骤。 10.一种存储介质， 所述存储介质为计算机可读存储介质， 其特征在于， 所述计算机可 读存储介质上存储有集群在线扩容程序， 所述集群在线扩容程序被处理器执行实现如权利 要求1至7中任一项所述 集群在线扩容方法的步骤。权　利　要　求　书 2/2 页 3 CN 115145893 A 3