应用于分布式服务器系统的服务器熔断方法、装置、设备、介质和产品与流程

1.本公开涉及大数据技术领域，更具体地涉及一种应用于分布式服务器系统的服务器熔断方法、装置、设备、介质和产品。


背景技术：

2.在“传统运营模式向数字化运营转型”的大背景下，各金融科技企业均在推进“企业级互联网智慧运营平台”建设，构建以用户为中心的，覆盖渠道运营、产品运营、用户运营、内容运营四大运营能力的运营平台。具体地，可以通过用户运营对业务客户进行地区划分、建群或打标处理，然后利用渠道运营为相关类别的客户建立权益活动，使得客户在登陆相关渠道应用(如手机银行第)时，需对当前全量活动列表(包括活动发布范围第)根据当前客户类表(如地区、客群、标签等)进行匹配，并按照产品运营和内容运营的设定规则展现匹配之后的互动列表。其中，在上述应用场景中，若基于现有分布式技术进行第三方系统对接时，通常会因第三方系统与所对接金融科技企业服务系统的系统能力存在差距，导致双方配置的熔断策略无法有效匹配实际信息处理场景，造成系统信息交易缓慢、超时甚至引发雪崩。


技术实现要素：

3.鉴于上述问题至少之一，本公开提供了提高熔断策略自由度的应用于分布式服务器系统的服务器熔断方法、装置、设备、介质和程序产品。
4.根据本公开的第一个方面，提供了一种应用于分布式服务器系统的服务器熔断方法，包括：确定当前的交易执行信息；根据初始熔断窗口获取对应交易执行信息的熔断执行信息；以及基于熔断执行信息更新初始熔断窗口，以用于执行在后的服务器熔断操作。
5.根据本公开的实施例，在确定当前的交易执行信息中，包括：基于设定查询周期，检测当前的交易执行率；根据设定执行阈值，通过交易执行率确定交易执行信息；其中交易执行率包括交易成功率或交易异常率。
6.根据本公开的实施例，在根据初始熔断窗口获取对应交易执行信息的熔断执行信息中，包括：当交易成功率低于第一设定阈值或者交易异常率高于第二设定阈值时，根据初始熔断窗口执行服务器熔断操作；获取服务器熔断操作的累计熔断次数，用于构成熔断执行信息。
7.根据本公开的实施例，在基于熔断执行信息更新初始熔断窗口中，还包括：当累计熔断次数大于第三设定阈值时，更新初始熔断窗口。
8.根据本公开的实施例，在更新初始熔断窗口中，还包括：根据初始熔断窗口和交易成功率之间的比值，确定第一实际熔断窗口；根据第一实际熔断窗口更新初始熔断窗口。
9.根据本公开的实施例，在更新初始熔断窗口中，还包括：根据交易异常率和初始熔断窗口之间的乘积与初始熔断窗口之间的和，确定第二实际熔断窗口；根据第二实际熔断
窗口更新初始熔断窗口。
10.根据本公开的实施例，方法还包括：获取检测当前的交易执行率的累计检测次数；当累计检测次数大于第四设定阈值时，更新初始熔断窗口。
11.根据本公开的实施例，在更新初始熔断窗口中，包括：根据交易成功率和初始熔断窗口之间的乘积，确定第三实际熔断窗口；根据第三实际熔断窗口更新初始熔断窗口。
12.根据本公开的实施例，在更新初始熔断窗口中，包括：根据初始熔断窗口与交易异常率和初始熔断窗口之间的乘积之间的差，确定第四实际熔断窗口；根据第四实际熔断窗口更新初始熔断窗口。
13.本公开的第二方面提供了一种应用于分布式服务器系统的服务器熔断装置，包括信息确定模块、信息获取模块和窗口更新模块。信息确定模块用于确定当前的交易执行信息；信息获取模块根据初始熔断窗口获取对应交易执行信息的熔断执行信息；以及窗口更新模块用于基于熔断执行信息更新初始熔断窗口，以用于执行在后的服务器熔断操作。
14.本公开的第三方面提供了一种电子设备，包括：一个或多个处理器；存储器，用于存储一个或多个程序，其中，当所述一个或多个程序被所述一个或多个处理器执行时，使得一个或多个处理器执行上述应用于分布式服务器系统的服务器熔断方法。
15.本公开的第四方面还提供了一种计算机可读存储介质，其上存储有可执行指令，该指令被处理器执行时使处理器执行上述应用于分布式服务器系统的服务器熔断方法。
16.本公开的第五方面还提供了一种计算机程序产品，包括计算机程序，该计算机程序被处理器执行时实现上述应用于分布式服务器系统的服务器熔断方法。
附图说明
17.通过以下参照附图对本公开实施例的描述，本公开的上述内容以及其他目的、特征和优点将更为清楚，在附图中：
18.图1示意性示出了现有分布式服务器系统的应用场景组成图；
19.图2示意性示出了根据本公开实施例的应用于分布式服务器系统的服务器熔断方法、装置、设备、介质和程序产品的应用场景图；
20.图3示意性示出了根据本公开实施例的应用于分布式服务器系统的服务器熔断方法的流程图；
21.图4a示意性示出了根据本公开实施例的应用于分布式服务器系统和第三方服务系统之间的一抢券场景图；
22.图4b示意性示出了根据本公开实施例的应用于分布式服务器系统的服务器熔断方法的一具体场景流程图；
23.图5示意性示出了根据本公开实施例的应用于分布式服务器系统的服务器熔断装置的结构框图；以及
24.图6示意性示出了根据本公开实施例的适于实现应用于分布式服务器系统的服务器熔断方法的电子设备的方框图。
具体实施方式
25.以下，将参照附图来描述本公开的实施例。但是应该理解，这些描述只是示例性
的，而并非要限制本公开的范围。在下面的详细描述中，为便于解释，阐述了许多具体的细节以提供对本公开实施例的全面理解。然而，明显地，一个或多个实施例在没有这些具体细节的情况下也可以被实施。此外，在以下说明中，省略了对公知结构和技术的描述，以避免不必要地混淆本公开的概念。
26.在此使用的术语仅仅是为了描述具体实施例，而并非意在限制本公开。在此使用的术语“包括”、“包含”等表明了所述特征、步骤、操作和/或部件的存在，但是并不排除存在或添加一个或多个其他特征、步骤、操作或部件。
27.在此使用的所有术语(包括技术和科学术语)具有本领域技术人员通常所理解的含义，除非另外定义。应注意，这里使用的术语应解释为具有与本说明书的上下文相一致的含义，而不应以理想化或过于刻板的方式来解释。
28.在使用类似于“a、b和c等中至少一个”这样的表述的情况下，一般来说应该按照本领域技术人员通常理解该表述的含义来予以解释(例如，“具有a、b和c中至少一个的系统”应包括但不限于单独具有a、单独具有b、单独具有c、具有a和b、具有a和c、具有b和c、和/或具有a、b、c的系统等)。
29.随着分布式技术的运用，解决了常规单点应用服务器及数据库的性能容量难以扩展的问题，分布式架构属于一种稳定可靠、容量和服务能力可弹性伸缩，具有自动化水平拆分，透明读写分离、在线平滑扩容服务能力可扩展等能力，为业务量长期具备增长或波动情况的业务系统，提供了较为有利的技术支撑。
30.在现有分布式应用场景中，可通过支持将不同用户的请求通过一致性hash路由流转到指定的set处理，从而实现系统并发吞吐能力的灵活扩容。如图1所示，服务接入层通过hash路由流转到指定的服务层set1-setn，可以实现对服务层set1-setn各自分别对应的数据库set1-setn进行数据访问，同时服务层set1-setn还可以进一步通过网络设备与第三方系统实现对接。对于系统内部的交易处理(包括交易日志、交易明细等流程数据以及用户相关的协议数据等)均可以较好的适配该规则，但是在对接第三方进行相关权益领取环节，可能会成为新的瓶颈，即使是将第三方系统对接处理进行异步化处理之后，还是会因为第三方对接的网络设备、第三方系统自身能力限制等原因导致交易缓慢、超时，甚至引发雪崩效应，如图1所示。
31.其中，在与第三方系统对接时，可以基于增加的熔断策略，在指定周期内(如2s)，如果出现指定次数(如3次)的超时异常(连接超时/读取超时)，则可以指定熔断时间窗口(如2s)，通过该熔断时间窗口给第三方系统以恢复时间，从而尽可能保证后续交易能正常完成。其中，当网络带宽一定的情况，第三方系统交易处理能力存在一定的不确定性，但是现有熔断策略是基于固定的网络和第三方系统能力确定的，从而在实际生产运行时，网络带宽和第三方系统能力实际情况与假设情况可能存在出入，就会导致熔断时间过长(容易造成服务时间中断过长)或者熔断时间过短(直接导致在熔断时间窗口过后第三方系统仍未能恢复提供正常服务的能力)，而且相关熔断策略一旦设置，几乎都不能灵活自动调整。例如，金融科技企业的应用服务系统(如手机银行app等金融服务应用的分布式服务系统)与第三方应用服务系统(如即时聊天app等企业服务系统)对接进行交易互联向客户提供任务执行交易服务(如消费券领取活动)的场景下，当服务系统被大量用户集中短时访问时，就极易出现上述问题。鉴于上述问题至少之一，本公开提供了提高熔断策略自由度的应用
于分布式服务器系统的服务器熔断方法、装置、设备、介质和程序产品。
32.需要说明的是，本公开实施例的应用于分布式服务器系统的服务器熔断方法和装置可以应用于大数据技术领域和信息安全技术领域，也可以应用于除大数据技术领域和信息安全技术领域之外的任意领域，如金融服务领域，本公开实施例的应用于分布式服务器系统的服务器熔断方法和装置的应用领域不作具体限定。
33.此外，在本公开的技术方案中，所涉及的用户个人信息的收集、存储、使用、加工、传输、提供、公开和应用等处理，均符合相关法律法规的规定，采取了必要保密措施，且不违背公序良俗。在本公开的技术方案中，在获取或采集用户个人信息之前，均获取了用户的授权或同意。
34.本公开的实施例提供了一种应用于分布式服务器系统的服务器熔断方法，包括：确定当前的交易执行信息；根据初始熔断窗口获取对应交易执行信息的熔断执行信息；以及基于熔断执行信息更新初始熔断窗口，以用于执行在后的服务器熔断操作。
35.图2示意性示出了根据本公开实施例的应用于分布式服务器系统的服务器熔断方法、装置、设备、介质和程序产品的应用场景图。
36.如图2所示，根据该实施例的应用场景200可以包括终端设备201、202、203、网络204和服务器205。网络204用以在终端设备201、202、203和服务器205之间提供通信链路的介质。网络204可以包括各种连接类型，例如有线、无线通信链路或者光纤电缆等等。
37.用户可以使用终端设备201、202、203通过网络204与服务器205交互，以接收或发送消息等。终端设备201、202、203上可以安装有各种通讯客户端应用，例如购物类应用、网页浏览器应用、搜索类应用、即时通信工具、邮箱客户端、社交平台软件等(仅为示例)。
38.终端设备201、202、203可以是具有显示屏并且支持网页浏览的各种电子设备，包括但不限于智能手机、平板电脑、膝上型便携计算机和台式计算机等等。
39.服务器205可以是提供各种服务的服务器，例如对用户利用终端设备201、202、203所浏览的网站提供支持的后台管理服务器(仅为示例)。后台管理服务器可以对接收到的用户请求等数据进行分析等处理，并将处理结果(例如根据用户请求获取或生成的网页、信息、或数据等)反馈给终端设备。
40.需要说明的是，本公开实施例所提供的应用于分布式服务器系统的服务器熔断方法一般可以由服务器205执行。相应地，本公开实施例所提供的应用于分布式服务器系统的服务器熔断装置一般可以设置于服务器205中。本公开实施例所提供的应用于分布式服务器系统的服务器熔断方法也可以由不同于服务器205且能够与终端设备201、202、203和/或服务器205通信的服务器或服务器集群执行。相应地，本公开实施例所提供的应用于分布式服务器系统的服务器熔断装置也可以设置于不同于服务器205且能够与终端设备201、202、203和/或服务器205通信的服务器或服务器集群中。
41.应该理解，图2中的终端设备、网络和服务器的数目仅仅是示意性的。根据实现需要，可以具有任意数目的终端设备、网络和服务器。
42.以下将基于图2描述的场景，通过图3～图4b对公开实施例的应用于分布式服务器系统的服务器熔断方法进行详细描述。
43.图3示意性示出了根据本公开实施例的应用于分布式服务器系统的服务器熔断方法的流程图。
44.如图3所示，该实施例的应用于分布式服务器系统的服务器熔断方法包括操作s301～操作s303。
45.在操作s301，确定当前的交易执行信息；
46.在操作s302，根据初始熔断窗口获取对应交易执行信息的熔断执行信息；
47.在操作s303，基于熔断执行信息更新初始熔断窗口，以用于执行在后的服务器熔断操作。
48.如图4a所示，在本公开一实施例的应用场景中，不同的多个用户移动设备1-n可以在同一时间段(如5s)内通过移动设备银行app向该银行的分布式服务器系统发送抢券请求1-n，分布式服务器系统将根据发送抢券请求1-n生成券码交易业务1-n并发送给第三方服务系统。其中，券码交易业务1-n可以通过任务队列的形式进行排队以待第三方服务系统进行处理。
49.但是，该第三方服务系统由于自身交易处理能力有限、交易能力被占用、交易能力超限等原因至少之一造成券码交易业务执行出现超时、缓慢等导致的异常情况，则需要对该任务队列中的券码交易业务的执行过程进行熔断操作，或者对分布式服务器系统执行熔断操作，使得其暂停向任务队列继续发送券码交易业务，即使得其能够在一段时间之内暂停执行，以确保第三方服务系统在该熔断窗口定义的时间段内仅对任务队列中的券码交易业务执行处理，从而有效避免第三方服务系统出现雪崩的情况。
50.其中，第三方服务系统在执行对应的券码交易业务之后，可以响应于用户移动设备1-n上通过各自即时聊天工具app(也可以是其他工具app，如外卖app等)发送的查券请求，向用户移动设备1-n发送对应的券码查询结果1-n，使得用户可以基于聊天工具app查询抢券结果。
51.其中，在本公开的实施例中，在获取用户的信息之前，可以获得用户的同意或授权。例如，在上述不同的多个用户移动设备1-n可以在同一时间段(如5s)内通过移动设备银行app向该银行的分布式服务器系统发送抢券请求1-n之前，可以向用户发出获取用户信息的请求。在用户同意或授权可以获取用户信息的情况下执行该操作。
52.交易执行信息为分布式服务器系统与第三方应用服务系统之间的执行交易业务所产生的执行状态信息，例如图4a所示券码交易业务1-n被第三方服务系统的执行过程所产生的状态信息，如对应券码交易业务1-n中至少一某券码交易业务的执行成功、执行异常、执行失败、执行成功率以及执行失败率等与执行相关的具体状态内容。
53.初始熔断窗口是初始执行熔断操作时所依据的熔断时长，例如该初始熔断窗口为5s时，如图4a所示，则可以将分布式服务器系统向任务队列发送交易任务的处理进程执行熔断操作，熔断时长5s，相当于暂停发送券码交易业务至第三方服务系统，暂停时间5s，以等待第三方服务系统将已接收到的券码交易业务执行完毕，防止交易任务大规模挤兑，避免服务器崩溃等。
54.根据初始熔断窗口可以实现对应时长的熔断操作，从而根据该熔断操作获取熔断执行信息，该熔断执行信息可以为针对交易执行进程的熔断操作的执行状态内容，例如可以是一特定时间内的熔断操作执行次数、每次熔断操作的熔断时长、每次熔断操作的执行位置(如图4a所示分布式服务器系统or任务队列等)等。
55.通常，每次熔断操作的执行，都是固定熔断窗口，即每次熔断操作都是基于固定的
时间段执行。因此，在遇到大规模短时集中交易访问时，更容易出交易缓慢、超时甚至雪崩效应；此外，若熔断窗口过大，熔断时间过长，在正常交易执行状态下，则会使得交易访问体系出现交易执行效率长期无法有效提升的情况。因此，通过对初始熔断窗口执行更新，可以对熔断窗口进行实时的调整，例如可以根据实际的当前交易执行状态将熔断窗口调整的更长或者更短。换言之，对初始熔断窗口的更新操作可以理解为将初始熔断窗口替换为新的熔断窗口以作为下一次或者后续几次熔断操作的熔断执行时间。
56.因此，基于上述本公开实施例的应用于分布式服务器系统的服务器熔断方法，能够基于现有熔断策略进行动态判定，如果熔断触发指定周期(如n次)之后，相关交易执行(例如服务调用、交易任务发送和处理等)成功率仍然较低，或者仍然出现在指定时间窗口(例如初始熔断窗口)中出现固定次数的超时异常，则自动将熔断窗口适当延长(根据周期内交易的成功率进行熔断，后续熔断窗口重新计算)，直至系统成功率稳定在预期正常水平，或异常次数低于相关阈值。相反，该初始熔断窗口还可以进行适当缩短，具体不作赘述。
57.可见，基于上述本公开实施例的应用于分布式服务器系统的服务器熔断方法，在分布式应用架构下，可以有效解决网络或第三方系统能力的不确定性，避免包括分布式服务器系统和第三方服务系统在内的服务并发处理能力过高，导致包括第三方系统等服务雪崩的问题。因此，本公开实施例的上述服务器熔断方法实际上是提供了一种全新的可动态调整的智能熔断策略方案，能够根据第三方服务系统的实际运营能力实时调整熔断窗口，以实现根据网络及第三方系统当前实际能力设置合理的熔断窗口，从而达到最高有效交易率。
58.如图3-图4b所示，根据本公开的实施例，在操作s301确定当前的交易执行信息中，包括：
59.基于设定查询周期，检测当前的交易执行率；
60.根据设定执行阈值，通过交易执行率确定交易执行信息；
61.其中交易执行率包括交易成功率或交易异常率。
62.设定查询周期为一预先设定的固定时间段，以用于使得查询检测程序可以根据该固定时间段对交易执行的状态进行反复查询，即每隔一次该设定查询周期即执行一次交易执行查询，从而达到周期性检测当前交易执行情况的目的，如图4b所示操作s401中周期性检测交易成功率。
63.交易执行率可以包括交易任务执行的成功率和/或交易异常率，如图3所示，在任务队列中发送券码交易业务1-n至第三服务系统的进程中，若在设定查询周期(如10s)之内共有n个发送执行成功，则其发送券码交易业务的成功率为n/n，反之其交易异常率为(n-n)/n，在此不作赘述。
64.对于特定的交易业务的执行，一般交易执行的成功率可以位于一范围内，如成功率需要大于80％，一旦成功率低于该阈值，则说明交易执行的成功率偏低，其交易执行信息中则可以包括该交易执行率的交易成功率。相反，交易执行的异常率也可以位于一特定范围内，如异常率需要小于30％，一旦异常率高于该阈值，则说明交易执行的异常率过高，其交易执行信息中则可以包括该交易执行率的交易异常率。因此，设定执行阈值可以是交易执行成功率的对应低阈值，或者交易执行异常率的对应高阈值，以借此对当前交易执行率作为评价参考，从而确定更为真实准确的交易执行信息。其中，交易执行信息还可以进一步
包括交易执行的交易任务内容、交易位置、交易时间等具体执行内容。
65.因此，通过交易执行率可以使得交易执行信息更加适用后续的熔断窗口更新，从而避免过于频繁地熔断更新操作，从而保证了更加准确的熔断操作，更加匹配于熔断更新的适用场景。
66.如图3-图4b所示，根据本公开的实施例，在操作s302根据初始熔断窗口获取对应交易执行信息的熔断执行信息中，包括：
67.当交易成功率低于第一设定阈值或者交易异常率高于第二设定阈值时，根据初始熔断窗口执行服务器熔断操作；
68.获取服务器熔断操作的累计熔断次数，用于构成熔断执行信息。
69.如图4b所示，在操作s402-s403中，当交易执行信息的交易成功率低于第一设定阈值，或者其交易异常率高于第二设定阈值时，可以基于初始熔断窗口执行当前分布式服务器系统的熔断操作，在该熔断窗口指定的时间段内暂停向任务队列发送交易任务，避免第三服务器系统的崩溃。
70.在上述执行初始熔断窗口的熔断操作的同时，可以同时记录该熔断操作的熔断次数为1次。进一步地，如图4b所示，在操作s404中，进一步判断该熔断次数与熔断次数阈值之间关系，若该熔断次数小于设定熔断次数阈值，则直接返回到操作s401继续检测交易成功率，重复执行操作s401-s404，并再次记录熔断次数，形成累计熔断次数。
71.该累计熔断次数可以作为熔断执行信息的一部分内容，用于指示在某一时间段内根据初始熔断窗口反复执行熔断操作的次数。其中，熔断执行信息还可以包括对应每次熔断操作执行的熔断窗口、熔断时长、熔断时刻、熔断结束时刻、熔断位置等操作内容。
72.因此，可以更加准确地获取当前的熔断操作的执行情况，从而能够对后续的熔断窗口的更新操作提供更为精准的更新依据。
73.如图3-图4b所示，根据本公开的实施例，在操作s303基于熔断执行信息更新初始熔断窗口中，还包括：
74.当累计熔断次数大于第三设定阈值时，更新初始熔断窗口。
75.如图4b所示，在操作s404-s405中，如果反复执行操作s401-s402-s403-s404-s401之后，当其累计熔断次数大于一设定的熔断次数相关的第三设定阈值，则意味着熔断操作的次数过多，熔断操作过于频繁，则说明当前交易任务的执行压力较大，可以对熔断窗口执行更新，例如对熔断窗口适当增加指定时长，然后在后续重复执行熔断操作时以更新之后的熔断窗口取代初始熔断窗口。同时，可以将累计熔断次数直接清零，回到操作s401，再次循环操作。
76.因此，可以根据实际的熔断操作情况实时且适时地对熔断窗口执行更新，从而能够保证在后续的熔断操作过程中，保证交易任务的有序进行，能够有效避免第三方服务系统的雪崩，极大提高了交易任务的执行效率。
77.如图3-图4b所示，根据本公开的一实施例，在操作s405更新初始熔断窗口中，还包括：
78.根据初始熔断窗口和交易成功率之间的比值，确定第一实际熔断窗口；
79.根据第一实际熔断窗口更新初始熔断窗口。
80.如图4b所示，在操作s405中，在更新熔断窗口的过程中，可以基于当前交易任务的
执行情况(如交易成功率)对初始熔断窗口进行调整，比如适当的增加熔断窗口所指定的熔断时长。
81.在本公开一实施例中，可以利用初始熔断窗口和交易成功率之间的比值，确定第一实际熔断窗口，即满足更新熔断窗口t
new
＝初始熔断窗口t
initial
/交易成功率f1。如此，由于成功率f1一般都会低于1，使得t
new
＞t
initial
，也即，适当的对熔断窗口进行了增加。其中，交易成功率f1为当前时刻下最近一次熔断操作对应的交易任务执行的成功率。例如，下述表1所示：
[0082][0083]
表1
[0084]
其中，系统a1-a3为第三方服务系统，例如某付宝服务系统a1、某银行服务系统a2、某信即时聊天app服务系统a3。其中，多个第三方服务系统均同时可以与本公开实施例的分布式服务系统对接，并实现类似于如图4a所示的交易任务执行操作及如图4b所示的熔断操作。熔断组号为熔断执行的周期数，可以理解为当前的熔断次数。交易成功率为最近一次的交易任务执行的成功率。
[0085]
具体地，如表1所示，对于第三方服务系统a3，如果当前次交易成功率在29％-31％之间，则直接依照t
new
＝t
initial
/f1将初始熔断窗口从2s更新为更新熔断窗口为6.67s，即第一实际熔断窗口；同样对于第三方服务系统a3，如果进一步的交易执行的交易成功率在80％左右，则直接依照t
new
＝t
initial
/f1将初始熔断窗口从6.67s更新为更新熔断窗口为8.83s。也即，本公开实施例的上述服务器熔断方法可以实现连续性的熔断更新过程。
[0086]
需要进一步说明的是，针对同一个第三方服务系统，熔断窗口调整为t
new
之后，可以对熔断窗口更新操作进行登记，登记为1表示扩展一个周期立即恢复，登记为2则表示扩展2个周期恢复，以此类推。
[0087]
因此，在后续系统出现需要熔断场景时，结合历史成功率和初始熔断窗口可以实时精确化对熔断窗口进行调整优化，加快交易执行恢复速度。此外，上述熔断操作的具体执行过程可以实现连续的实时熔断窗口更新，更新操作更加智能化和自动化，能够确保高效率的交易执行过程，同时有力避免第三方服务系统的反应慢、反馈超时甚至雪崩。
[0088]
如图3-图4b所示，根据本公开的另一实施例，在操作s405更新初始熔断窗口中，还包括：
[0089]
根据交易异常率和初始熔断窗口之间的乘积与初始熔断窗口之间的和，确定第二实际熔断窗口；
[0090]
根据第二实际熔断窗口更新初始熔断窗口。
[0091]
如图4b所示，在操作s405中，在更新熔断窗口的过程中，可以基于当前交易任务的
执行情况(如交易成功率)对初始熔断窗口进行调整，比如适当的增加熔断窗口所指定的熔断时长。
[0092]
在本公开另一实施例中，可以交易异常率和初始熔断窗口之间的乘积与初始熔断窗口之间的和，确定第二实际熔断窗口，即满足更新熔断窗口t
new
＝初始熔断窗口t
initial
×
(交易异常率f2+1)。如此，由于异常率f2一般都会低于1，使得t
new
＞t
initial
。也即，适当的对熔断窗口进行了增加。其中，交易异常率f2可以为当前时刻下对应最近一次熔断操作对应的交易任务执行的异常率。其中，具体的更新方式也可以参照上述针对表1的说明进行调整优化，在此不作赘述。
[0093]
如此，便能够以另一种简易方式实现针对初始熔断窗口的有效更新，从而显著增加了熔断窗口更新的方式，使得其具有更好的适应性。而且，在此基础上，在后续系统出现需要熔断场景时，结合历史交易异常率和初始熔断窗口可以实时精确化对熔断窗口进行调整优化，加快交易执行恢复速度，能够确保高效率的交易执行过程，同时有力避免第三方服务系统的反应慢、反馈超时甚至雪崩。
[0094]
如图3-图4b所示，根据本公开的实施例，方法还包括：
[0095]
获取检测当前的交易执行率的累计检测次数；
[0096]
当累计检测次数大于第四设定阈值时，更新初始熔断窗口。
[0097]
如图4b所示，在操作s406-s407中，在获取周期性检测的交易成功率之后，可以对检测交易成功率的次数进行累计，获取累计检测次数。
[0098]
进一步地，在操作s402中确定检测的当前交易成功率大于第一设定阈值或者交易异常率低于第二设定阈值时，则可以说明当前交易执行比较顺利，基本无需担心对第三方服务系统的影响，在此情况下，对累计检测次数与第四设定阈值进行比较，若累计检测次数大于第四设定阈值，则说明初始熔断窗口指定时间过长。
[0099]
例如，经过40次检测之后，每次检测的交易成功率都大于90％，则其累计检测次数为40，进一步地，当确定该累计检测次数大于第四设定阈值(例如39)，则可以说明当前初始熔断窗口的设定可能过长，使得熔断操作对交易执行的效率存在一定影响。为此，可以借此对熔断窗口进行调整优化，将初始熔断窗口的指定时长进行缩短。同时，对累计检测次数执行清零，从而完成一个正常交易执行循环。
[0100]
因此，可以结合上述检测次数针对熔断窗口的更新影响，实现对熔断窗口的实时动态调整，使得其后续熔断操作的熔断周期可长可短，并且能够维持在较好的时间阈值内，从而在优先保证系统正常的交易执行状态下，确保将熔断操作对交易执行的影响降低到最小，同时提高熔断操作对恢复正常交易执行、避免第三方服务交易慢甚至雪崩情况的作用。
[0101]
如图3-图4b所示，根据本公开的另一实施例，在操作s405更新初始熔断窗口中，包括：
[0102]
根据交易成功率和初始熔断窗口之间乘积，确定第三实际熔断窗口：
[0103]
根据第三实际熔断窗口更新初始熔断窗口。
[0104]
如图4b所示，在操作s405中，在更新熔断窗口的过程中，可以基于当前交易任务的执行情况(如交易成功率)对初始熔断窗口进行调整，比如适当的减小熔断窗口所指定的熔断时长。
[0105]
在本公开另一实施例中，可以利用交易成功率和初始熔断窗口之间的比值，确定
第三实际熔断窗口，即满足更新熔断窗口t
new
＝交易成功率f1×
初始熔断窗口t
initial
。如此，由于交易成功率f1一般都会低于1，使得t
new
＜t
initial
，也即，适当的对熔断窗口进行了减小。其中，交易成功率f1为当前时刻下最近一次熔断操作对应的交易任务执行的成功率。其中，具体的更新方式也可以参照上述针对表1的说明进行调整优化，在此不作赘述。
[0106]
如此，便能够以另一种简易方式实现针对初始熔断窗口的有效更新，从而显著增加了熔断窗口更新的方式，使得其具有更好的适应性。而且，在此基础上，在后续系统出现需要熔断场景时，结合历史交易异常率和初始熔断窗口可以实时精确化对熔断窗口进行调整优化，加快交易执行恢复速度，能够确保高效率的交易执行过程，同时有力避免第三方服务系统的反应慢、反馈超时甚至雪崩。
[0107]
如图3-图4b所示，根据本公开的另一实施例，在操作s405更新初始熔断窗口中，包括：
[0108]
根据初始熔断窗口与交易异常率和初始熔断窗口之间的乘积之间的差，确定第四实际熔断窗口；
[0109]
根据第四实际熔断窗口更新初始熔断窗口。
[0110]
如图4b所示，在操作s405中，在更新熔断窗口的过程中，可以基于当前交易任务的执行情况(如交易异常率)对初始熔断窗口进行调整，比如适当的减小熔断窗口所指定的熔断时长。
[0111]
在本公开另一实施例中，可以利用交易异常率和初始熔断窗口之间的乘积与初始熔断窗口之间的差，确定第四实际熔断窗口，即满足更新熔断窗口t
new
＝初始熔断窗口t
initial
×
(1-交易异常率f2)。如此，由于交易异常率f2一般都会低于1，使得t
new
＜t
initial
。也即，适当的对熔断窗口进行了减小。其中，交易异常率f2可以为当前时刻下对应最近一次熔断操作对应的交易任务执行的异常率。其中，具体的更新方式也可以参照上述针对表1的说明进行调整优化，在此不作赘述。
[0112]
如此，便能够以另一种简易方式实现针对初始熔断窗口的有效更新，从而显著增加了熔断窗口更新的方式，使得其具有更好的适应性。而且，在此基础上，在后续系统出现需要熔断场景时，结合历史交易异常率和初始熔断窗口可以实时精确化对熔断窗口进行调整优化，加快交易执行恢复速度，能够确保高效率的交易执行过程，同时有力避免第三方服务系统的反应慢、反馈超时甚至雪崩。
[0113]
综上，本公开实施例中的应用于分布式服务器系统的服务器熔断方法，不仅可以实现熔断窗口的增加更新，也可以实现对其的适当减小更新，结合二者之间的相互影响，使得分布式服务器系统的熔断窗口可以在相当大的范围内根据实际交易执行的状态进行适时动态调整，从而完成了对熔断窗口的动态更新效果，使得其能够最大程度地满足实际交易执行的需要。
[0114]
此外，借助于上述熔断窗口的调整优化，能够直接解决分布式应用架构下，网络或第三方系统能力不确定或能力有限、同时分布式服务器系统的并发处理能力过高，所造成的因双方系统能力不匹配产生的交易执行过慢、反馈超时甚至雪崩的问题。具体地，本公开实施例的上述应用于分布式服务器系统的服务器熔断方法，能够提供一种智能化的动态熔断策略，可以根据第三方实际系统能力实时调整熔断窗口，以实现根据网络及第三方系统当前实际能力设置合理的熔断窗口，从而达到最高有效交易率。
[0115]
基于上述应用于分布式服务器系统的服务器熔断方法，本公开还提供了一种应用于分布式服务器系统的服务器熔断装置。以下将结合图5对该装置进行详细描述。
[0116]
图5示意性示出了根据本公开实施例的应用于分布式服务器系统的服务器熔断装置的结构框图。
[0117]
如图5所示，该实施例的应用于分布式服务器系统的服务器熔断装置500包括信息确定模块510、信息获取模块520和窗口更新模块530。
[0118]
信息确定模块510用于确定当前的交易执行信息。在一实施例中，信息确定模块510可以用于执行前文描述的操作s201，在此不再赘述。
[0119]
信息获取模块520根据初始熔断窗口获取对应交易执行信息的熔断执行信息。在一实施例中，信息获取模块520可以用于执行前文描述的操作s202，在此不再赘述。
[0120]
窗口更新模块530用于基于熔断执行信息更新初始熔断窗口，以用于执行在后的服务器熔断操作。在一实施例中，窗口更新模块530可以用于执行前文描述的操作s203，在此不再赘述。
[0121]
根据本公开的实施例，信息确定模块510、信息获取模块520和窗口更新模块530中的任意多个模块可以合并在一个模块中实现，或者其中的任意一个模块可以被拆分成多个模块。或者，这些模块中的一个或多个模块的至少部分功能可以与其他模块的至少部分功能相结合，并在一个模块中实现。根据本公开的实施例，信息确定模块510、信息获取模块520和窗口更新模块530中的至少一个可以至少被部分地实现为硬件电路，例如现场可编程门阵列(fpga)、可编程逻辑阵列(pla)、片上系统、基板上的系统、封装上的系统、专用集成电路(asic)，或可以通过对电路进行集成或封装的任何其他的合理方式等硬件或固件来实现，或以软件、硬件以及固件三种实现方式中任意一种或以其中任意几种的适当组合来实现。或者，信息确定模块510、信息获取模块520和窗口更新模块530中的至少一个可以至少被部分地实现为计算机程序模块，当该计算机程序模块被运行时，可以执行相应的功能。
[0122]
图6示意性示出了根据本公开实施例的适于实现应用于分布式服务器系统的服务器熔断方法的电子设备的方框图。
[0123]
如图6所示，根据本公开实施例的电子设备600包括处理器601，其可以根据存储在只读存储器(rom)602中的程序或者从存储部分608加载到随机访问存储器(ram)603中的程序而执行各种适当的动作和处理。处理器601例如可以包括通用微处理器(例如cpu)、指令集处理器和/或相关芯片组和/或专用微处理器(例如，专用集成电路(asic))等等。处理器601还可以包括用于缓存用途的板载存储器。处理器601可以包括用于执行根据本公开实施例的方法流程的不同动作的单一处理单元或者是多个处理单元。
[0124]
在ram 603中，存储有电子设备600操作所需的各种程序和数据。处理器601、rom 602以及ram 603通过总线604彼此相连。处理器601通过执行rom 602和/或ram 603中的程序来执行根据本公开实施例的方法流程的各种操作。需要注意，所述程序也可以存储在除rom 602和ram 603以外的一个或多个存储器中。处理器601也可以通过执行存储在所述一个或多个存储器中的程序来执行根据本公开实施例的方法流程的各种操作。
[0125]
根据本公开的实施例，电子设备600还可以包括输入/输出(i/o)接口605，输入/输出(i/o)接口605也连接至总线604。电子设备600还可以包括连接至i/o接口605的以下部件中的一项或多项：包括键盘、鼠标等的输入部分606；包括诸如阴极射线管(crt)、液晶显示
器(lcd)等以及扬声器等的输出部分607；包括硬盘等的存储部分608；以及包括诸如lan卡、调制解调器等的网络接口卡的通信部分606。通信部分606经由诸如因特网的网络执行通信处理。驱动器610也根据需要连接至i/o接口605。可拆卸介质611，诸如磁盘、光盘、磁光盘、半导体存储器等等，根据需要安装在驱动器610上，以便于从其上读出的计算机程序根据需要被安装入存储部分608。
[0126]
本公开还提供了一种计算机可读存储介质，该计算机可读存储介质可以是上述实施例中描述的设备/装置/系统中所包含的；也可以是单独存在，而未装配入该设备/装置/系统中。上述计算机可读存储介质承载有一个或者多个程序，当上述一个或者多个程序被执行时，实现根据本公开实施例的方法。
[0127]
根据本公开的实施例，计算机可读存储介质可以是非易失性的计算机可读存储介质，例如可以包括但不限于：便携式计算机磁盘、硬盘、随机访问存储器(ram)、只读存储器(rom)、可擦式可编程只读存储器(eprom或闪存)、便携式紧凑磁盘只读存储器(cd-rom)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本公开中，计算机可读存储介质可以是任何包含或存储程序的有形介质，该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。例如，根据本公开的实施例，计算机可读存储介质可以包括上文描述的rom 602和/或ram 603和/或rom 602和ram 603以外的一个或多个存储器。
[0128]
本公开的实施例还包括一种计算机程序产品，其包括计算机程序，该计算机程序包含用于执行流程图所示的方法的程序代码。当计算机程序产品在计算机系统中运行时，该程序代码用于使计算机系统实现本公开实施例所提供的方法。
[0129]
在该计算机程序被处理器601执行时执行本公开实施例的系统/装置中限定的上述功能。根据本公开的实施例，上文描述的系统、装置、模块、单元等可以通过计算机程序模块来实现。
[0130]
在一种实施例中，该计算机程序可以依托于光存储器件、磁存储器件等有形存储介质。在另一种实施例中，该计算机程序也可以在网络介质上以信号的形式进行传输、分发，并通过通信部分609被下载和安装，和/或从可拆卸介质611被安装。该计算机程序包含的程序代码可以用任何适当的网络介质传输，包括但不限于：无线、有线等等，或者上述的任意合适的组合。
[0131]
在这样的实施例中，该计算机程序可以通过通信部分609从网络上被下载和安装，和/或从可拆卸介质611被安装。在该计算机程序被处理器601执行时，执行本公开实施例的系统中限定的上述功能。根据本公开的实施例，上文描述的系统、设备、装置、模块、单元等可以通过计算机程序模块来实现。
[0132]
根据本公开的实施例，可以以一种或多种程序设计语言的任意组合来编写用于执行本公开实施例提供的计算机程序的程序代码，具体地，可以利用高级过程和/或面向对象的编程语言、和/或汇编/机器语言来实施这些计算程序。程序设计语言包括但不限于诸如java，c++，python，“c”语言或类似的程序设计语言。程序代码可以完全地在用户计算设备上执行、部分地在用户设备上执行、部分在远程计算设备上执行、或者完全在远程计算设备或服务器上执行。在涉及远程计算设备的情形中，远程计算设备可以通过任意种类的网络，包括局域网(lan)或广域网(wan)，连接到用户计算设备，或者，可以连接到外部计算设备(例如利用因特网服务提供商来通过因特网连接)。
[0133]
附图中的流程图和框图，图示了按照本公开各种实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上，流程图或框图中的每个方框可以代表一个模块、程序段、或代码的一部分，上述模块、程序段、或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个接连地表示的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这依所涉及的功能而定。也要注意的是，框图或流程图中的每个方框、以及框图或流程图中的方框的组合，可以用执行规定的功能或操作的专用的基于硬件的系统来实现，或者可以用专用硬件与计算机指令的组合来实现。
[0134]
本领域技术人员可以理解，本公开的各个实施例和/或权利要求中记载的特征可以进行多种组合或/或结合，即使这样的组合或结合没有明确记载于本公开中。特别地，在不脱离本公开精神和教导的情况下，本公开的各个实施例和/或权利要求中记载的特征可以进行多种组合和/或结合。所有这些组合和/或结合均落入本公开的范围。
[0135]
以上对本公开的实施例进行了描述。但是，这些实施例仅仅是为了说明的目的，而并非为了限制本公开的范围。尽管在以上分别描述了各实施例，但是这并不意味着各个实施例中的措施不能有利地结合使用。本公开的范围由所附权利要求及其等同物限定。不脱离本公开的范围，本领域技术人员可以做出多种替代和修改，这些替代和修改都应落在本公开的范围之内。

技术特征：
1.一种应用于分布式服务器系统的服务器熔断方法，包括：确定当前的交易执行信息；根据初始熔断窗口获取对应所述交易执行信息的熔断执行信息；以及基于所述熔断执行信息更新所述初始熔断窗口，以用于执行在后的服务器熔断操作。2.根据权利要求1所述的方法，其中，在所述确定当前的交易执行信息中，包括：基于设定查询周期，检测当前的交易执行率；根据设定执行阈值，通过所述交易执行率确定所述交易执行信息；其中所述交易执行率包括交易成功率或交易异常率。3.根据权利要求2所述的方法，其中，在所述根据初始熔断窗口获取对应所述交易执行信息的熔断执行信息中，包括：当所述交易成功率低于第一设定阈值或者所述交易异常率高于第二设定阈值时，根据所述初始熔断窗口执行服务器熔断操作；获取所述服务器熔断操作的累计熔断次数，用于构成所述熔断执行信息。4.根据权利要求3所述的方法，其中，在所述基于所述熔断执行信息更新所述初始熔断窗口中，还包括：当所述累计熔断次数大于第三设定阈值时，更新所述初始熔断窗口。5.根据权利要求4所述的方法，其中，在所述更新所述初始熔断窗口中，还包括：根据所述初始熔断窗口和交易成功率之间的比值，确定第一实际熔断窗口；根据所述第一实际熔断窗口更新所述初始熔断窗口。6.根据权利要求4所述的方法，其中，在所述更新所述初始熔断窗口中，还包括：根据所述交易异常率和所述初始熔断窗口之间的乘积与所述初始熔断窗口之间的和，确定第二实际熔断窗口；根据所述第二实际熔断窗口更新所述初始熔断窗口。7.根据权利要求2所述的方法，其中，还包括：获取所述检测当前的交易执行率的累计检测次数；当所述累计检测次数大于第四设定阈值时，更新所述初始熔断窗口。8.根据权利要求7所述的方法，其中，在所述更新所述初始熔断窗口中，包括：根据所述交易成功率和初始熔断窗口之间的乘积，确定第三实际熔断窗口；根据所述第三实际熔断窗口更新所述初始熔断窗口。9.根据权利要求7所述的方法，其中，在所述更新所述初始熔断窗口中，包括：根据所述初始熔断窗口与所述交易异常率和所述初始熔断窗口之间的乘积之间的差，确定第四实际熔断窗口；根据所述第四实际熔断窗口更新所述初始熔断窗口。10.一种应用于分布式服务器系统的服务器熔断装置，包括：信息确定模块，用于确定当前的交易执行信息；信息获取模块，根据初始熔断窗口获取对应所述交易执行信息的熔断执行信息；以及窗口更新模块，用于基于所述熔断执行信息更新所述初始熔断窗口，以用于执行在后的服务器熔断操作。11.一种电子设备，包括：
一个或多个处理器；存储装置，用于存储一个或多个程序，其中，当所述一个或多个程序被所述一个或多个处理器执行时，使得所述一个或多个处理器执行根据权利要求1～9中任一项所述的方法。12.一种计算机可读存储介质，其上存储有可执行指令，该指令被处理器执行时使处理器执行根据权利要求1～9中任一项所述的方法。13.一种计算机程序产品，包括计算机程序，所述计算机程序被处理器执行时实现根据权利要求1～9中任一项所述的方法。

技术总结
本公开提供了一种应用于分布式服务器系统的服务器熔断方法，可以应用于大数据技术领域。该应用于分布式服务器系统的服务器熔断方法包括：确定当前的交易执行信息；根据初始熔断窗口获取对应所述交易执行信息的熔断执行信息；以及基于所述熔断执行信息更新所述初始熔断窗口，以用于执行在后的服务器熔断操作。本公开还提供了一种应用于分布式服务器系统的服务器熔断装置、设备、存储介质和程序产品。存储介质和程序产品。存储介质和程序产品。


技术研发人员：张宏根 胡凯乐 刘金凤 雷琼
受保护的技术使用者：中国工商银行股份有限公司
技术研发日：2023.04.27
技术公布日：2023/7/25