CN104484167B - 任务处理方法及装置 - Google Patents

Abstract

本发明公开了一种任务处理方法及装置，属于计算机技术领域。所述方法包括：获取重新启动前预设时间段内未成功执行的第一流程实例；修复第一流程实例中的所有未成功处理的第一任务，并修复第一流程实例中每个第一任务之间的先后依赖关系；根据每个第一任务之间修复后的先后依赖关系确定第一流程实例中已修复且需要处理的第一任务，并根据已修复且需要处理的第一任务生成第一任务处理指令；将第一任务处理指令发送至第二服务器，由第二服务器接收第一任务处理指令，并根据接收到的第一任务处理指令处理任务。本发明通过修复重启前未成功执行的第一流程实例，从而在重启后能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

Description

任务处理方法及装置

技术领域

本发明涉及计算机技术领域，特别涉及一种任务处理方法及装置。

背景技术

随着现在计算机技术的快速发展，越来越多的服务商通过服务器来处理不同业务中的任务。其中，服务器对任务进行处理的方法影响到相关系统可用性。因此，如何对任务进行处理是提高系统可用性的关键。

相关技术中提供了一种任务处理方法，在该方法中，预先确定需要执行的流程实例，根据需要执行的流程实例确定当前需要处理的任务，并对任务进行处理。其中，执行上述过程的服务器中可能会因故障而重新启动，服务器在执行流程实例或处理流程实例中的任务时也可能会失败。当流程实例执行失败时，则立刻重新执行流程实例。当流程实例中的任务处理失败时，则立刻重新处理任务。

在实现本发明的过程中，发明人发现上述方法至少存在以下问题：

由于服务器可能会因故障而重新启动，若重新启动前存在未成功处理的任务对应的流程实例，则服务器在重新启动后，之前未执行成功的流程实例或未处理成功的任务均会丢失。因此，任务处理时的可用性较低，稳定性较差。

发明内容

为了解决现有技术的问题，本发明实施例提供了一种任务处理方法及装置。所述技术方案如下：

第一方面，提供了一种任务处理方法，所述方法包括：

获取重新启动前预设时间段内未成功执行的第一流程实例，所述第一流程实例为重新启动前预设时间段内包含未成功处理的任务对应的流程实例，所述第一流程实例中包括至少一个未成功处理的第一任务；

修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系；

根据每个第一任务之间修复后的先后依赖关系确定所述第一流程实例中已修复且需要处理的第一任务，并根据已修复且需要处理的第一任务生成第一任务处理指令，所述第一任务处理指令中至少包括已修复且需要处理的第一任务；

将所述第一任务处理指令发送至第二服务器，由所述第二服务器接收第一任务处理指令，并根据接收到的第一任务处理指令处理任务。

结合第一方面，在第一方面的第一种可能的实现方式中，所述根据每个第一任务之间修复后的先后依赖关系确定所述第一流程实例中已修复且需要处理的第一任务，包括：

根据每个第一任务之间修复后的先后依赖关系确定已修复的第一任务中无前序任务的第一任务，并将无前序任务的第一任务作为已修复且需要处理的第一任务。

结合第一方面，在第一方面的第二种可能的实现方式中，所述修复所述第一流程实例中的所有第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系之前，还包括：

记录重新启动前所述第一流程实例中的所有第一任务的状态信息，并记录重新启动前所述第一流程实例中每个第一任务之间的先后依赖关系的相关信息；

所述修复所述第一流程实例中的所有第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系，包括：

根据所述第一流程实例中的所有第一任务的状态信息修复所述第一流程实例中的所有第一任务，并根据所述第一流程实例中每个第一任务之间的先后依赖关系的相关信息修复所述第一流程实例中每个第一任务之间的先后依赖关系。

结合第一方面，在第一方面的第三种可能的实现方式中，所述方法还包括：

获取当前任务流程，并根据当前任务流程生成第二流程实例，所述第二流程实例中包括至少一个第二任务，每个第二任务之间存在先后依赖关系；

根据每个第二任务之间的先后依赖关系确定所述第二流程实例中需要处理的第二任务，并根据需要处理的第二任务生成第二任务处理指令，所述第二任务处理指令中至少包括需要处理的第二任务；

将所述第二任务处理指令发送至第二服务器，由所述第二服务器接收第二任务处理指令，并根据接收到的第二任务处理指令处理任务。

第二方面，提供了一种任务处理方法，所述方法包括：

接收第一服务器发送的第一任务处理指令，所述第一任务处理指令中至少包括已修复且需要处理的第一任务，所述已修复且需要处理的第一任务为所述第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例中的任务；

根据接收到的第一任务处理指令处理任务。

结合第二方面，在第二方面的第一种可能的实现方式中，所述方法还包括：

接收第一服务器发送的第二任务处理指令，所述第二任务处理指令中至少包括需要处理的第二任务，所述需要处理的第二任务为所述第一服务器根据当前任务流程生成的第二流程实例中的任务；

根据接收到的第二任务处理指令处理任务。

第三方面，提供了一种任务处理装置，所述装置包括：

第一获取模块，用于获取重新启动前预设时间段内未成功执行的第一流程实例，所述第一流程实例为重新启动前预设时间段内包含未成功处理的任务对应的流程实例，所述第一流程实例中包括至少一个未成功处理的第一任务；

修复模块，用于修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系；

第一确定模块，用于根据每个第一任务之间修复后的先后依赖关系确定所述第一流程实例中已修复且需要处理的第一任务；

第一生成模块，用于根据已修复且需要处理的第一任务生成第一任务处理指令，所述第一任务处理指令中至少包括已修复且需要处理的第一任务；

第一发送模块，用于将所述第一任务处理指令发送至第二服务器，由所述第二服务器接收第一任务处理指令，并根据接收到的第一任务处理指令处理任务。

结合第三方面，在第三方面的第一种可能的实现方式中，所述第一确定模块，用于根据每个第一任务之间修复后的先后依赖关系确定已修复的第一任务中无前序任务的第一任务，并将无前序任务的第一任务作为已修复且需要处理的第一任务。

结合第三方面，在第三方面的第二种可能的实现方式中，所述装置还包括：

记录模块，用于记录重新启动前所述第一流程实例中的所有第一任务的状态信息，并记录重新启动前所述第一流程实例中每个第一任务之间的先后依赖关系的相关信息；

所述修复模块，用于根据所述第一流程实例中的所有第一任务的状态信息修复所述第一流程实例中的所有第一任务，并根据所述第一流程实例中每个第一任务之间的先后依赖关系的相关信息修复所述第一流程实例中每个第一任务之间的先后依赖关系。

结合第三方面，在第三方面的第三种可能的实现方式中，所述装置还包括：

第二获取模块，用于获取当前任务流程，并根据当前任务流程生成第二流程实例，所述第二流程实例中包括至少一个第二任务，每个第二任务之间存在先后依赖关系；

第二确定模块，用于根据每个第二任务之间的先后依赖关系确定所述第二流程实例中需要处理的第二任务；

第二生成模块，用于根据需要处理的第二任务生成第二任务处理指令，所述第二任务处理指令中至少包括需要处理的第二任务；

第二发送模块，用于将所述第二任务处理指令发送至第二服务器，由所述第二服务器接收第二任务处理指令，并根据接收到的第二任务处理指令处理任务。

第四方面，提供了一种任务处理装置，所述装置包括：

第一接收模块，用于接收第一服务器发送的第一任务处理指令，所述第一任务处理指令中至少包括已修复且需要处理的第一任务，所述已修复且需要处理的第一任务为所述第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例中的任务；

第一处理模块，用于根据接收到的第一任务处理指令处理任务。

结合第四方面，在第四方面的第一种可能的实现方式中，所述装置还包括：

第二接收模块，用于接收第一服务器发送的第二任务处理指令，所述第二任务处理指令中至少包括需要处理的第二任务，所述需要处理的第二任务为所述第一服务器根据当前任务流程生成的第二流程实例中的任务；

第二处理模块，用于根据接收到的第二任务处理指令处理任务。

本发明实施例提供的技术方案带来的有益效果是：

通过修复重新启动前预设时间段内未成功执行的第一流程实例中的所有未成功处理的第一任务及每个第一任务之间的先后依赖关系，根据修复后的先后依赖关系确定需要处理的第一任务，生成第一任务处理指令，将第一任务处理指令发送至第二服务器，由第二服务器根据第一任务处理指令处理任务。由于能够修复重新启动前未成功执行的第一流程实例，从而在重新启动后能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

附图说明

为了更清楚地说明本发明实施例中的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

图1是本发明一实施例提供的一种任务处理方法的实施环境示意图；

图2是本发明另一实施例提供的一种任务处理方法的流程图；

图3是本发明另一实施例提供的一种任务处理方法的流程图；

图4是本发明另一实施例提供的一种任务处理方法的流程图；

图5是本发明另一实施例提供的一种任务处理装置的结构示意图；

图6是本发明另一实施例提供的一种任务处理装置的结构示意图；

图7是本发明另一实施例提供的一种任务处理装置的结构示意图；

图8是本发明另一实施例提供的一种服务器的结构示意图；

图9是本发明另一实施例提供的一种任务处理装置的结构示意图；

图10是本发明另一实施例提供的一种任务处理装置的结构示意图；

图11是本发明另一实施例提供的一种服务器的结构示意图。

具体实施方式

为使本发明的目的、技术方案和优点更加清楚，下面将结合附图对本发明实施方式作进一步地详细描述。

请参考图1，其示出了本发明实施例提供的任务处理方法所涉及的实施环境示意图。如图1所示，该实施环境包括第一服务器101及第二服务器102。通过图1所示的实施环境，第一服务器101与第二服务器102可通过无线网络或有线网络进行通信。

为了便于说明，图1示出的第一服务器101与第二服务器102仅代表多台服务器中的一台。下面将以通过第一服务器101与第二服务器102之间的信息交互实现对任务进行处理为例，来对本发明实施例提供的任务处理方法进行举例说明。

结合上述图1所示的实施环境，本发明另一实施例提供了一种任务处理方法，参见图2，本发明实施例提供的方法流程包括：

201：获取重新启动前预设时间段内未成功执行的第一流程实例，第一流程实例为重新启动前预设时间段内包含未成功处理的任务对应的流程实例，第一流程实例中包括至少一个未成功处理的第一任务；

202：修复第一流程实例中的所有未成功处理的第一任务，并修复第一流程实例中每个第一任务之间的先后依赖关系；

作为一种可选实施例，修复第一流程实例中的所有第一任务，并修复第一流程实例中每个第一任务之间的先后依赖关系之前，还包括：

记录重新启动前第一流程实例中的所有第一任务的状态信息，并记录重新启动前第一流程实例中每个第一任务之间的先后依赖关系的相关信息；

修复第一流程实例中的所有第一任务，并修复第一流程实例中每个第一任务之间的先后依赖关系，包括：

根据第一流程实例中的所有第一任务的状态信息修复第一流程实例中的所有第一任务，并根据第一流程实例中每个第一任务之间的先后依赖关系的相关信息修复第一流程实例中每个第一任务之间的先后依赖关系。

203：根据每个第一任务之间修复后的先后依赖关系确定第一流程实例中已修复且需要处理的第一任务，并根据已修复且需要处理的第一任务生成第一任务处理指令，第一任务处理指令中至少包括已修复且需要处理的第一任务；

作为一种可选实施例，根据每个第一任务之间修复后的先后依赖关系确定第一流程实例中已修复且需要处理的第一任务，包括：

根据每个第一任务之间修复后的先后依赖关系确定已修复的第一任务中无前序任务的第一任务，并将无前序任务的第一任务作为已修复且需要处理的第一任务。

204：将第一任务处理指令发送至第二服务器，由第二服务器接收第一任务处理指令，并根据接收到的第一任务处理指令处理任务。

作为一种可选实施例，该方法还包括：

获取当前任务流程，并根据当前任务流程生成第二流程实例，第二流程实例中包括至少一个第二任务，每个第二任务之间存在先后依赖关系；

根据每个第二任务之间的先后依赖关系确定第二流程实例中需要处理的第二任务，并根据需要处理的第二任务生成第二任务处理指令，第二任务处理指令中至少包括需要处理的第二任务；

将第二任务处理指令发送至第二服务器，由第二服务器接收第二任务处理指令，并根据接收到的第二任务处理指令处理任务。

本发明实施例提供的方法，通过修复重新启动前预设时间段内未成功执行的第一流程实例中的所有未成功处理的第一任务及每个第一任务之间的先后依赖关系，根据修复后的先后依赖关系确定需要处理的第一任务，生成第一任务处理指令，将第一任务处理指令发送至第二服务器，由第二服务器根据第一任务处理指令处理任务。由于能够修复重新启动前未成功执行的第一流程实例，从而在重新启动后能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

结合上述图1所示的实施环境，本发明另一实施例提供了一种任务处理方法，参见图3，本发明实施例提供的方法流程包括：

301：接收第一服务器发送的第一任务处理指令，第一任务处理指令中至少包括已修复且需要处理的第一任务，已修复且需要处理的第一任务为第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例中的任务；

302：根据接收到的第一任务处理指令处理任务。

作为一种可选实施例，该方法还包括：

接收第一服务器发送的第二任务处理指令，第二任务处理指令中至少包括需要处理的第二任务，需要处理的第二任务为第一服务器根据当前任务流程生成的第二流程实例中的任务；

根据接收到的第二任务处理指令处理任务。

本发明实施例提供的方法，通过接收第一服务器发送的第一任务处理指令，第一任务处理指令中至少包括已修复且需要处理的第一任务，已修复且需要处理的第一任务为第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例中的任务，根据接收到的第一任务处理指令处理任务。由于第一服务器能够修复重新启动前未成功执行的第一流程实例，从而在第一服务器重新启动后第二服务器能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

结合图1及上述实施环境的内容，本发明实施例提供了一种业务处理方法，该方法涉及第一服务器及第二服务器。结合上述图2及图3对应的实施例中的内容，对本实施例提供的方法进行举例说明。参见图4，本实施例提供的方法流程包括：

401：第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例，第一流程实例为重新启动前预设时间段内包含未成功处理的任务对应的流程实例，第一流程实例中包括至少一个未成功处理的第一任务；

由于第一服务器在处理任务时，需按照任务流程进行处理。例如，以任务流程为任务流程1为例，任务流程1中任务执行的顺序为先执行任务A，再执行任务B，最后执行任务C。若确定了任务流程，并确定了任务流程的执行时间，则可确定一个流程实例。例如，若任务流程为任务流程1，且任务流程1需要在今天下午3点执行。此时，便确定了一个任务流程1的流程实例，且该流程实例中至少包括一个需要处理的任务。

另外，由于在执行上述流程实例的过程中，流程实例可能会执行失败。对应地，流程实例中的任务也会处理失败。或者，流程实例中有些任务会处理失败。因此，在执行流程实例时可能会存在执行失败的流程实例。

以上述内容作为基础，关于第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例的方式，本实施例对此不作具体限定，包括但不限于：预先将重新启动前预设时间段内未成功执行的第一流程实例进行存储；获取存储的第一流程实例。其中，预设时间段可以根据需求进行设置，本实施例对此不作具体限定。另外，第一流程实例为重新启动前预设时间段内包含未成功处理的任务对应的流程实例，为了便于叙述，本实施例中将第一流程实例中包括的未成功处理的任务称为第一任务。例如，预设时间段可以设置为一个月，则第一服务器会预先存储重新启动前一个月内未成功执行的第一流程实例，并在重新启动后获取预先存储的第一流程实例。

其中，重新启动前预设时间段内未成功执行的第一流程实例可以存储在数据库中，该数据库可以存储在除第一服务器及第二服务器之外的其它服务器中，本实施例对此不作具体限定。具体获取第一流程实例时，可从数据库中获取，本实施例对此也不作具体限定。另外，第一流程实例中可以包含未成功处理的第一任务，还可以包含第一任务之间的先后依赖关系，本实施例对此不作具体限定。

402：第一服务器修复第一流程实例中的所有未成功处理的第一任务，并修复第一流程实例中每个第一任务之间的先后依赖关系；

在上述步骤401中，由于在数据库中存储有未成功执行的流程实例，且未成功执行的流程实例中包含着未成功处理的第一任务，而这些任务在第一服务器重启前均已置入内存并等待被处理。因此，需将这些未成功处理的第一任务重新恢复至第一服务器重启前的状态，即需要对未成功处理的第一任务进行修复。

本实施例不对第一服务器修复第一流程实例中的所有未成功处理的第一任务实例的方式作具体限定，包括但不限于：获取第一流程实例中的第一任务对应的任务实例对象，将第一任务对应的任务实例对象重新置入内存中。其中，任务实例对象可以包含第一任务的执行代码，第一任务的执行时间及第一任务的其它相关信息，本实施例不对任务实例对象的内容作具体限定。

例如，以第一流程实例中包含有第一任务A为例。从数据库中取出第一流程实例后，可获取第一流程实例中第一任务A对应的任务实例对象，并将第一任务A对应的任务实例对象重新置入内存中。其中，第一任务A对应的任务实例对象中可以包含第一任务A的执行代码，还可以包含第一任务A的执行时间等相关信息。

另外，由于第一流程实例中除了包括未成功处理的第一任务之外，还包括每个第一任务之间的先后依赖关系，即每个第一任务的前序任务与后序任务分别是哪些任务。因此，除了对第一流程实例中每个第一任务进行修复外，还需要对第一流程实例中每个第一任务之间的先后依赖关系进行修复。

为了便于对第一流程实例中每个第一任务之间的先后依赖关系进行修复，数据库中可以记录第一服务器在重新启动前第一流程实例中每个第一任务之间的先后依赖关系的相关信息，本实施例对此不作具体限定。其中，每个第一任务之间的先后依赖关系的相关信息中可以包含每个第一任务的前序任务或后序任务的任务标识，本实施例对此也不作具体限定。

以上述内容为基础，本实施例不对第一服务器修复第一流程实例中每个第一任务之间的先后依赖关系的方式作具体限定，包括但不限于：将第一流程实例中每个第一任务之间的先后依赖关系的相关信息置入内存中，其中，每个第一任务均有对应的先后依赖关系。

例如，以任务A，任务B及任务C，且任务执行的顺序为先执行任务A，再执行任务B，最后执行任务C为例。此时，任务之间的先后依赖关系的相关信息可以如下表所示：

表1

任务	前序任务	后序任务
			A	空	B
B	A	C

C	B	空
			……	……	……

其中，任务A的前序任务的任务标识为空，任务A的后序任务的任务标识为B，任务B的前序任务的任务标识为A，任务B的后序任务的任务标识为C，任务C的前序任务的任务标识为B，任务A的后序任务的任务标识为空。上表1在第一服务器重启前可存储在数据库中，当需要修复第一流程实例中每个第一任务之间的先后依赖关系时，可从数据库中获取第一任务之间的先后依赖关系的相关信息以进行修复。

例如，根据表1可确定任务A的前序任务为空，后续任务为任务B。因此，当任务A对应的执行代码重新置入内存后，可确定内存中任务A的前序任务的任务标识为空，任务A的后序任务的任务标识为B。

403：第一服务器根据每个第一任务之间修复后的先后依赖关系确定第一流程实例中已修复且需要处理的第一任务，并根据已修复且需要处理的第一任务生成第一任务处理指令，第一任务处理指令中至少包括已修复且需要处理的第一任务；

关于第一服务器根据每个第一任务之间修复后的先后依赖关系确定第一流程实例中已修复且需要处理的第一任务的方式，本实施例对此不作具体限定，包括但不限于：根据每个第一任务之间修复后的先后依赖关系确定已修复的第一任务中无前序任务的第一任务，并将无前序任务的第一任务作为已修复且需要处理的第一任务。

例如，以任务之间修复后的先后依赖关系为上面表1中的内容为例，表1对应的任务执行顺序为先执行任务A，再执行任务B，最后执行任务C。根据表1中的内容可确定无前序任务的第一任务为任务A，可将任务A作为已修复且需要处理的第一任务。

需要说明的是，根据每个第一任务之间修复后的先后依赖关系确定已修复的第一任务中无前序任务的第一任务的个数可能会有多个，此时，确定的多个第一任务均为已修复且需要处理的第一任务。

通过上述修复过程，能让第一服务器中的流程实例恢复到重新启动前的状态，使执行任务不受重新启动的影响，从而能保证调度系统的高可用性。另外，在确定第一流程实例中已修复且需要处理的第一任务后，可根据已修复且需要处理的第一任务生成第一任务处理指令。其中，第一任务处理指令中至少包括已修复且需要处理的第一任务，本实施例对此不作具体限定。

另外，由于在对已修复的第一任务进行处理之前，可能需要满足一定环境条件，才能对已修复的第一任务进行处理。因此，在确定第一流程实例中已修复且需要处理的第一任务后，可检测当前环境是否满足已修复且需要处理的第一任务的运行条件，本实施例对此不作具体限定。例如，可检测处理任务的服务器当前是否在可处理任务的状态等。若当前环境满足已修复且需要处理的第一任务的运行条件，则可生成对应的第一任务处理指令。

404：第一服务器将第一任务处理指令发送至第二服务器；

本实施例不对第一服务器将第一任务处理指令发送至第二服务器的方式作具体限定，包括但不限于：通过以HTTP(HyperText Transfer Protocol，超文本传输协议)请求的方式向第二服务器发送第一任务指令。

405：第二服务器接收第一任务处理指令，并根据接收到的第一任务处理指令处理任务；

本实施例不对第二服务器接收第一任务处理指令的方式作具体限定，包括但不限于根据第一服务器发送第一任务处理指令的方式进行接收，如通过接收第一服务器发送的HTTP请求来接收第一任务处理指令。第二服务器在接收到第一任务处理指令后，可根据接收到的第一任务处理指令处理任务。

上述步骤401至405为通过第一服务器与第二服务器之间的交互实现对已修复的第一任务进行处理的方法过程。可选地，在实际情况中，除了对已修复的任务进行处理之外，可能还需要对当前任务进行处理。针对该种情况，本实施例还提供了一种对当前任务进行处理的方法，具体过程详见后续步骤。

406：第一服务器获取当前任务流程，并根据当前任务流程生成第二流程实例，第二流程实例中包括至少一个第二任务，每个第二任务之间存在先后依赖关系；

本实施例不对第一服务器获取当前任务流程的方式作具体限定，包括但不限于：接收当前任务流程对应的流程指令；根据流程指令获取当前任务流程。

其中，任务流程可由相关人员进行设计并存储在除第一服务器及第二服务器之外的其它服务器中，存储有任务流程的服务器可向第一服务器发送当前任务流程对应的流程指令，并由第一服务器接收流程指令，本实施例对此不作具体限定。可选地，存储有任务流程的服务器还可以预先设置管理后台，相关人员通过管理后台能够监控第一服务器对任务流程的调度情况，本实施例对此不作具体限定。

另外，根据上述步骤401中的内容可知，确定了任务流程，并在确定任务流程的执行时间后，即可确定一个流程实例。因此，第一服务器在获取当前任务流程后，确定当前任务流程的执行时间，即可生成对应的第二流程实例。例如，若当前任务流程为任务流程1，而任务流程1的执行时间为下午2点，则可生成对应的第二流程实例1。

其中，第二流程实例中包括至少一个第二任务，本实施例不对第二流程实例中的任务个数作具体限定。每个第二任务之间存在先后依赖关系，先后依赖关系的内容具体可参考上述步骤402，此处不再赘述。

407：第一服务器根据每个第二任务之间的先后依赖关系确定第二流程实例中需要处理的第二任务，并根据需要处理的第二任务生成第二任务处理指令，第二任务处理指令中至少包括需要处理的第二任务；

本实施例不对第一服务器根据每个第二任务之间的先后依赖关系确定第二流程实例中需要处理的第二任务的方式作具体限定，包括但不限于：根据每个第二任务之间的先后依赖关系确定第二任务中无前序任务的第二任务，并将无前序任务的第二任务作为需要处理的第二任务。

在确定第二流程实例中需要处理的第二任务后，可根据需要处理的第二任务生成第二任务处理指令。其中，第二任务处理指令中至少包括需要处理的第二任务，本实施例对此不作具体限定。

408：第一服务器将第二任务处理指令发送至第二服务器；

本实施例不对第一服务器将第二任务处理指令发送至第二服务器的方式作具体限定，具体过程可参考上述步骤404中的内容，此处不再赘述。

409：第二服务器接收第二任务处理指令，并根据接收到的第二任务处理指令处理任务。

本实施例不对第二服务器接收第二任务处理指令的方式作具体限定，具体过程可参考上述步骤405中的内容，此处不再赘述。

需要说明的是，在上述步骤405以及在本步骤中，第二服务器在处理任务时，可采用同步处理的方式，也可以采用异步处理的方式，本实施例对此不作具体限定。其中，同步处理指的是第二服务器接收第一服务器发送的任务处理指令，并根据任务处理指令处理任务，第一服务器等到第二服务器在处理完该任务处理指令对应的任务后，再向第二服务器发送下一条任务处理指令。而异步处理指的是第一服务器负责向第二服务器发送任务处理指令，而不管第二服务器任务处理的情况，第二服务器负责根据任务处理指令处理任务。

当第二服务器采用异步处理的方式处理任务时，由于不用考虑第一服务器发送过来的任务处理指令的数量，运行时不需要依赖于第一服务器的控制。因此，第一服务器可以随时进行重新启动，即第一服务器若出现了宕机等情形需要重新启动，也不会影响第二服务器执行任务，从而保证了任务调度系统的高可用性。

另外，在上述步骤405以及在本步骤中，第二服务器在处理完任务后，可将该任务的处理情况写入到用于存储任务处理情况的数据库中，本实施例对此不作具体限定。由于第二服务器每次处理完一个任务，流程实例中的任务之间的先后依赖关系的相关信息可能会发生改变。因此，在上述步骤403及步骤407中，第一服务器在确定流程实例中需要处理的任务时，可读取数据库中的任务处理情况，根据读取到的任务处理情况修改任务之间的先后依赖关系的相关信息，从而根据修改后的任务之间的先后依赖关系的相关信息再次确定下一个需要处理的任务，本实施例对此不作具体限定。

例如，以任务执行的顺序为先执行任务A，再执行任务B，最后执行任务C为例。此时，任务之间的先后依赖关系的相关信息可以如上面表1所示。当任务A处理成功后，第二服务器会根据读取到的任务A的任务处理情况修改任务之间的先后依赖关系的相关信息，修改后的内容可如下面的表2所示：

表2

任务	前序任务	后序任务
			B	空	C
C	B	空
			……	……	……

此时，第一服务器再确定当前需要处理的任务时，可确定任务B为无前序任务的任务，并将任务B作为当前需要处理的任务。

可选地，第二服务器在处理完任务后，还可将任务的执行日志存储在本地中，本实施例对此不作具体限定。其中，任务的执行日志可以包括但不限于任务处理的起始时间，任务处理的耗时等，本实施例对此也不作具体限定。

需要说明的是，上述步骤401至405为处理修复任务的方法过程，步骤406至409为处理当前任务的方法过程。在具体实施本实施例提供的方法时，可先执行上述步骤401至405中的内容，再执行步骤406至409中的内容。或者，还可以先执行步骤406至409中的内容，再执行步骤401至405中的内容，本实施例对此不作具体限定。

本发明实施例提供的方法，通过第一服务器修复重新启动前预设时间段内未成功执行的第一流程实例中的所有未成功处理的第一任务及每个第一任务之间的先后依赖关系，根据修复后的先后依赖关系确定需要处理的第一任务，生成第一任务处理指令，将第一任务处理指令发送至第二服务器，由第二服务器根据第一任务处理指令处理任务。由于能够修复重新启动前未成功执行的第一流程实例，从而在重新启动后能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

本发明另一实施例提供了一种任务处理装置，该装置用于执行上述各个实施例中任一实施例提供的方法中第一服务器所执行的功能。参见图5，该任务处理装置包括：

第一获取模块501，用于获取重新启动前预设时间段内未成功执行的第一流程实例，第一流程实例为重新启动前预设时间段内包含未成功处理的任务对应的流程实例，第一流程实例中包括至少一个未成功处理的第一任务；

修复模块502，用于修复第一流程实例中的所有未成功处理的第一任务，并修复第一流程实例中每个第一任务之间的先后依赖关系；

第一确定模块503，用于根据每个第一任务之间修复后的先后依赖关系确定第一流程实例中已修复且需要处理的第一任务；

第一生成模块504，用于根据已修复且需要处理的第一任务生成第一任务处理指令，第一任务处理指令中至少包括已修复且需要处理的第一任务；

第一发送模块505，用于将第一任务处理指令发送至第二服务器，由第二服务器接收第一任务处理指令，并根据接收到的第一任务处理指令处理任务。

作为一种可选实施例，第一确定模块503，用于根据每个第一任务之间修复后的先后依赖关系确定已修复的第一任务中无前序任务的第一任务，并将无前序任务的第一任务作为已修复且需要处理的第一任务。

作为一种可选实施例，参见图6，该装置还包括：

记录模块506，用于记录重新启动前第一流程实例中的所有第一任务的状态信息，并记录重新启动前第一流程实例中每个第一任务之间的先后依赖关系的相关信息；

该修复模块502，用于根据第一流程实例中的所有第一任务的状态信息修复第一流程实例中的所有第一任务，并根据第一流程实例中每个第一任务之间的先后依赖关系的相关信息修复第一流程实例中每个第一任务之间的先后依赖关系。

作为一种可选实施例，参见图7，该装置还包括：

第二获取模块507，用于获取当前任务流程，并根据当前任务流程生成第二流程实例，第二流程实例中包括至少一个第二任务，每个第二任务之间存在先后依赖关系；

第二确定模块508，用于根据每个第二任务之间的先后依赖关系确定第二流程实例中需要处理的第二任务；

第二生成模块509，用于根据需要处理的第二任务生成第二任务处理指令，第二任务处理指令中至少包括需要处理的第二任务；

第二发送模块510，用于将第二任务处理指令发送至第二服务器，由第二服务器接收第二任务处理指令，并根据接收到的第二任务处理指令处理任务。

本发明实施例提供的装置，通过修复重新启动前预设时间段内未成功执行的第一流程实例中的所有未成功处理的第一任务及每个第一任务之间的先后依赖关系，根据修复后的先后依赖关系确定需要处理的第一任务，生成第一任务处理指令，将第一任务处理指令发送至第二服务器，由第二服务器根据第一任务处理指令处理任务。由于能够修复重新启动前未成功执行的第一流程实例，从而在重新启动后能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

图8是根据一示例性实施例示出的一种服务器1900的框图。例如，服务器1900可以被提供为一服务器。参照图8，服务器1900包括处理组件1922，其进一步包括一个或多个处理器，以及由存储器1932所代表的存储器资源，用于存储可由处理部件1922的执行的指令，例如应用程序。存储器1932中存储的应用程序可以包括一个或一个以上的每一个对应于一组指令的模块。此外，处理组件1922被配置为执行指令，以执行上述各个实施例中信息统计设备所执行的方法。

服务器1900还可以包括一个电源组件1926被配置为执行服务器1900的电源管理，一个有线或无线网络接口1950被配置为将服务器1900连接到网络，和一个输入输出(I/O)接口1958。服务器1900可以操作基于存储在存储器1932的操作系统，例如WindowsServerTM，Mac OS XTM，UnixTM,LinuxTM，FreeBSDTM或类似。

本发明实施例提供的服务器，通过修复重新启动前预设时间段内未成功执行的第一流程实例中的所有未成功处理的第一任务及每个第一任务之间的先后依赖关系，根据修复后的先后依赖关系确定需要处理的第一任务，生成第一任务处理指令，将第一任务处理指令发送至第二服务器，由第二服务器根据第一任务处理指令处理任务。由于能够修复重新启动前未成功执行的第一流程实例，从而在重新启动后能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

本发明另一实施例提供了一种任务处理装置，该装置用于执行上述各个实施例中任一实施例的方法中第二服务器所执行的功能。参见图9，该任务处理装置包括：

第一接收模块601，用于接收第一服务器发送的第一任务处理指令，第一任务处理指令中至少包括已修复且需要处理的第一任务，已修复且需要处理的第一任务为第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例中的任务；

第一处理模块602，用于根据接收到的第一任务处理指令处理任务。

作为一种可选实施例，参见图10，该装置还包括：

第二接收模块603，用于接收第一服务器发送的第二任务处理指令，第二任务处理指令中至少包括需要处理的第二任务，需要处理的第二任务为第一服务器根据当前任务流程生成的第二流程实例中的任务；

第二处理模块604，用于根据接收到的第二任务处理指令处理任务。

本发明实施例提供的装置，通过接收第一服务器发送的第一任务处理指令，第一任务处理指令中至少包括已修复且需要处理的第一任务，已修复且需要处理的第一任务为第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例中的任务，根据接收到的第一任务处理指令处理任务。由于第一服务器能够修复重新启动前未成功执行的第一流程实例，从而在第一服务器重新启动后第二服务器能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

图11是根据一示例性实施例示出的一种服务器2000的框图。例如，服务器2000可以被提供为一服务器。参照图11，服务器2000包括处理组件2022，其进一步包括一个或多个处理器，以及由存储器2032所代表的存储器资源，用于存储可由处理部件2022的执行的指令，例如应用程序。存储器2032中存储的应用程序可以包括一个或一个以上的每一个对应于一组指令的模块。此外，处理组件2022被配置为执行指令，以执行上述各个实施例中信息统计设备所执行的方法。

服务器2000还可以包括一个电源组件2026被配置为执行服务器2000的电源管理，一个有线或无线网络接口2050被配置为将服务器2000连接到网络，和一个输入输出(I/O)接口2058。服务器2000可以操作基于存储在存储器2032的操作系统，例如WindowsServerTM，Mac OS XTM，UnixTM,LinuxTM，FreeBSDTM或类似。

本发明实施例提供的服务器，通过接收第一服务器发送的第一任务处理指令，第一任务处理指令中至少包括已修复且需要处理的第一任务，已修复且需要处理的第一任务为第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例中的任务，根据接收到的第一任务处理指令处理任务。由于第一服务器能够修复重新启动前未成功执行的第一流程实例，从而在第一服务器重新启动后第二服务器能重新处理第一流程实例中的任务。因此，处理任务的可用性较高，稳定性较好。

需要说明的是：上述实施例提供的任务处理装置在处理任务时，仅以上述各功能模块的划分进行举例说明，实际应用中，可以根据需要而将上述功能分配由不同的功能模块完成，即将装置的内部结构划分成不同的功能模块，以完成以上描述的全部或者部分功能。另外，上述实施例提供的任务处理装置与任务处理方法实施例属于同一构思，其具体实现过程详见方法实施例，这里不再赘述。

上述本发明实施例序号仅仅为了描述，不代表实施例的优劣。

本领域普通技术人员可以理解实现上述实施例的全部或部分步骤可以通过硬件来完成，也可以通过程序来指令相关的硬件完成，所述的程序可以存储于一种计算机可读存储介质中，上述提到的存储介质可以是只读存储器，磁盘或光盘等。

以上所述仅为本发明的较佳实施例，并不用以限制本发明，凡在本发明的精神和原则之内，所作的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。

Claims (12)

1.一种任务处理方法，其特征在于，所述方法包括：

获取重新启动前预设时间段内未成功执行的第一流程实例，所述第一流程实例为重新启动前预设时间段内包含未成功处理的任务对应的流程实例，所述第一流程实例中包括至少一个未成功处理的第一任务；

修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系；

根据每个第一任务之间修复后的先后依赖关系确定所述第一流程实例中已修复且需要处理的第一任务，并根据已修复且需要处理的第一任务生成第一任务处理指令，所述第一任务处理指令中至少包括已修复且需要处理的第一任务；

将所述第一任务处理指令发送至第二服务器，由所述第二服务器接收第一任务处理指令，并根据接收到的第一任务处理指令处理任务；

其中，所述修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系，包括：

将第一任务对应的任务实例对象以及第一任务之间的先后依赖关系的相关信息重新置入内存中，使第一任务重新恢复至第一服务器重启前的状态。

2.根据权利要求1所述的方法，其特征在于，所述根据每个第一任务之间修复后的先后依赖关系确定所述第一流程实例中已修复且需要处理的第一任务，包括：

根据每个第一任务之间修复后的先后依赖关系确定已修复的第一任务中无前序任务的第一任务，并将无前序任务的第一任务作为已修复且需要处理的第一任务。

3.根据权利要求1所述的方法，其特征在于，所述修复所述第一流程实例中的所有第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系之前，还包括：

记录重新启动前所述第一流程实例中的所有第一任务的状态信息，并记录重新启动前所述第一流程实例中每个第一任务之间的先后依赖关系的相关信息；

所述修复所述第一流程实例中的所有第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系，包括：

根据所述第一流程实例中的所有第一任务的状态信息修复所述第一流程实例中的所有第一任务，并根据所述第一流程实例中每个第一任务之间的先后依赖关系的相关信息修复所述第一流程实例中每个第一任务之间的先后依赖关系。

4.根据权利要求1所述的方法，其特征在于，所述方法还包括：

获取当前任务流程，并根据当前任务流程生成第二流程实例，所述第二流程实例中包括至少一个第二任务，每个第二任务之间存在先后依赖关系；

根据每个第二任务之间的先后依赖关系确定所述第二流程实例中需要处理的第二任务，并根据需要处理的第二任务生成第二任务处理指令，所述第二任务处理指令中至少包括需要处理的第二任务；

将所述第二任务处理指令发送至第二服务器，由所述第二服务器接收第二任务处理指令，并根据接收到的第二任务处理指令处理任务。

5.一种任务处理方法，其特征在于，所述方法包括：

接收第一服务器发送的第一任务处理指令，所述第一任务处理指令中至少包括已修复且需要处理的第一任务，所述已修复且需要处理的第一任务为所述第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例，修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系之后，根据每个第一任务之间修复后的先后依赖关系从所述第一流程实例中确定的，其中，所述第一服务器修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系，包括：将第一任务对应的任务实例对象以及第一任务之间的先后依赖关系的相关信息重新置入内存中，使第一任务重新恢复至第一服务器重启前的状态；

根据接收到的第一任务处理指令处理任务。

6.根据权利要求5所述的方法，其特征在于，所述方法还包括：

接收第一服务器发送的第二任务处理指令，所述第二任务处理指令中至少包括需要处理的第二任务，所述需要处理的第二任务为所述第一服务器根据当前任务流程生成的第二流程实例中的任务；

根据接收到的第二任务处理指令处理任务。

7.一种任务处理装置，其特征在于，所述装置包括：

第一获取模块，用于获取重新启动前预设时间段内未成功执行的第一流程实例，所述第一流程实例为重新启动前预设时间段内包含未成功处理的任务对应的流程实例，所述第一流程实例中包括至少一个未成功处理的第一任务；

修复模块，用于修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系；

第一确定模块，用于根据每个第一任务之间修复后的先后依赖关系确定所述第一流程实例中已修复且需要处理的第一任务；

第一生成模块，用于根据已修复且需要处理的第一任务生成第一任务处理指令，所述第一任务处理指令中至少包括已修复且需要处理的第一任务；

第一发送模块，用于将所述第一任务处理指令发送至第二服务器，由所述第二服务器接收第一任务处理指令，并根据接收到的第一任务处理指令处理任务；

其中，所述修复模块修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系，包括：

将第一任务对应的任务实例对象以及第一任务之间的先后依赖关系的相关信息重新置入内存中，使第一任务重新恢复至第一服务器重启前的状态。

8.根据权利要求7所述的装置，其特征在于，所述第一确定模块，用于根据每个第一任务之间修复后的先后依赖关系确定已修复的第一任务中无前序任务的第一任务，并将无前序任务的第一任务作为已修复且需要处理的第一任务。

9.根据权利要求7所述的装置，其特征在于，所述装置还包括：

记录模块，用于记录重新启动前所述第一流程实例中的所有第一任务的状态信息，并记录重新启动前所述第一流程实例中每个第一任务之间的先后依赖关系的相关信息；

所述修复模块，用于根据所述第一流程实例中的所有第一任务的状态信息修复所述第一流程实例中的所有第一任务，并根据所述第一流程实例中每个第一任务之间的先后依赖关系的相关信息修复所述第一流程实例中每个第一任务之间的先后依赖关系。

10.根据权利要求7所述的装置，其特征在于，所述装置还包括：

第二获取模块，用于获取当前任务流程，并根据当前任务流程生成第二流程实例，所述第二流程实例中包括至少一个第二任务，每个第二任务之间存在先后依赖关系；

第二确定模块，用于根据每个第二任务之间的先后依赖关系确定所述第二流程实例中需要处理的第二任务；

第二生成模块，用于根据需要处理的第二任务生成第二任务处理指令，所述第二任务处理指令中至少包括需要处理的第二任务；

第二发送模块，用于将所述第二任务处理指令发送至第二服务器，由所述第二服务器接收第二任务处理指令，并根据接收到的第二任务处理指令处理任务。

11.一种任务处理装置，其特征在于，所述装置包括：

第一接收模块，用于接收第一服务器发送的第一任务处理指令，所述第一任务处理指令中至少包括已修复且需要处理的第一任务，所述已修复且需要处理的第一任务为所述第一服务器获取重新启动前预设时间段内未成功执行的第一流程实例，修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系之后，根据每个第一任务之间修复后的先后依赖关系从所述第一流程实例中确定的，其中，所述第一服务器修复所述第一流程实例中的所有未成功处理的第一任务，并修复所述第一流程实例中每个第一任务之间的先后依赖关系，包括：将第一任务对应的任务实例对象以及第一任务之间的先后依赖关系的相关信息重新置入内存中，使第一任务重新恢复至第一服务器重启前的状态；

第一处理模块，用于根据接收到的第一任务处理指令处理任务。

12.根据权利要求11所述的装置，其特征在于，所述装置还包括：

第二接收模块，用于接收第一服务器发送的第二任务处理指令，所述第二任务处理指令中至少包括需要处理的第二任务，所述需要处理的第二任务为所述第一服务器根据当前任务流程生成的第二流程实例中的任务；

第二处理模块，用于根据接收到的第二任务处理指令处理任务。