CN107861749B - 一种基于配置的任务单元的流程编排系统及其实现方法 - Google Patents

Abstract

本发明涉及一种基于配置的任务单元的流程编排系统及其实现方法。本发明的系统由配置的任务单元(HC‑TASK)组件、流程编排模块和任务(TASK)守护进程组成。配置的任务单元(HC‑TASK)组件，包括构成配置的任务单元(HC‑TASK)的任务基础单元和版本生成器。任务基础单元是配置的任务单元(HC‑TASK)组件的最小构成因素。流程编排模块提供版本管理和流程编排功能，以任务基础单元为中心可对单个或多个任务进行组合编排，结合版本管理，形成具有可控版本的流程。任务(TASK)守护进程提供对多个编排流程包含的任务单元进行有序任务的检测服务。本发明将任务进行流程编排，并加以版本控制，具有扩展性好、适用范围广等特点，可有效地应用于多种业务型系统中。

Description

一种基于配置的任务单元的流程编排系统及其实现方法

技术领域

本发明涉及计算机应用技术领域，特别涉及一种基于配置的任务单元的流程编排系统及其实现方法。

背景技术

随着计算机应用技术的发展，业务系统间的交互方式愈趋向于多样化。伴随着业务的复杂化及不确定因素，频繁的业务需求变更要求业务系统有非常好的兼容性和健壮性。传统业务系统间的交互，当一方发生的变更与原协议具有差异性时，往往需要另一方根据新协议进行配合变更。而这种配合式的交互方式，通常变更都只有代码级别的版本控制，一旦变更失败或者变更撤销，需要花费大量的开销进行版本回退。这时候更需要一种灵活度高和适用范围广的方法，可以方便快捷地对业务功能进行版本变更，并且变更范围可控。

发明内容

本发明解决的技术问题在于针对存在业务链路的系统，在某个或多个任务节点存在变更需求时，变更的开销、回撤预防以及范围控制等方面存在不可控风险的问题，提供一种基于配置的任务单元的流程编排系统。

本发明解决的另一技术问题在于提供一种基于配置的任务单元的流程编排系统的实现方法。

本发明解决上述技术问题之一的技术方案是：

所述的系统由HC-TASK组件、流程编排模块和TASK守护进程组成，并提供相应的开发和集成接口；

所述的HC-TASK组件，包括构成HC-TASK的任务基础单元和版本生成器；任务基础单元，是HC-TASK组件的最小构成因素；版本生成器提供版本号生成服务；HC-TASK存放了任务的版本信息；

流程编排模块统一管理任务单元，根据业务需求对任务基础单元进行编排；任务单元可自由搭配生成带版本信息的流程链路；

TASK守护进程，提供对多个编排流程包含的任务单元进行有序任务的检测服务。

所述的HC-TASK是配置的任务单元，可通过HC-TASK组件进行配置组装。

所述的任务基础单元包括了任务ID、任务类型、版本号、时间戳和状态五种元素；

所述的版本生成器在维护任务基础单元的过程中，由系统对同任务ID的基础单元进行加锁，按照时间戳的先后顺序，对最新版本的版本号进行累计，并生成新的版本号。

所述的流程编排模块，负责对任务基础单元生成头结点和尾节点，并根据业务需求对任务基础单元进行编排；单个任务流程可对应一个或多个任务基础单元，每个任务都以“头结点+任务ID+版本+尾节点”的形式生成流程链路；

流程编排模块提供CRUD访问接口，用于查询、维护流程链路以及切换流程链路中的TASK版本。

本发明解决上述技术问题之二的技术方案是：

所述的方法包括新建任务基础单元和维护现有任务基础单元；

新建基础单元的步骤是：

第一步，选择TASK生成方式：新建初始化版本HC-TASK基础单元；

第二步，系统自动生成唯一任务ID；

第三步，添加任务类型和时间戳；

第四步，保存HC-TASK基础单元，并填充初始化版本号和状态；

第五步，日志记录；

维护现有任务基础单元的步骤是：

第一步，选择TASK生成方式：选择已有版本TASK；

第二步，复用已有版本TASK的任务ID；

第三步，添加任务类型、时间戳和初始化状态；

第四步，保存HC-TASK基础单元，根据时间戳生成临时唯一标识TEMP_KEY；

第五步，调用版本生成器，传递任务ID作为参数调用服务，获取版本号；

第六步，根据临时唯一标识TEMP_KEY更新HC-TASK基础单元，进行版本填充；

第七步，日志记录。

版本生成器提供服务的流程是：

第一步，版本生成器服务处于监听状态；

第二步，版本生成器接收到服务请求，并检验任务ID真实性；

第三步，对有效的任务ID进行任务检索，并对该ID下的所有任务基础单元进行版本加锁；对无效的任务ID直接返回异常信息；

第四步，根据任务基础单元的时间戳和版本号进行比较，对最新版本的版本号进行累计；

第五步，生成新的版本号，并对该ID下的所有任务基础单元进行版本解锁；

第六步，日志记录，完成。

流程编排模块的管理流程是：

第一步，新建任务流程，生成任务流程ID；

第二步，选择一个或多个任务基础单元；

第三步，对选择的任务基础单元进行链路组装，组装关系包括任务之间的串行或者并行关系；

第四步，解析链路，并根据任务的串行或并行关系自动生成每个任务的头结点和尾节点；

第五步，将每个任务按照“头结点+任务ID+版本+尾节点”的格式存放到有序列表内，并将有序列表作为值，以键值对<K,V>的方式关联上流程ID；

第六步，保存有序列表和任务流程；

第七步，将任务流程添加至TASK守护进程队列；

第八步，日志记录，完成。

TASK守护进程的工作流程是：

第一步，守护进程处于监听状态；

第二步，守护进程按先进先出原则处理队列内的任务流程；

第三步，提取任务流程对应的有序列表，并按顺序检测任务执行状态：当同一任务ID的TASK处于执行中时，暂停当前任务链路，并添加至重复任务代办队列；否则执行当前任务，并设置任务状态为执行中；

第四步，任务执行完成后，检测重复任务代办队列内是否有同任务ID的待办项，对其进行唤醒操作，并标记相同任务为完成状态；

第五步，日志记录，完成。

本发明针对存在业务链路的系统，通过对业务功能点细化分解，转换为HC-TASK任务基础单元；以任务基础单元的形式映射细化功能点。版本生成器提供了版本号生成服务，HC-TASK存放了任务的版本信息；流程编排模块统一管理任务单元，任务单元可自由搭配生成带版本信息的流程链路。可以方便快捷地对细化的功能点进行版本切换，保证系统的稳定，预防不可控风险。TASK守护进程通过对任务流程进行监管，保障了多任务流程间的状态共享。各个组件模块紧密结合，将流程编排形成动态可维护的流程链路，保证了系统的灵活性和扩展性。

附图说明

下面结合附图对本发明进一步说明：

图1是本发明的总体结构图；

图2是本发明版本生成器提供服务的序列图；

图3是本发明服务编排模块的活动图。

具体实施方式

本发明针对存在业务链路的系统，在某个或多个任务节点存在变更需求时，变更的开销、回撤预防以及范围控制等方面存在不可控风险的问题，提供了一种基于配置的任务单元的流程编排系统。通过对业务功能点细化管理，任务流程编排，实现了方便快捷地对业务功能进行版本变更。

图1表示了本发明的总体结构图，由HC-TASK组件、流程编排模块和TASK守护进程组成。

HC-TASK：是配置的任务单元，可通过HC-TASK组件进行配置组装。

HC-TASK组件：包括构成HC-TASK的任务基础单元和版本生成器。

任务基础单元，是HC-TASK组件的最小构成因素，包括了任务ID、任务类型、版本号、时间戳和状态五种元素；任务ID和版本号的组合是基础单元的唯一标识，保证基础单元的唯一性。版本生成器，提供对同一任务ID的基础单元进行版本填充的服务。在维护任务基础单元的过程中，由系统对同任务ID的基础单元进行加锁，按照时间戳的先后顺序，对最新版本的版本号进行累计，并生成新的版本号；流程编排模块，负责对任务基础单元生成头结点和尾节点，并根据业务需求对任务基础单元进行编排。单个任务流程可对应一个或多个任务基础单元，每个任务都以“头结点+任务ID+版本+尾节点”的形式生成流程链路；当存在两个串行的任务时，上级任务尾节点对应下级任务的头结点；当存在两个或两个以上并行的任务时，视为优先级相同，头结点同时对应上级任务的尾节点；TASK守护进程，提供对多个编排流程包含的任务单元进行有序任务的检测服务。流程链路中包含的每一个HC-TASK都具有版本信息。

此外，流程编排模块提供CRUD访问接口，用于查询、维护流程链路以及切换流程链路中的TASK版本。

图2表示了版本生成器提供服务的序列图，图3表示了服务编排模块的活动图，有关的实现步骤分别如下。

版本生成器提供服务的流程是：

第一步，版本生成器服务处于监听状态；

第二步，版本生成器接收到服务请求，并检验任务ID真实性；

第三步，对有效的任务ID进行任务检索，并对该ID下的所有任务基础单元进行版本加锁；对无效的任务ID直接返回异常信息；

第四步，根据任务基础单元的时间戳和版本号进行比较，对最新版本的版本号进行累计；

第五步，生成新的版本号，并对该ID下的所有任务基础单元进行版本解锁；

第六步，日志记录，完成。

服务编排模块的管理流程是：

第一步，新建任务流程，生成任务流程ID；

第二步，选择一个或多个任务基础单元；

第三步，对选择的任务基础单元进行链路组装，组装关系包括任务之间的串行或者并行关系；

第四步，解析链路，并根据任务的串行或并行关系自动生成每个任务的头结点和尾节点；

第五步，将每个任务按照“头结点+任务ID+版本+尾节点”的格式存放到有序列表内，并将有序列表作为值，以键值对<K,V>的方式关联上流程ID；

第六步，保存有序列表和任务流程；

第七步，将任务流程添加至TASK守护进程队列；

第八步，日志记录，完成。

本发明将业务功能点细化并进行编排，具有扩展性好、适用范围广等特点，可有效地应用于多种业务型系统中。

Claims (8)

1.一种基于配置的任务单元的流程编排系统，其特征在于：所述的系统由HC-TASK组件、流程编排模块和TASK守护进程组成，并提供相应的开发和集成接口；

所述的HC-TASK组件，包括构成HC-TASK的任务基础单元和版本生成器；任务基础单元，是HC-TASK组件的最小构成因素；版本生成器提供版本号生成服务；HC-TASK存放了任务的版本信息；

流程编排模块统一管理任务单元，根据业务需求对任务基础单元进行编排；任务单元搭配生成带版本信息的流程链路；

TASK守护进程，提供对多个编排流程包含的任务单元进行有序任务的检测服务；

所述的版本生成器在维护任务基础单元的过程中，由系统对同任务ID的基础单元进行加锁，按照时间戳的先后顺序，对最新版本的版本号进行累计，并生成新的版本号；

所述的流程编排模块，负责对任务基础单元生成头结点和尾节点，并根据业务需求对任务基础单元进行编排；单个任务流程对应一个或多个任务基础单元，每个任务都以“头结点+任务ID+版本+尾节点”的形式生成流程链路；

流程编排模块提供CRUD访问接口，用于查询、维护流程链路以及切换流程链路中的TASK版本。

2.根据权利要求1所述的任务单元的流程编排系统，其特征在于：所述的HC-TASK是配置的任务单元，通过HC-TASK组件进行配置组装。

3.根据权利要求1所述的任务单元的流程编排系统，其特征在于：所述的任务基础单元包括了任务ID、任务类型、版本号、时间戳和状态五种元素。

4.一种基于权利要求1-3任一项所述的基于配置的任务单元的流程编排的方法，其特征在于：所述的方法包括新建任务基础单元和维护现有任务基础单元；

新建基础单元的步骤是：

第一步，选择TASK生成方式：新建初始化版本HC-TASK基础单元；

第二步，系统自动生成唯一任务ID；

第三步，添加任务类型和时间戳；

第四步，保存HC-TASK基础单元，并填充初始化版本号和状态；

第五步，日志记录；

维护现有任务基础单元的步骤是：

第一步，选择TASK生成方式：选择已有版本TASK；

第二步，复用已有版本TASK的任务ID；

第三步，添加任务类型、时间戳和初始化状态；

第四步，保存HC-TASK基础单元，根据时间戳生成临时唯一标识TEMP_KEY；

第五步，调用版本生成器，传递任务ID作为参数调用服务，获取版本号；

第六步，根据临时唯一标识TEMP_KEY更新HC-TASK基础单元，进行版本填充；

第七步，日志记录。

5.根据权利要求4所述的基于配置的任务单元的流程编排方法，其特征在于：

版本生成器提供服务的流程是：

第一步，版本生成器服务处于监听状态；

第二步，版本生成器接收到服务请求，并检验任务ID真实性；

第三步，对有效的任务ID进行任务检索，并对该ID下的所有任务基础单元进行版本加锁；对无效的任务ID直接返回异常信息；

第四步，根据任务基础单元的时间戳和版本号进行比较，对最新版本的版本号进行累计；

第五步，生成新的版本号，并对该ID下的所有任务基础单元进行版本解锁；

第六步，日志记录，完成。

6.根据权利要求4所述的基于配置的任务单元的流程编排方法，其特征在于：

流程编排模块的管理流程是：

第一步，新建任务流程，生成任务流程ID；

第二步，选择一个或多个任务基础单元；

第三步，对选择的任务基础单元进行链路组装，组装关系包括任务之间的串行或者并行关系；

第四步，解析链路，并根据任务的串行或并行关系自动生成每个任务的头结点和尾节点；

第五步，将每个任务按照“头结点+任务ID+版本+尾节点”的格式存放到有序列表内，并将有序列表作为值，以键值对<K,V>的方式关联上流程ID；

第六步，保存有序列表和任务流程；

第七步，将任务流程添加至TASK守护进程队列；

第八步，日志记录，完成。

7.根据权利要求5所述的基于配置的任务单元的流程编排方法，其特征在于：

流程编排模块的管理流程是：

第一步，新建任务流程，生成任务流程ID；

第二步，选择一个或多个任务基础单元；

第三步，对选择的任务基础单元进行链路组装，组装关系包括任务之间的串行或者并行关系；

第四步，解析链路，并根据任务的串行或并行关系自动生成每个任务的头结点和尾节点；

第五步，将每个任务按照“头结点+任务ID+版本+尾节点”的格式存放到有序列表内，并将有序列表作为值，以键值对<K,V>的方式关联上流程ID；

第六步，保存有序列表和任务流程；

第七步，将任务流程添加至TASK守护进程队列；

第八步，日志记录，完成。

8.根据权利要求5至7任一项所述的基于配置的任务单元的流程编排方法，其特征在于：

TASK守护进程的工作流程是：

第一步，守护进程处于监听状态；

第二步，守护进程按先进先出原则处理队列内的任务流程；

第三步，提取任务流程对应的有序列表，并按顺序检测任务执行状态：当同一任务ID的TASK处于执行中时，暂停当前任务链路，并添加至重复任务代办队列；否则执行当前任务，并设置任务状态为执行中；

第四步，任务执行完成后，检测重复任务代办队列内是否有同任务ID的待办项，对其进行唤醒操作，并标记相同任务为完成状态；

第五步，日志记录，完成。

Images