(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211077338.8 (22)申请日 2022.09.05 (71)申请人 深圳前海微众 银行股份有限公司 地址 518027 广东省深圳市前海深港合作 区前湾一路1号A栋201室 (72)发明人 熊林博　 (74)专利代理 机构 北京同立钧成知识产权代理 有限公司 1 1205 专利代理师 吴会英　刘芳 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 数据传输方法、 装置、 设备及存 储介质 (57)摘要 本申请提供一种数据传输方法、 装置、 设备 及存储介质， 该方法包括： 第一系统获取第二系 统向多个第一处理节点的每一第一处理节点传 输当前批次数据的数据传输时长， 根据每一第一 处理节点的内存溢出指标、 数据传输时长和多个 资源性能参数， 确定每一第一处理节 点的当前负 载， 根据每一第一处理节点的当前负载， 从多个 第一处理节 点中确定出目标处理节 点， 最后将目 标处理节 点的标识发送至第二系统， 以使通过目 标处理节 点接收第二系统下一批次传输的数据。 在本方案中， 充分考虑了第一系统中不同处理节 点的处理能力和状态， 从而提高了负载均衡性。 权利要求书4页 说明书27页 附图4页 CN 115357398 A 2022.11.18 CN 115357398 A 1.一种数据传输方法， 其特征在于， 应用于第一系统， 所述第一系统包括多个处理节 点， 所述方法包括： 获取第二系统向多个第一处理节点中的每一第一处理节点传输当前批次数据的数据 传输时长， 所述多个第一处 理节点是从所述多个处 理节点中确定的； 根据每一第一处理节点的内存溢出指标、 数据传输时长和多个资源性能参数， 确定每 一第一处理节点的当前负载， 每一第一处理节点的内存溢出指标用于表示该第一处理节点 的内存是否溢出； 根据每一第一处理节点的当前负载， 从所述多个第一处理节点中确定出目标处理节 点； 将所述目标处理节点的标识发送至所述第 二系统， 以使通过所述目标处理节点接收所 述第二系统下一批次传输的数据。 2.根据权利要求1所述的方法， 其特征在于， 所述根据每一第 一处理节点的内存溢出指 标、 数据传输时长和多个资源性能参数， 确定每一第一处 理节点的当前负载， 包括： 根据每一第 一处理节点的内存溢出指标和多个资源性能参数， 确定每一资源性 能的权 重值， 每一资源性能的权 重值用于表示该资源性能对第一处 理节点的当前负载的重要性； 根据每一资源性能的权重值、 每一第一处理节点的数据传输时长和多个资源性能参 数， 确定每一第一处 理节点的当前负载。 3.根据权利要求2所述的方法， 其特征在于， 所述根据每一第 一处理节点的内存溢出指 标和多个资源性能参数， 确定每一资源性能的权 重值， 包括： 针对每一资源性能， 根据每一第一处理节点的该资源性能参数， 确定多个初始资源性 能参数， 每一初始资源性能参数均处于多个第一处理节点的该资源性能参数所在的参数范 围内； 根据每一第 一处理节点的内存溢出指标以及该资源性能参数， 确定每一初始资源性 能 参数的基尼指数； 根据所述基尼指数的最小值确定该资源性能的权 重值。 4.根据权利要求3所述的方法， 其特征在于， 所述针对每一资源性能， 根据每一第一处 理节点的该资源性能参数， 确定多个初始资源性能参数， 包括： 针对每一资源性 能， 根据由大到小的顺序将所述多个第 一处理节点的资源性 能参数进 行排序， 获取排序结果； 根据所述 排序结果， 将相邻两个资源性能参数的平均值确定为初始资源性能参数。 5.根据权利要求1所述的方法， 其特征在于， 在所述根据每一第 一处理节点的内存溢出 指标、 数据传输时长和多个资源性能参数， 确定每一第一处理节点的当前负载之后， 所述方 法还包括： 将每一第一处理节点的当前负载确定为该第一处理节点的当前综合负载样本指数加 权移动平均SLEWMA值； 相应的， 所述根据每一第一处理节点的当前负载， 从所述多个第一处理节点中确定出 目标处理节点， 包括： 根据每一第一处理节点的当前SLEWMA值， 从所述多个第一处理节点中确定出满足预设 条件的所述目标处理节 点， 所述预设条件为第一处理节 点的当前SLEWMA值大于预设SLEWMA权　利　要　求　书 1/4 页 2 CN 115357398 A 2值， 或当前SLEWMA值 最大的预设数量个第一处 理节点。 6.根据权利要求5所述的方法， 其特征在于， 在所述根据每一第一处理节点的当前 SLEWMA值， 从所述多个第一处理节点中确定出满足预设条件的所述目标处理节点之后， 所 述方法还 包括： 根据所述目标处理节点的当前SLEWMA值， 将所述目标处理节点的标识放入初始为空的 大顶堆中， 生成第一大顶堆； 相应的， 所述将所述目标处 理节点的标识发送至所述第二系统， 包括： 根据由下到上的顺序， 将所述第 一大顶堆中的所述目标处理节点的标识依次发送至所 述第二系统。 7.根据权利要求6所述的方法， 其特征在于， 在所述将所述目标处理节点的标识发送至 所述第二系统之后， 所述方法还 包括： 将每一第一处理节点的当前负载确定为历史负载， 并从所述多个处理节点中重新确定 出多个第二处 理节点； 根据每一第二处理节点的内存溢出指标、 多个资源性能参数以及数据传输时长， 确定 每一第二处 理节点的当前负载； 根据每一第 二处理节点的当前负载以及所述目标处理节点的历史负载， 从所述多个第 二处理节点以及所述目标处 理节点中重新确定出新的目标处 理节点； 将所述新的目标处 理节点的标识发送至所述第二系统。 8.根据权利要求7所述的方法， 其特征在于， 在所述根据每一第 二处理节点的内存溢出 指标、 多个 资源性能参数以及数据传输时长， 确定每一第二处理节 点的当前负载之后， 所述 方法还包括： 若任一第二处理节点不存在所述历史负载， 则将该第 二处理节点的当前负载确定为该 第二处理节点的当前SLEWMA值； 若任一第二处理节点存在所述历史负载， 则根据该第二处理节点的当前负载、 所述历 史负载以及预先设置的毛刺变量， 计算该第二处理节点的当前SLEWMA值， 所述毛刺变量是 根据所述历史负载确定的； 根据所述目标处理节点的历史负载以及所述毛刺变量， 确定所述目标处理节点的历史 SLEWMA值； 相应的， 所述根据每一第二处理节点的当前负载以及所述目标处理节点的历史负载， 从所述多个第二处 理节点以及所述目标处 理节点中重新确定出新的目标处 理节点， 包括： 根据所述目标处理节点的历史SLEWMA值以及每一第二处理节点的当前SLEWMA值， 从多 个第二处 理节点和所述目标处 理节点中重新确定出 所述新的目标处 理节点。 9.根据权利要求8所述的方法， 其特征在于， 在所述根据所述目标处理节点的历史 SLEWMA值以及每一第二处理节 点的当前SLEWMA 值， 从多个第二处理节 点和所述目标处理节 点中重新确定出 所述新的目标处 理节点之后， 所述方法还 包括： 根据所述新的目标处理节点的当前SLEWMA值以及标识， 对所述第一大顶堆进行更新， 生成第二大顶堆； 相应的， 所述将所述 新的目标处 理节点的标识发送至所述第二系统， 包括： 根据由下到上的顺序， 将所述第 二大顶堆中的新的目标处理节点的标识依次发送至所权　利　要　求　书 2/4 页 3 CN 115357398 A 3