CN113010272B 一种交易并发数控制方法及其相关设备 （中国建设银行股份有限公司）

本申请公开了一种交易并发数控制方法及其相关设备，对于该分布式系统中的第i个服务器来说，获取该第i个服务器的当前资源使用数据，在确定该第i个服务器的当前资源使用数据达到第一熔断条件，且确定该第i个服务器的交照第一比例降低第i个服务器的交易并发数上限；在确定该第i个服务器的当前资源使用数据达到第一恢复条件，且确定该第i个服务器的交按照第一比例增加该第i个服务器的交易并发数2在确定所述第i个服务器的当前资源使用数据达到第一熔断条件务器的交易并发数上限高于单服务器并发数阈值之后，按照第一比例降低所述第i个服务在确定所述第i个服务器的当前资源使用数据达到第一恢复条件务器的交易并发数上限低于单服务器并发数目标值之后，按照第一比例增加所述第i个服在确定所述N个服务器中至少存在第一数量第一目标服务器，且确定所述分布式系统易并发数上限，以使所述降低后的所述分布式系统的交易并发数上限等于更新后的N个服在确定所述N个服务器中至少存在第二数量第二目标服务器，且确定所述分布式系统交易并发数上限，以使所述增加后的所述分布式系统的交易并发数上限等于更新后的N个2.根据权利要求1所述的方法，其特征在于，用率，则所述第一熔断条件为当前CPU使用率高于第一阈值，且所述第一恢复条件为当前若所述当前资源使用数据包括当前内存使用率，则所述第一熔断条件若所述当前资源使用数据包括当前CPU使用率和当前内存使用率，则所述第一熔断条件为当前CPU使用率高于第一阈值或者当前内存使用率高于第三阈值，且所述第一恢复条件为当前CPU使用率低于第二阈值或者当前内存使用率低3.根据权利要求1所述的方法，其特征在于用率，则所述第二熔断条件为当前CPU使用率高于第五阈值，且所述第二恢复条件为当前3若所述当前资源使用数据包括当前内存使用率，则所述第二熔断条件若所述当前资源使用数据包括当前CPU使用率和当前内存使用率，则所述第二熔断条件为当前CPU使用率高于第五阈值或者当前内存使用率高于第七阈值，且所述第二恢复条件为当前CPU使用率低于第六阈值或者当前内存使用率低在确定所述第j个交易码的系统内部成功率低于第一系统成功率阈个交易码的系统并发数上限高于所述第j个交易码的系统并发数阈值之后，按照第三比例在确定所述第j个交易码的系统内部成功率高于第二系统成功率阈个交易码的系统并发数上限低于所述第j个交易码的系统并发数目标值之后，按照第三比jj为正整数；在确定所述第j个交易码的第g个服务器成功率低于第一服务述第j个交易码的第g个服务器并发数上限高于所述第j个交易码的第g个服务器并发数阈在确定所述第j个交易码的第g个服务器成功率高于第二服务述第j个交易码的第g个服务器并发数上限低于所述第j个交易码的第g个服务器并发数目在确定所述第j个交易码的系统内部处理时间高于第一系统处理时间阈值，且确定所在确定所述第j个交易码的系统内部处理时间低于第二系统处理时间阈值，且确定所4jj为正整数；在确定所述第j个交易码的第g个服务器处理时间高于第一服定所述第j个交易码的第g个服务器并发数上限高于所述第j个交易码的第g个服务器并发在确定所述第j个交易码的第g个服务器处理时间低于第二服定所述第j个交易码的第g个服务器并发数上限低于所述第j个交易码的第g个服务器并发8.根据权利要求1所述的方法，其特征在于，若所述分jj为正整数；在确定所述第j个交易码对应的第f个关联交易响应时间超过第一关联交易响应时间在确定所述第j个交易码对应的第f个关联交易响应时间低于第二关联交易响应时间9.根据权利要求1所述的方法，其特征在于，若所述分布jj为正整数；在确定所述Fj个关联交易中至少存在第三数量的第一目标关联交易，且确定所述第hj在确定所述Fj个关联交易中至少存在第四数量的第二目标关联交易，确定所述Fj个关在确定所述第j个交易码对应的第f个关联交易系统成功率低于第一关联交易系统成在确定所述第j个交易码对应的第f个关联交易系统成功率高于第二关联交易系统成5在确定所述Fj个关联交易中至少存在第五数量的第三目标关联交易，且确定所述第hj在确定所述Fj个关联交易中至少存在第六数量的第四目标关联交易，确定所述Fj个关且确定所述第i个服务器的交易并发数上限高于单服务器并发数阈值之后，按照第一比例且确定所述第i个服务器的交易并发数上限低于单服务器并发数目标值之后，按照第一比所述分布式系统的交易并发数上限，并根据降低后的所述分布式系统的交易并发数上限，6所述处理器用于根据所述计算机程序执行权利要求1_11中任一项得所述终端设备执行权利要求1_11中任7[0001]本申请涉及数据处理技术领域，尤其涉及一种交易并发数控制方法及其相关设个服务器的交易并发数上限高于单服务器并发数阈值之后，按照第一比例降低所述第i个个服务器的交易并发数上限低于单服务器并发数目标值之后，按照第一比例增加所述第i[0015]若所述当前资源使用数据包括当前CPU使用率和当前内存使用率，则所述第一熔断条件为当前CPU使用率高于第一阈值或者当前内存使用率高于第三阈值，且所述第一恢复条件为当前CPU使用率低于第二阈值或者当前内存8[0017]在确定所述N个服务器中至少存在第一数量第一目标服务器，且确定所述分布式的交易并发数上限，以使所述降低后的所述分布式系统的交易并发数上限等于更新后的N[0018]在确定所述N个服务器中至少存在第二数量第二目标服务器，且确定所述分布式[0023]若所述当前资源使用数据包括当前CPU使用率和当前内存使用率，则所述第二熔断条件为当前CPU使用率高于第五阈值或者当前内存使用率高于第七阈值，且所述第二恢复条件为当前CPU使用率低于第六阈值或者当前内存[0026]在确定所述第j个交易码的系统内部成功率低于第一系统成功率阈值，且确定所[0027]在确定所述第j个交易码的系统内部成功率高于第二系统成功率阈值，且确定所jj为正整数；定所述第j个交易码的第g个服务器并发数上限高于所述第j个交易码的第g个服务器并发9定所述第j个交易码的第g个服务器并发数上限低于所述第j个交易码的第g个服务器并发[0034]在确定所述第j个交易码的系统内部处理时间高于第一系统处理时间阈值，且确[0035]在确定所述第j个交易码的系统内部处理时间低于第二系统处理时间阈值，且确jj为正整数；[0038]在确定所述第j个交易码的第g个服务器处理时间高于第且确定所述第j个交易码的第g个服务器并发数上限高于所述第j个交易码的第g个服务器[0039]在确定所述第j个交易码的第g个服务器处理时间低于第且确定所述第j个交易码的第g个服务器并发数上限低于所述第j个交易码的第g个服务器[0040]在一种可能的实施方式中，若所述分布式系统处理M个交易且所述分布式系统使j为正整数；[0042]在确定所述第j个交易码对应的第f个关联交易响应时间超过第一关联交易响应[0043]在确定所述第j个交易码对应的第f个关联交易响应时间低于第二关联交易响应[0044]在一种可能的实施方式中，若所述分布式系统处理M个交易且所述分布式系统使j为正整数；[0047]在确定所述Fj个关联交易中至少存在第四数量的第二目标关联交[0048]在一种可能的实施方式中，若所述分布式系统处理M个交易且所述分布式系统使j为正整数；[0050]在确定所述第j个交易码对应的第f个关联交易系统成功率低于第一关联交易系[0051]在确定所述第j个交易码对应的第f个关联交易系统成功率高于第二关联交易系[0052]在一种可能的实施方式中，若所述分布式系统处理M个交易且所述分布式系统使j为正整数；[0055]在确定所述Fj个关联交易中至少存在第六数量的第四目标关联交[0059]第一降低单元，用于在确定所述第i个服务器的当前资源使用数据达到第一熔断[0060]第一增加单元，用于在确定所述第i个服务器的当前资源使用数据达到第一恢复[0063]所述处理器用于根据所述计算机程序执行本申请实施例提供的交易并发数控制运行时，使得所述终端设备执行本申请实施例提供的交易并发数控制方法的任一实施方器的当前资源使用数据达到第一熔断条件，且确定该第i个服务器的交易并发数上限高于[0072]为了便于理解和解释本申请技术方案，下面先对本申请涉及的技术名词进行介前资源使用数据可以包括当前CPU(centralprocessingunit，中央处理器)使用率和/或[0085]另外，本申请实施例也不限定第i个服务器的当前资源使用数据的获取时间，例各个服务器的当前资源使用数据对各个服务器进行相应的交易并发数上务器的交易并发数上限高于单服务器并发数阈值之后，按照第一比例降低第i个服务器的[0088]其中，第一熔断条件是指对单个服务器进行交易并发数降低控制所需达到的条[0089]示例一，若当前资源使用数据包括当前CPU使用率，则第一熔断条件可以为当前条件为当前CPU使用率高于第一阈值或者当前内存务器的当前CPU使用率高于第一阈值，或者第i个服务器的当前内存使用率高于第三阈值，[0095]第i个服务器的交易并发数上限是指该第i个服务器能够同时处理的交易的最大[0096]单服务器并发数阈值是指预先设定的允许一个服务器同时处理的交易的最低个[0098]基于上述S2的相关内容可知，对于分布系统中第i个服务器的当前轮交易并发数务器的交易并发数上限低于单服务器并发数目标值之后，按照第一比例增加第i个服务器[0101]其中，第一恢复条件是指对单个服务器进行交易并发数增加控制所需达到的条条件可以为当前CPU使用率低于第二阈值或者当前内存务器的当前CPU使用率低于第二阈值，或者第i个服务器的当前内存使用率低于第四阈值，[0108]单服务器并发数目标值是指预先设定的允许一个服务器同时处理的交易的最高[0109]基于上述S2的相关内容可知，对于分布系统中第i个服务器的当前轮交易并发数个服务器的交易并发数上限保持不变，以使该第i个服务器的交易并发数上限始终不会超到第一恢复条件，且确定该第i个服务器的交易并发数上限低于单服务器并发数目标值之服务器的当前资源水平，如此能够有效地降低处理速度变慢的服务器对分布式系统的影限，以使降低后的分布式系统的交易并发数上限等于更新后的N个服务器的交易并发数上[0116]第二熔断条件是指对分布式系统进行交易并发数降低控制时单个服务器所需达[0117]示例一，若当前资源使用数据包括当前CPU使用率，则第二熔断条件可以为当前[0119]需要说明的是，本申请实施例不限定第五阈值与上文第[0122]需要说明的是，本申请实施例不限定第七阈值与上文第条件为当前CPU使用率高于第五阈值或者当前内存务器的当前CPU使用率高于第五阈值，或者第q个服务器的当前内存使用率高于第七阈值，[0126]分布式系统的交易并发数上限是指该分布式系统能够同时处理的交易的最大个数；而且分布式系统的交易并发数上限等于该分布式系统中第1个服务器的交易并发数上[0127]第一系统并发数阈值是指预先设定的允许分布式系统同时处理的交易的最低个[0129]基于上述S4的相关内容可知，对于分布式系统的当前轮交易并发数控制过程来的交易并发数上限，以使降低后的分布式系统的交易并发数上限等于更新后的N个服务器上限，以使增加后的分布式系统的交易并发数上限等于更新后的N个服务器的交易并发数[0133]第二恢复条件是指对分布式系统进行交易并发数增加控制时单个服务器所需达条件可以为当前CPU使用率低于第六阈值或者当前内存务器的当前CPU使用率低于第二阈值，或者第q个服务器的当前内存使用率低于第四阈值，[0141]第一系统并发数目标值是指预先设定的允许分布式系统同时处理的交易的最高[0142]基于上述S4的相关内容可知，对于分布式系统的当前轮交易并发数控制过程来交易并发数上限，以使增加后的分布式系统的交易并发数上限等于更新后的N个服务器的[0148]第j个交易码的系统内部成功率是指分布式系统对第j个交易成功处理完成的概分布式系统在第一时间段内的对第j个交易码的处理结果(例如，成功完成或者失败未完个交易码的系统并发数上限高于第j个交易码的系统并发数阈值之后，按照第三比例降低[0153]第j个交易码的系统并发数上限是指分布式系统能够同时处理第j个交易的最大[0154]第j个交易码的系统并发数阈值是指预先设定的允许分布式系统同时处理第j个[0156]基于上述S7的相关内容可知，对于分布式系统中第j个交易的当前轮并发数控制断第j个交易码的系统并发数上限是否高于第j个交易码的系统并发数阈值，若高于第j个个交易码的系统并发数上限低于第j个交易码的系统并发数目标值之后，按照第三比例增系统成功率阈值可以等于上文第一系统成功率阈值，也可以高于上文第一系统成功率阈[0160]第j个交易码的系统并发数目标值是指预先设定的允许分布式系统同时处理第j[0161]基于上述S8的相关内容来说，对于分布式系统中第j个交易的当前轮并发数控制断第j个交易码的系统并发数上限是否低于第j个交易码的系统并发数目标值，若低于第j以使增加后的第j个交易码的交易并发数上限＝增加前的第j个交易码的交易并发数上限个交易且第j个交易由分布式系统中Gj个服务器进行处理，则该交易并发数控制方法除了jj为正整数。[0166]其中，第j个交易码的第g个服务器成功率是指上述Gj个服务器中第g个服务器对交易码的第g个服务器成功率，以便后续能够依据第j个交易码的第g个服务器成功率对该定第j个交易码的第g个服务器并发数上限高于第j个交易码的第g个服务器并发数阈值之jj为正整数。[0170]第j个交易码的第g个服务器并发数上限是指上述Gj个服务器中第g个服务器能够[0171]第j个交易码的第g个服务器并发数阈值是指预先设定的允许上述Gj个服务器中进一步判断第j个交易码的第g个服务器并发数上限是否高于第j个交易码的第g个服务器个交易码的第g个服务器并发数上限，以使降低后的第j个交易码的第g个服务器并发数上一服务器成功率阈值，但确定第j个交易码的第g个服务器并发数上限不高于第j个交易码第j个交易码的第g个服务器并发数上限始终不会低于第j个交易码的第g个服务器并发数定第j个交易码的第g个服务器并发数上限低于第j个交易码的第g个服务器并发数目标值jj为正整数。实施例不限定第二服务器成功率阈值与上文第一服务器成功率阈值之间的大小关系，例[0177]第j个交易码的第g个服务器并发数目标值是指预先设定的允许上述Gj个服务器中第g个服务器同时处理第j个交易的最高个数；而且本申请实施例不限定第j个交易码的进一步判断第j个交易码的第g个服务器并发数上限是否低于第j个交易码的第g个服务器二服务器成功率阈值，但确定第j个交易码的第g个服务器并发数上限不低于第j个交易码该第j个交易码的第g个服务器并发数上限始终不会超过第j个交易码的第g个服务器并发[0180]基于上述S9至S11的相关内容可知，本申请实施例可以依据分布式系统中各个交[0183]第j个交易码的系统内部处理时间是指分布式系统对第j个交易进行处理所需消[0184]另外，本申请实施例也不限定第j个交易码的系统内部处理时间的获取时间，例实施例不限定第二系统处理时间阈值与上文第一系统处理时间阈值之间的大小关系，例个交易且第j个交易由分布式系统中Gj个服务器进行处理，则该交易并发数控制方法除了jj为正整数。[0197]其中，第j个交易码的第g个服务器处理时间是指上述Gj个服务器中第g个服务器[0198]基于上述S15的相关内容可知，可以针对分布式系统中各个交易按照预设时间间个交易码的第g个服务器处理时间，以便后续能够依据第j个交易码的第g个服务器处理时[0199]S16：在确定所述第j个交易码的第g个服务器处理时间高于第一服务器处理时间jj为正整数。第g个服务器处理时间是否高于第一服务器处理时间阈值，若高于第一服务器处理时间阈第一服务器处理时间阈值，但确定第j个交易码的第g个服务器并发数上限不高于第j个交使该第j个交易码的第g个服务器并发数上限始终不会低于第j个交易码的第g个服务器并[0203]S17：在确定所述第j个交易码的第g个服务器处理时间低于第二服务器处理时间务器并发数目标值之后，按照第四比例增加所述第j个交易码的第g个服务器并发数上限。jj为正整数。请实施例不限定第二服务器处理时间阈值与上文第一服务器处理时间阈值之间的大小关第g个服务器处理时间是否低于第二服务器处理时间阈值，若低于第二服务器处理时间阈第二服务器处理时间阈值，但确定第j个交易码的第g个服务器并发数上限不低于第j个交以使该第j个交易码的第g个服务器并发数上限始终不会超过第j个交易码的第g个服务器jj为正整数。[0210]其中，第j个交易码对应的第f个关联交易响应时间是指在分布式系统处理第j个交易时由与该分布式系统具有关联关系的第hj个关联系统向该分布式系统响应第f个关联个交易时触发的关联交易请求进行处理，以后在该分布式系统处理第j个交易时能够使用[0212]基于上述S18的相关内容可知，可以针对分布式系统中各个交易按照预设时间间个交易码对应的第f个关联交易响应时间，以便后续能够依据第j个交易码对应的第f个关联交易响应时间对该第j个交易进行相应的并发[0213]S19：在确定第j个交易码对应的第f个关联交易响应时间超过第一关联交易响应时间阈值，且确定第j个交易码的系统并发数上限高于第j个交易码的系统并发数阈值之j为正整数。易码对应的第f个关联交易响应时间是否超过第一关联交易响应时间阈值，若超过第一关[0217]S20：在确定第j个交易码对应的第f个关联交易响应时间低于第二关联交易响应j为正整数。申请实施例不限定第二关联交易响应时间阈值与上文第一关联交易响应时间阈值之间的易码对应的第f个关联交易响应时间是否低于第二关联交易响应时间阈值，若低于第二关码的系统并发数上限始终不会超过第j个交易码的系统jj为正整数。jj为正整[0228]第hj个关联系统的交易并发数上限是指第hj个关联系统能够同j个关联系统的交易并发数上限等于该第hj个关联系统中所有服务器的交[0229]第二系统并发数阈值是指预先设定的允许第hj个关联系统同时处理的交易的最[0231]基于上述S22的相关内容可知，对于第hj个关联系统的当前轮交易并发数控制过判断第j个交易码对应的上述Fj个关联交易中第y个关联交易的响应时间是否超过第一关例降低第hj个关联系统的交易并发数上限，以使降低后的第hj个关联系统的交易并发数上后的第hj个关联系统的交易并发数上限，更新第hj个关联系统中各个服务器的交易并发数上限，以使降低后的第hj个关联系统的交易并发数上限等于更新后的第hj个关联系统中所将第hj个关联系统的交易并发数上限保持不变，以使该第hj个关联系统的交易并发数上限限低于第二系统并发数目标值之后，按照第五比例增加第hj个关联系统的交易并发数上jj为正整数。[0236]第二系统并发数目标值是指预先设定的允许第hj个关联系统同时处理的交易的[0237]基于上述S23的相关内容可知，对于第hj个关联系统的当前轮交易并发数控制过程来说，在获取到该第hj个关联系统向分布式系统响应的各个关联交易的响应时间之后，先判断第j个交易码对应的上述Fj个关联交易中第y个关联交易响应时间是否超过第一关易中第y个关联交易响应时间是否低于第二关联交易响应时间阈值，若低于第二关联交易j第hj个关联系统的交易并发数上限，以使增加后的第hj个关联系统的交易并发数上限＝增使增加后的第hj个关联系统的交易并发数上限等于更新后的第hj个关联系统中所有服务器第hj个关联系统的交易并发数上限不低于第二系统并发数目标值，则将第hj个关联系统的该分布式系统的各个关联系统能够承接的关联交易的个数更符合该分布式系统的各个关j为正整数。[0242]其中，第j个交易码对应的第f个关联交易系统成功率是指在分布式系统处理第j个交易时由与该分布式系统具有关联关系的第hj个关联系统对第f个关联交易成功处理完j个关联系统在第一时间段内的对第f个关联交易的处理结果，[0243]基于上述S24的相关内容可知，可以针对分布式系统中各个交易按照预设时间间个交易码对应的第f个关联交易系统成功率，以便后续能够依据第j个交易码对应的第f个关联交易系统成功率对该第j个交易进行相应的并发[0244]S25：在确定第j个交易码对应的第f个关联交易系统成功率低于第一关联交易系jj为正整数。交易码对应的第f个关联交易系统成功率是否低于第一关联交易系统成功率阈值，若低于第一关联交易系统成功率阈值，则可以进一步判断第j个交易码的系统并发数上限是否高=降低前的第j个交易码的交易并发数上限×(1_第三比例)。易码的系统并发数上限始终不会低于第j个交易码的系统[0248]S26：在确定第j个交易码对应的第f个关联交易系统成功率高于第二关联交易系jj为正整数。本申请实施例不限定第二关联交易系统成功率阈值与上文第一关联交易系统成功率阈值交易码对应的第f个关联交易系统成功率是否高于第二关联交易系统成功率阈值，若高于第二关联交易系统成功率阈值，则可以进一步判断第j个交易码的系统并发数上限是否低交易码的系统并发数上限始终不会超过第j个交易码的系统并j为正整数。jj为正整[0259]基于上述S28的相关内容可知，对于第hj个关联系统的当前轮交易并发数控制过程来说，在获取到该第hj个关联系统向分布式系统响应各个关联交易的系统成功率之后，先判断第j个交易码对应的上述Fj个关联交易中第y个关联交易的系统成功率是否低于第按照第五比例降低第hj个关联系统的交易并发数上限，以使降低后的第hj个关联系统的交够依据降低后的第hj个关联系统的交易并发数上限，更新第hj个关联系统中各个服务器的交易并发数上限，以使降低后的第hj个关联系统的交易并发数上限等于更新后的第hj个关将第hj个关联系统的交易并发数上限保持不变，以使该第hj个关联系统的交易并发数上限限低于第二系统并发数目标值之后，按照第五比例增加第hj个关联系统的交易并发数上jj为正整数。[0264]基于上述S29的相关内容可知，对于第hj个关联系统的当前轮交易并发数控制过程来说，在获取到该第hj个关联系统向分布式系统响应的各个关联交易的系统成功率之Fj个关联交易中第y个关联交易系统成功率是否高于第二关联交易系统成功率阈值，若高于第二关联交易系统成功率阈值，则将上述Fj个关联交易中第y个关联交易确定为第四目j按照第五比例增加第hj个关联系统的交易并发数上限，以使增加后的第hj个关联系统的交够依据增加后的第hj个关联系统的交易并发数上限，更新第hj个关联系统中各个服务器的交易并发数上限，以使增加后的第hj个关联系统的交易并发数上限等于更新后的第hj个关第hj个关联系统的交易并发数上限不低于第二系统并发数目标值，则将第hj个关联系统的使该分布式系统的各个关联系统能够承接的关联交易的个数更符合该分布式系统的各个[0281]若所述当前资源使用数据包括当前CPU使用率和当前内存使用率，则所述第一熔断条件为当前CPU使用率高于第一阈值或者当前内存使用率高于第三阈值，且所述第一恢复条件为当前CPU使用率低于第二阈值或者当前内存低所述分布式系统的交易并发数上限，并根据降低后的所述分布式系统的交易并发数上[