用于业务系统的异步调度方法及装置

摘要

本申请公开了一种用于业务系统的异步调度方法及装置。该方法包括在异步处理场景中，按照标准事件处理接口提交事件；在事件保存接口，将异步处理场景中处理的数据储存至数据库；还包括：在所述异步调度组件中处理一个或多个所述事件；根据事件类型确定事件处理类，并根据所述事件处理类调用所述业务系统的事件处理类；在所述异步调度组件接收所述业务系统返回的处理结果。本申请解决了异步处理代价高的技术问题。通过本申请将异步处理的场景概念化，抽象化。本申请中的可嵌入式组件，容易与业务系统的集成。而且无须额外部署，节省了硬件资源。

权利要求

1.一种用于业务系统的异步调度方法，其特征在于，在业务系统中嵌入异步调度组件，所述方法包括：在异步处理场景中，按照标准事件处理接口提交事件，其中，一个或多个所述事件是指通过异步调度组件对需要进行异步处理的业务场景的转化结果；

在事件保存接口，将异步处理场景中处理的数据储存至数据库；

还包括：

在所述异步调度组件中处理一个或多个所述事件；

根据事件类型确定事件处理类，并根据所述事件处理类调用所述业务系统的事件处理类；

在所述异步调度组件接收所述业务系统返回的处理结果。

2.根据权利要求1所述的用于业务系统的异步调度方法，其特征在于，在异步处理场景中，按照标准事件处理接口提交事件之前，还包括：异步调度组件初始化步骤，所述异步调度组件初始化步骤包括：在业务系统加载组件，启动组件初始化；

组件扫描业务系统中的事件处理类，并绑定事件处理类和事件类型的映射；

在业务系统完成组件初始化。

3.根据权利要求1所述的用于业务系统的异步调度方法，其特征在于，在所述异步调度组件接收所述业务系统返回的处理结果包括：如果所述业务系统返回的处理结果是成功，则将事件处理状态修改为处理成功；

将事件转化为冷数据，完成事件处理。

4.根据权利要求1所述的用于业务系统的异步调度方法，其特征在于，在所述异步调度组件接收所述业务系统返回的处理结果包括：如果所述业务系统返回的处理结果是重试，则将事件处理状态修改为处理中；

计算事件的下一次处理时间，等待下次事件调用处理。

5.根据权利要求1所述的用于业务系统的异步调度方法，其特征在于，在所述异步调度组件接收所述业务系统返回的处理结果包括：如果所述业务系统返回的处理结果是失败，则将事件处理状态修改为处理失败；

增加处理的失败次数，根据所述失败次数计算下一次处理时间，其中，所述失败次数的越多，计算下一次处理时间间隔越大。

6.根据权利要求1所述的用于业务系统的异步调度方法，其特征在于，异步调度组还包括：告警步骤，所述告警步骤包括：判断异步调度组件接收所述业务系统返回的处理结果中的失败次数是否超过处理阀值；

如果判断异步调度组件接收所述业务系统返回的处理结果中的失败次数超过处理阀值，则发送处理失败告警并终止事件处理。

7.根据权利要求1所述的用于业务系统的异步调度方法，其特征在于，异步调度组还包括：清理或归档事件的步骤，根据异步调度组件接收所述业务系统返回的处理结果中的处理成功的已转化为冷数据的事件；

对事件中的冷数据进行定期归档或者清理。

8.一种用于业务系统的异步调度装置，其特征在于，在业务系统中嵌入异步调度组件，所述装置包括：提交模块，用于在异步处理场景中，按照标准事件处理接口提交事件，其中，一个或多个所述事件是指通过异步调度组件对需要进行异步处理的业务场景的转化结果；

保存模块，用于在事件保存接口，将异步处理场景中处理的数据储存至数据库；

还包括：

处理模块，用于在所述异步调度组件中处理一个或多个所述事件；

调用模块，用于根据事件类型确定事件处理类，并根据所述事件处理类调用所述业务系统的事件处理类；

返回模块，用于在所述异步调度组件接收所述业务系统返回的处理结果。

9.根据权利要求8所述的用于业务系统的异步调度装置，其特征在于，还包括：初始化模块，用于在业务系统加载组件，启动组件初始化；

组件扫描业务系统中的事件处理类，并绑定事件处理类和事件类型的映射；

在业务系统完成组件初始化。

10.根据权利要求8所述的用于业务系统的异步调度装置，其特征在于，所述异步调度组件还包括：告警模块，用于判断异步调度组件接收所述业务系统返回的处理结果中的失败次数是否超过处理阀值；

如果判断异步调度组件接收所述业务系统返回的处理结果中的失败次数超过处理阀值，则发送处理失败告警并终止事件处理；

数据归档或清理模块，用于根据异步调度组件接收所述业务系统返回的处理结果中的处理成功的已转化为冷数据的事件；

对事件中的冷数据进行定期归档或者清理。

说明书

用于业务系统的异步调度方法及装置

技术领域

[0001] 本申请涉及业务系统异步处理领域，具体而言，涉及一种用于业务系统的异步调度方法及装置。

背景技术

[0002] 业务系统中上会存在很多场景需要转为异步处理。

[0003] 发明人发现，现有异步处理采用集中式解决方式，对于业务系统接入的代价较高。进一步，造成维护代价提高。

[0004] 针对相关技术中异步处理代价高的问题，目前尚未提出有效的解决方案。

发明内容

[0005] 本申请的主要目的在于提供一种用于业务系统的异步调度方法及装置，以解决异步处理代价高的问题。

[0006] 为了实现上述目的，根据本申请的一个方面，提供了一种用于业务系统的异步调度方法，在业务系统中嵌入异步调度组件。

[0007] 根据本申请的用于业务系统的异步调度方法包括：在异步处理场景中，按照标准事件处理接口提交事件，其中，一个或多个所述事件是指通过异步调度组件对需要进行异
步处理的业务场景的转化结果；在事件保存接口，将异步处理场景中处理的数据储存至数
据库；还包括：在所述异步调度组件中处理一个或多个所述事件；根据事件类型确定事件处
理类，并根据所述事件处理类调用所述业务系统的事件处理类；在所述异步调度组件接收
所述业务系统返回的处理结果。

[0008] 进一步地，在异步处理场景中，按照标准事件处理接口提交事件之前，还包括：异步调度组件初始化步骤，所述异步调度组件初始化步骤包括：在业务系统加载组件，启动组
件初始化；组件扫描业务系统中的事件处理类，并绑定事件处理类和事件类型的映射；在业
务系统完成组件初始化。

[0009] 进一步地，在所述异步调度组件接收所述业务系统返回的处理结果包括：如果所述业务系统返回的处理结果是成功，则将事件处理状态修改为处理成功；将事件转化为冷
数据，完成事件处理。

[0010] 进一步地，在所述异步调度组件接收所述业务系统返回的处理结果包括：如果所述业务系统返回的处理结果是重试，则将事件处理状态修改为处理中；计算事件的下一次
处理时间，等待下次事件调用处理。

[0011] 进一步地，在所述异步调度组件接收所述业务系统返回的处理结果包括：如果所述业务系统返回的处理结果是失败，则将事件处理状态修改为处理失败；增加处理的失败
次数，根据所述失败次数计算下一次处理时间，其中，所述失败次数的越多，计算下一次处
理时间间隔越大。

[0012] 进一步地，异步调度组还包括：告警步骤，所述告警步骤包括：判断异步调度组件接收所述业务系统返回的处理结果中的失败次数是否超过处理阀值；如果判断异步调度组
件接收所述业务系统返回的处理结果中的失败次数超过处理阀值，则发送处理失败告警并
终止事件处理。

[0013] 进一步地，异步调度组还包括：清理或归档事件的步骤，根据异步调度组件接收所述业务系统返回的处理结果中的处理成功的已转化为冷数据的事件；对事件中的冷数据进
行定期归档或者清理。

[0014] 为了实现上述目的，根据本申请的另一方面，提供了一种用于业务系统的异步调度装置，在业务系统中嵌入异步调度组件。

[0015] 根据本申请的用于业务系统的异步调度装置包括：提交模块，用于在异步处理场景中，按照标准事件处理接口提交事件，其中，一个或多个所述事件是指通过异步调度组件
对需要进行异步处理的业务场景的转化结果；保存模块，用于在事件保存接口，将异步处理
场景中处理的数据储存至数据库；还包括：处理模块，用于在所述异步调度组件中处理一个
或多个所述事件；调用模块，用于根据事件类型确定事件处理类，并根据所述事件处理类调
用所述业务系统的事件处理类；返回模块，用于在所述异步调度组件接收所述业务系统返
回的处理结果。

[0016] 进一步地，还包括：初始化模块，用于在业务系统加载组件，启动组件初始化；组件扫描业务系统中的事件处理类，并绑定事件处理类和事件类型的映射；在业务系统完成组件初始化。

[0017] 进一步地，所述异步调度组件还包括：告警模块，用于判断异步调度组件接收所述业务系统返回的处理结果中的失败次数是否超过处理阀值；如果判断异步调度组件接收所
述业务系统返回的处理结果中的失败次数超过处理阀值，则发送处理失败告警并终止事件
处理；数据归档或清理模块，用于根据异步调度组件接收所述业务系统返回的处理结果中
的处理成功的已转化为冷数据的事件；对事件中的冷数据进行定期归档或者清理。

[0018] 在本申请实施例中用于业务系统的异步调度方法及装置，采用在业务系统中嵌入异步调度组件的方式，通过在异步处理场景中，按照标准事件处理接口提交事件，在事件保
存接口，将异步处理场景中处理的数据储存至数据库，以及通过在所述异步调度组件中处
理一个或多个所述事件；根据事件类型确定事件处理类，并根据所述事件处理类调用所述
业务系统的事件处理类；在所述异步调度组件接收所述业务系统返回的处理结果。达到了
将异步处理的场景概念化、抽象化的目的，从而实现了将事件处理的全流程标准化，程式化
的技术效果，进而解决了异步处理代价高的技术问题。

[0019] 进一步，通过将冷热数据自动分离，可以使待处理的数据始终保持在一个可控的范围内，避免随着时间的增加导致数据积累过大从而影响处理效率。通过处理失败衰减策
略，就可以避免无意义的重试，节省服务器资源。通过引入了告警机制，当事件无法被处理
时，可以及时的通知到业务负责人，提高发现问题的时效。另外，还提供了冷数据定期归档
或者清理功能，可以节省数据库资源。

附图说明

[0020] 构成本申请的一部分的附图用来提供对本申请的进一步理解，使得本申请的其它特征、目的和优点变得更明显。本申请的示意性实施例附图及其说明用于解释本申请，并不
构成对本申请的不当限定。在附图中：

[0021] 图1是根据本申请第一实施例的用于业务系统的异步调度方法流程示意图；

[0022] 图2是根据本申请第二实施例的用于业务系统的异步调度方法流程示意图；

[0023] 图3是根据本申请第三实施例的用于业务系统的异步调度方法流程示意图；

[0024] 图4是根据本申请第四实施例的用于业务系统的异步调度方法流程示意图；

[0025] 图5是根据本申请第五实施例的用于业务系统的异步调度方法流程示意图；

[0026] 图6是根据本申请第六实施例的用于业务系统的异步调度方法流程示意图；

[0027] 图7是根据本申请第七实施例的用于业务系统的异步调度方法流程示意图；

[0028] 图8是根据本申请第一实施例的用于业务系统的异步调度装置结构示意图；

[0029] 图9是根据本申请第二实施例的用于业务系统的异步调度装置结构示意图；

[0030] 图10是根据本申请实施例的调度组件工作原理示意图。

具体实施方式

[0031] 为了使本技术领域的人员更好地理解本申请方案，下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是
本申请一部分的实施例，而不是全部的实施例。基于本申请中的实施例，本领域普通技术人
员在没有做出创造性劳动前提下所获得的所有其他实施例，都应当属于本申请保护的范
围。

[0032] 需要说明的是，本申请的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用
的数据在适当情况下可以互换，以便这里描述的本申请的实施例。此外，术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或单元的
过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元，而是可包括没有清
楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。

[0033] 在本申请中，术语“上”、“下”、“左”、“右”、“前”、“后”、“顶”、“底”、“内”、“外”、“中”、“竖直”、“水平”、“横向”、“纵向”等指示的方位或位置关系为基于附图所示的方位或位置关系。这些术语主要是为了更好地描述本申请及其实施例，并非用于限定所指示的装置、元件或组成部分必须具有特定方位，或以特定方位进行构造和操作。

[0034] 并且，上述部分术语除了可以用于表示方位或位置关系以外，还可能用于表示其他含义，例如术语“上”在某些情况下也可能用于表示某种依附关系或连接关系。对于本领
域普通技术人员而言，可以根据具体情况理解这些术语在本申请中的具体含义。

[0035] 此外，术语“安装”、“设置”、“设有”、“连接”、“相连”、“套接”应做广义理解。例如，可以是固定连接，可拆卸连接，或整体式构造；可以是机械连接，或电连接；可以是直接相连，或者是通过中间媒介间接相连，又或者是两个装置、元件或组成部分之间内部的连通。
对于本领域普通技术人员而言，可以根据具体情况理解上述术语在本申请中的具体含义。

[0036] 需要说明的是，在不冲突的情况下，本申请中的实施例及实施例中的特征可以相互组合。下面将参考附图并结合实施例来详细说明本申请。

[0037] 如图1所示，该方法包括如下的步骤S102至步骤S110：

[0038] 步骤S102，在异步处理场景中，按照标准事件处理接口提交事件；

[0039] 具体地，一个可嵌入到业务系统的轻量级异步调度组件，异步调度组件有个核心的概念叫事件(event)，所有需要异步处理的业务场景对于组件来说都可以转化为一个事
件。一个或多个所述事件是指通过异步调度组件对需要进行异步处理的业务场景的转化结
果。

[0040] 步骤S104，在事件保存接口，将异步处理场景中处理的数据储存至数据库；

[0041] 具体地，在业务系统只需针对需要异步处理的场景实现组件提供的标准事件处理接口，并在合适的时机将数据通过组件提供的事件保存接口存入数据库，后续通通交由组
件来完成，对业务系统的侵入非常小，从而接入代价非常小。

[0042] 还包括：

[0043] 步骤S106，在所述异步调度组件中处理一个或多个所述事件；

[0044] 步骤S108，根据事件类型确定事件处理类，并根据所述事件处理类调用所述业务系统的事件处理类；

[0045] 步骤S110，在所述异步调度组件接收所述业务系统返回的处理结果。

[0046] 在业务系统中嵌入异步调度组件中进行上述的操作，所述异步调度组件中可以处理一个或批量处理多个所述事件，根据事件类型确定所述事件处理类，然后再根据所述事
件处理类调用在所述业务系统中的事件处理类，并且在所述异步调度组件接收由所述业务
系统返回的处理结果。通过将需要异步处理的场景抽象成一个或多个事件的概念，并把一
个或多个事件的处理全流程打包在一个异步调度组件当中，由异步调度组件统一来完成。

[0047] 具体地，通过事件调度可以捞取批量待处理的事件，并且循环处理每一个待处理的事件。根据事件类型可以找到事件处理类，调用业务系统中的事件处理类对事件进行处
理。

[0048] 从以上的描述中，可以看出，本申请实现了如下技术效果：

[0049] 采用在业务系统中嵌入异步调度组件的方式，通过在异步处理场景中，按照标准事件处理接口提交事件，在事件保存接口，将异步处理场景中处理的数据储存至数据库，以
及通过在所述异步调度组件中处理一个或多个所述事件；根据事件类型确定事件处理类，
并根据所述事件处理类调用所述业务系统的事件处理类；在所述异步调度组件接收所述业
务系统返回的处理结果。达到了将异步处理的场景概念化、抽象化的目的，从而实现了将事
件处理的全流程标准化，程式化的技术效果，进而解决了异步处理代价高的技术问题。

[0050] 根据本申请实施例，作为本实施例中的优选，如图2所示，在异步处理场景中，按照标准事件处理接口提交事件之前，还包括：异步调度组件初始化步骤，所述异步调度组件初
始化步骤包括：

[0051] 步骤S202，在业务系统加载组件，启动组件初始化；

[0052] 步骤S204，组件扫描业务系统中的事件处理类，并绑定事件处理类和事件类型的映射；

[0053] 步骤S206，在业务系统完成组件初始化。

[0054] 具体地，通过上述操作可以完成异步调度组件的初始化。在业务系统中启动服务，在业务系统中加载组件，组件进行初始化开始扫描业务务系统中的事件处理类，然后绑定
事件处理类与事件类型的映射，初始化组件完毕。

[0055] 优选地，在本申请的实施例中将冷热数据自动分离，可以使待处理的数据始终保持在一个可控的范围内，避免随着时间的增加导致数据积累过大从而影响处理效率。

[0056] 根据本申请实施例，作为本实施例中的优选，如图3所示，在所述异步调度组件接收所述业务系统返回的处理结果包括：

[0057] 步骤S302，如果所述业务系统返回的处理结果是成功，则将事件处理状态修改为处理成功；

[0058] 步骤S304，将事件转化为冷数据，完成事件处理。

[0059] 具体地，异步调度组件采用标准的事件存储结构SQL。

[0060] 所述异步调度组件支持单个事件处理或调度式处理，如果所述业务系统返回的处理结果是成功，则将事件处理状态修改为处理成功。所述异步调度组件支持单线程或者多
线程调度事件处理。所述异步调度组件冷热数据自动分离，用于将事件转化为冷数据，完成
事件处理。

[0061] 根据本申请实施例，作为本实施例中的优选，如图4所示，在所述异步调度组件接收所述业务系统返回的处理结果包括：

[0062] 步骤S402，如果所述业务系统返回的处理结果是重试，则将事件处理状态修改为处理中；

[0063] 步骤S404，计算事件的下一次处理时间，等待下次事件调用处理。

[0064] 具体地，异步调度组件采用标准的事件存储结构SQL。

[0065] 所述异步调度组件支持单个事件处理或调度式处理，如果所述业务系统返回的处理结果是重试，则将事件处理状态修改为处理中。所述异步调度组件支持单线程或者多线
程调度事件处理，进一步计算事件的下一次处理时间，等待下次事件调用处理。

[0066] 根据本申请实施例，作为本实施例中的优选，如图5所示，在所述异步调度组件接收所述业务系统返回的处理结果包括：

[0067] 步骤S502，如果所述业务系统返回的处理结果是失败，则将事件处理状态修改为处理失败；

[0068] 步骤S504，增加处理的失败次数，根据所述失败次数计算下一次处理时间，其中，所述失败次数的越多，计算下一次处理时间间隔越大。

[0069] 具体地，异步调度组件采用异常时的调度衰减机制，同时支持自定义衰减策略。

[0070] 所述异步调度组件支持单个事件处理或调度式处理，如果所述业务系统返回的处理结果是失败，则将事件处理状态修改为处理失败。所述异步调度组件支持单线程或者多
线程调度事件处理，增加处理的失败次数，根据所述失败次数计算下一次处理时间。

[0071] 优选地，通过引入处理失败衰减策略，可以避免无意义的重试，节省服务器资源。

[0072] 根据本申请实施例，作为本实施例中的优选，如图6所示，异步调度组还包括：告警步骤，所述告警步骤包括：

[0073] 步骤S602，判断异步调度组件接收所述业务系统返回的处理结果中的失败次数是否超过处理阀值；

[0074] 步骤S604，如果判断异步调度组件接收所述业务系统返回的处理结果中的失败次数超过处理阀值，则发送处理失败告警并终止事件处理。

[0075] 具体地，所述异步调度组件支持失败超过处理阀值的告警机制。通过判断异步调度组件接收所述业务系统返回的处理结果中的失败次数是否超过处理阀值，如果判断异步
调度组件接收所述业务系统返回的处理结果中的失败次数超过处理阀值，则事件中止处
理、事件调度结束，并等待下次调度。所述异步调度组件支持自定义衰减策略，失败次数不
小于允许最大尝试次数可以配置。

[0076] 优选地，通过引入告警机制，当事件无法被处理时，可以及时的通知到业务负责人，提高发现问题的时效。

[0077] 根据本申请实施例，作为本实施例中的优选，如图7所示，异步调度组还包括：清理或归档事件的步骤，

[0078] 步骤S702，根据异步调度组件接收所述业务系统返回的处理结果中的处理成功的已转化为冷数据的事件；

[0079] 步骤S704，对事件中的冷数据进行定期归档或者清理。

[0080] 具体地，所述异步调度组件支持数据归档以及清理功能。

[0081] 需要说明的是，在附图的流程图示出的步骤可以在诸如一组计算机可执行指令的计算机系统中执行，并且，虽然在流程图中示出了逻辑顺序，但是在某些情况下，可以以不
同于此处的顺序执行所示出或描述的步骤。

[0082] 优选地，通过提供冷数据定期归档或者清理功能，可以节省数据库资源。

[0083] 根据本申请实施例，还提供了一种用于实施上述方法的用于业务系统的异步调度装置，如图8所示，在业务系统中嵌入异步调度组件，该装置包括：提交模块10，用于在异步处理场景中，按照标准事件处理接口提交事件，其中，一个或多个所述事件是指通过异步调
度组件对需要进行异步处理的业务场景的转化结果；保存模块20，用于在事件保存接口，将
异步处理场景中处理的数据储存至数据库；还包括：处理模块30，用于在所述异步调度组件
中处理一个或多个所述事件；调用模块40，用于根据事件类型确定事件处理类，并根据所述
事件处理类调用所述业务系统的事件处理类；返回模块50，用于在所述异步调度组件接收
所述业务系统返回的处理结果。

[0084] 本申请实施例的提交模块10中具体地，一个可嵌入到业务系统的轻量级异步调度组件，异步调度组件有个核心的概念叫事件(event)，所有需要异步处理的业务场景对于组
件来说都可以转化为一个事件。一个或多个所述事件是指通过异步调度组件对需要进行异
步处理的业务场景的转化结果。

[0085] 本申请实施例的保存模块20中具体地，在业务系统只需针对需要异步处理的场景实现组件提供的标准事件处理接口，并在合适的时机将数据通过组件提供的事件保存接口
存入数据库，后续通通交由组件来完成，对业务系统的侵入非常小，从而接入代价非常小。

[0086] 本申请实施例的处理模块30、调用模块40以及返回模块50中在业务系统中嵌入异步调度组件中进行上述的操作，所述异步调度组件中可以处理一个或批量处理多个所述事
件，根据事件类型确定所述事件处理类，然后再根据所述事件处理类调用在所述业务系统
中的事件处理类，并且在所述异步调度组件接收由所述业务系统返回的处理结果。通过将
需要异步处理的场景抽象成一个或多个事件的概念，并把一个或多个事件的处理全流程打
包在一个异步调度组件当中，由异步调度组件统一来完成。

[0087] 具体地，通过事件调度可以捞取批量待处理的事件，并且循环处理每一个待处理的事件。根据事件类型可以找到事件处理类，调用业务系统中的事件处理类对事件进行处
理。

[0088] 根据本申请实施例，作为本实施例中的优选，如图9所示，还包括：初始化模块，用于在业务系统加载组件，启动组件初始化60；组件扫描业务系统中的事件处理类，并绑定事
件处理类和事件类型的映射；在业务系统完成组件初始化。

[0089] 具体地，通过上述操作可以完成异步调度组件的初始化。在业务系统中启动服务，在业务系统中加载组件，组件进行初始化开始扫描业务务系统中的事件处理类，然后绑定
事件处理类与事件类型的映射，初始化组件完毕。

[0090] 优选地，在本申请的实施例中将冷热数据自动分离，可以使待处理的数据始终保持在一个可控的范围内，避免随着时间的增加导致数据积累过大从而影响处理效率。

[0091] 根据本申请实施例，作为本实施例中的优选，如图9所示，所述异步调度组件还包括：告警模块70，用于判断异步调度组件接收所述业务系统返回的处理结果中的失败次数
是否超过处理阀值；如果判断异步调度组件接收所述业务系统返回的处理结果中的失败次
数超过处理阀值，则发送处理失败告警并终止事件处理；数据归档或清理模块80，用于根据
异步调度组件接收所述业务系统返回的处理结果中的处理成功的已转化为冷数据的事件；
对事件中的冷数据进行定期归档或者清理。

[0092] 具体地，所述异步调度组件支持失败超过处理阀值的告警机制。通过判断异步调度组件接收所述业务系统返回的处理结果中的失败次数是否超过处理阀值，如果判断异步
调度组件接收所述业务系统返回的处理结果中的失败次数超过处理阀值，则事件中止处
理、事件调度结束，并等待下次调度。所述异步调度组件支持自定义衰减策略，失败次数不
小于允许最大尝试次数可以配置。

[0093] 优选地，通过引入告警机制，当事件无法被处理时，可以及时的通知到业务负责人，提高发现问题的时效。

[0094] 具体地，所述异步调度组件支持数据归档以及清理功能。

[0095] 如图10所示，是本申请实施例的用于业务系统的异步调度方法的实现原理。

[0096] 具体地，在业务系统只需针对需要异步处理的场景实现组件提供的标准事件处理接口，并在合适的时机将数据通过组件提供的事件保存接口存入数据库，后续通通交由组
件来完成，对业务系统的侵入非常小，接入代价非常小。

[0097] 在业务系统中嵌入异步调度组件，调度组件用于，按照标准的事件存储结构(SQL)。

[0098] 调度组件，支持单个事件处理和调度式处理；调度组件，支持单线程或者多线程调度事件处理；调度组件支持冷热数据自动分离；调度组件支持异常时的调度衰减机制；调度
组件支持自定义衰减策略；调度组件支持失败超过处理阀值的告警机制；调度组件支持数
据归档以及清理功能。

[0099] 本申请实施例中可嵌入式组件，容易与业务系统的集成。而且无须额外部署，节省了硬件资源。

[0100] 显然，本领域的技术人员应该明白，上述的本申请的各模块或各步骤可以用通用的计算装置来实现，它们可以集中在单个的计算装置上，或者分布在多个计算装置所组成
的网络上，可选地，它们可以用计算装置可执行的程序代码来实现，从而，可以将它们存储
在存储装置中由计算装置来执行，或者将它们分别制作成各个集成电路模块，或者将它们
中的多个模块或步骤制作成单个集成电路模块来实现。这样，本申请不限制于任何特定的
硬件和软件结合。

[0101] 以上所述仅为本申请的优选实施例而已，并不用于限制本申请，对于本领域的技术人员来说，本申请可以有各种更改和变化。凡在本申请的精神和原则之内，所作的任何修
改、等同替换、改进等，均应包含在本申请的保护范围之内。