(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210952934.X (22)申请日 2022.08.10 (65)同一申请的已公布的文献号 申请公布号 CN 115016952 A (43)申请公布日 2022.09.06 (73)专利权人 中邮消费金融有限公司 地址 510000 广东省广州市南沙区海 滨路 171号南沙金融大厦1 1楼1101之一J3 0 (72)发明人 张庆荣　陈俊杰　谢陆豪　朱威　 (74)专利代理 机构 广州微斗专利代理有限公司 44390 专利代理师 朱武 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/54(2006.01)G06F 11/30(2006.01) G06F 11/34(2006.01) (56)对比文件 CN 112199150 A,2021.01.08 CN 111309409 A,2020.0 6.19 CN 113487307 A,2021.10.08 CN 112398945 A,2021.02.23 CN 111435320 A,2020.07.21 审查员 马丹凤 (54)发明名称 一种基于服务调用端的动态扩缩容方法及 系统 (57)摘要 本发明涉及一种基于服务调用端的动态扩 缩容方法， 包括如下步骤： S1： 进行监控规则参数 的配置并保存至 数据库中； S2： 通过Redi s统计采 集交易结果， 采用监控线程对交易结果进行异步 分析， 并将分析结果与监控规则参数进行比对； S3： 调用端根据比对结果进行扩容或缩容处理。 本发明提供的基于服务调用端的动态扩缩容方 法， 通过监控线程分析各项采集指标， 根据分析 结果与系统设置的预设监控规则参数比对， 当符 合条件时调用端自动进行扩容 或缩容处理， 不需 要额外的人工干预。 系统的各项预设监控规则参 数统一管理， 修改监控规则参数后实时生效， 保 证请求能够正常及时处理， 同时又能充分利用服 务端的系统资源。 权利要求书2页 说明书6页 附图2页 CN 115016952 B 2022.10.28 CN 115016952 B 1.一种基于服 务调用端的动态扩 缩容方法， 其特 征在于， 包括如下步骤： S1： 进行监控规则参数的配置； 其中， 所述监控规则参数包括： 业务类型、 统计时间、 最小统计数、 失败率、 异常率、 消息 堆积数和响应时间； S2： 通过Redis统计采集交易结果， 采用监控线程对Redis采集的交易结果进行异步分 析， 通过Kafka消息队列 异步处理被JAVA线程池 所拒绝的交易请求， 并将分析结果与监控规 则参数进行比对； 其中， 通过 Kafka消息队列异步处 理被JAVA线程池所拒绝的交易请求具体包括： 对进入JAVA线程池中的交易请求进行判定， 当JAVA线程池中的核心线程已满时， 则 JAVA线程池执 行拒绝策略， 若未满， 则JA VA线程池新建核心线程进行交易请求的执 行； 当JAVA线程池中的线程池队列已满时， 则JAVA线程池执行拒绝策略， 若未满， 则JAVA线 程池将该交易请求 放入线程池队列中进行 执行； 当JAVA线程池中的最大线程已满时， 则JAVA线程池执行拒绝策略， 若未满， 则JAVA线程 池新建非核心线程 来对交易请求进行 执行； 将核心线程、 线程池队列以及最大线程所拒绝的交易请求放入Kafka消息队列中， 并通 过Kafka消息列队进行异步处 理； S3： 调用端根据交易结果和监控规则参数的比对结果， 调节JAVA线程池 的参数来控制 调用端发往服 务端的请求并发量 来进行扩容或缩容处 理； 其中， 当采集的交易结果的数值大于监控规则参数的第一预设值时， 减少JAVA线程池 中的参数 数值以及调用端发往服 务端的请求并发量 来进行缩容处 理； 当采集的交易结果的数值小于监控规则参数的第一预设值时， 增加JAVA线程池中的参 数数值以及调用端发往服 务端的请求并发量 来进行扩容处 理。 2.一种基于服 务调用端的动态扩 缩容方法系统， 其特 征在于， 包括： 监控管理模块： 包括 参数配置模块和数据管理模块； 参数配置模块： 对监控规则参数进行配置并保存在数据库中； 其中监控规则参数包括： 业务类型、 统计时间、 最小统计数、 失败率、 异常率、 消息堆积 数和响应时间； 数据管理模块： 统计采集交易结果并对 采集交易结果进行读取； 监控执行模块： 对交易结果进行异步分析， 并将分析后的结果与配置的监控规则参数 进行比对； 调用模块： 根据分析后的结果与配置的监控规则参数比对的结果进行扩容或缩容处 理； 其中， 当采集的交易结果的数值大于监控规则参数的第一预设值时， 减少JAVA线程池 中的参数 数值以及调用端发往服 务端的请求并发量 来进行缩容处 理； 当采集的交易结果的数值小于监控规则参数的第一预设值时， 增加JAVA线程池中的参 数数值以及调用端发往服 务端的请求并发量 来进行扩容处 理； 分析模块： 对Redis采集的交易结果进行分析并将分析结果进行汇总， 根据汇总结果与 所配置的监控规则参数进行 数据比对； 处理模块： 通过Kafk a消息队列异步处理被JAVA线程池所拒绝的交易请求， 对进入JAVA权　利　要　求　书 1/2 页 2 CN 115016952 B 2线程池中的交易请求进行判定， 当JAVA线程池中的核心线程已满 时， 则JAVA线程池执行拒 绝策略， 若未满， 则JA VA线程池新建核心线程进行交易请求的执 行； 当JAVA线程池中的线程池队列已满时， 则JAVA线程池执行拒绝策略， 若未满， 则JAVA线 程池将该交易请求 放入线程池队列中进行 执行； 当JAVA线程池中的最大线程已满时， 则JAVA线程池执行拒绝策略， 若未满， 则JAVA线程 池新建非核心线程 来对交易请求进行 执行； 将核心线程、 线程池队列以及最大线程所拒绝的交易请求放  入Kafka消息队列中， 并 通过Kafka消息列队进行异步处 理。权　利　要　求　书 2/2 页 3 CN 115016952 B 3