(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211108327.1 (22)申请日 2022.09.13 (71)申请人 天翼云科技有限公司 地址 100007 北京市东城区青龙胡同甲1 号、 3号2幢2层20 5-32室 (72)发明人 张杰　黄创光　 (74)专利代理 机构 北京同达信恒知识产权代理 有限公司 1 1291 专利代理师 周秀珍 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/445(2018.01) G06F 9/50(2006.01) G06F 16/25(2019.01) (54)发明名称 一种服务调度方法及装置 (57)摘要 本申请实施例提供一种服务调度方法及装 置， 应用在通信技术领域， 包括： 通过多线程采集 多个数据源的业务请求； 基于配置参数对获得的 多个业务请求进行校验， 并将校验合格的业务请 求进行封装， 获得多个待处理业务数据； 基于每 个待处理业务数据的类型， 确定相应的业务服务 器， 并通过多线程池将多个待处理业务数据调度 至相应的业务服务器进行处理。 基于flink架构 的多线程并发采集能力和调度服务器内部多线 程池， 使得同一主题数据源可以实现多个任务并 发执行， 并可以按照业务请求类型和调度服务器 的配置对并发数据的处理， 可在 线程上最大程度 提高叠加效率， 提高对业 务的处理效率。 权利要求书1页 说明书7页 附图3页 CN 115469986 A 2022.12.13 CN 115469986 A 1.一种服 务调度方法， 应用于调度服 务器， 其特 征在于， 包括： 通过多线程采集多个数据源的业务请求； 基于配置参数对获得的多个业务请求进行校 验， 并将校验合格的业 务请求进行封装， 获得多个待处 理业务数据； 基于每个待处理业务数据的类型， 确定相应的业务服务器， 并通过多线程池将所述多 个待处理业务数据调度至相应的业 务服务器进行处 理。 2.如权利要求1所述的方法， 其特征在于， 所述通过多线程采集多个数据源的业务请求 之后， 还包括： 将所述多个数据源的业 务请求添加在到异步消息队列中； 所述基于配置参数对获得的多个业务请求进行校验， 并将校验合格的业务请求进行封 装， 获得多个待处 理业务数据之前， 还 包括： 从所述异步消息队列中获取 所述多个业 务请求。 3.如权利要求1所述的方法， 其特征在于， 所述多个业务请求的格式相同， 且每个业务 请求携带一个唯一标识。 4.如权利要求1所述的方法， 其特 征在于， 还 包括： 将校验不 合格的业 务请求添加到异常数据库。 5.如权利要求1所述的方法， 其特 征在于， 还 包括： 在监测到服 务调度异常时， 生成调度异常信息， 并将调度异常信息保存在异常数据库。 6.如权利要求5所述的方法， 其特 征在于， 还 包括： 若所述调度异常信 息表征网络异常或服务异常， 则通过异常补偿任务重新执行服务调 度。 7.如权利要求5所述的方法， 其特 征在于， 还 包括： 对所述异常数据库中的调度异常信息进行分类和统计。 8.一种服 务调度装置， 其特 征在于， 包括： 采集模块， 通过多线程采集多个数据源的业务请求； 基于配置参数对获得的多个业务 请求进行 校验， 并将校验合格的业 务请求进行封装， 获得多个待处 理业务数据； 处理模块， 用于基于每个待处理业务数据的类型， 确定相应的业务服务器， 并通过多线 程池将所述多个待处 理业务数据调度至相应的业 务服务器进行处 理。 9.一种计算机设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计 算机程序， 其特征在于， 所述处理器执行所述程序时实现权利要求1～7任一所述方法的步 骤。 10.一种计算机可读存储介质， 其特征在于， 其存储有可由计算机设备执行的计算机程 序， 当所述程序在计算机设备上运行时， 使得所述计算机设备执行权利要求1～7任一所述 方法的步骤。权　利　要　求　书 1/1 页 2 CN 115469986 A 2一种服务调度方 法及装置 技术领域 [0001]本申请涉及通信技 术领域， 尤其涉及一种服 务调度方法及装置 。 背景技术 [0002]随着互联 网技术的发展， 人们对业务数据处理速度的要求越来越高。 相关技术下， 用户的服 务请求往 往需要服 务器并行处 理， 部分专门业 务请求还需要更 快、 更及时的响应。 [0003]然而， 在普通架构下， 当业务请求量过大时， 普通架构对单一业务请求的处理率下 降， 从而导 致业务的处理效率较低。 发明内容 [0004]本申请实施例提供了一种服务调度方法及装置， 用于对多数据源的业务请求进行 调度。 [0005]第一方面， 本申请实施例提供了一种服 务调度方法， 包括： [0006]通过多线程采集多个数据源的业务请求； 基于配置参数对获得的多个业务请求进 行校验， 并将校验合格的业 务请求进行封装， 获得多个待处 理业务数据； [0007]基于每个待处理业务数据的类型， 确定相应的业务服务器， 并通过多线程池将所 述多个待处 理业务数据调度至相应的业 务服务器进行处 理。 [0008]本申请实施例基于flink架构的多线程并发采集能力和调度服务器内部多线程 池， 使得同一主题数据源可以实现多个任务并发执行， 并可以按照业务请求类型和调度服 务器的配置对并发数据的处理， 可在线程上最大程度提高叠加效率， 提高对业务的处理效 率。 [0009]可选地， 所述 通过多线程采集多个数据源的业 务请求之后， 还 包括： [0010]将所述多个数据源的业 务请求添加在到异步消息队列中； [0011]所述基于配置参数对获得的多个业务请求进行校验， 并将校验合格的业务请求进 行封装， 获得多个待处 理业务数据之前， 还 包括： [0012]从所述异步消息队列中获取 所述多个业 务请求。 [0013]可选地， 所述多个业 务请求的格式相同， 且每 个业务请求携带一个唯一标识。 [0014]可选地， 将校验不 合格的业 务请求添加到异常数据库。 [0015]可选地， 在监测到服务调度异常时， 生成调度异常信息， 并将调度异常信息保存在 异常数据库。 [0016]可选地， 若所述调度异常信息表征网络异常或服务异常， 则通过异常补偿任务重 新执行服务调度。 [0017]可选地， 对所述异常数据库中的调度异常信息进行分类和统计。 [0018]第二方面， 本申请实施例提供了一种服 务调度装置， 包括： [0019]采集模块， 用于通过多线程采集多个数据源的业务请求； 基于配置参数对获得的 多个业务请求进行 校验， 并将校验合格的业 务请求进行封装， 获得多个待处 理业务数据；说　明　书 1/7 页 3 CN 115469986 A 3