工作流引擎在vivo营销自动化中的应用实践 | 引擎篇03

营销自动化平台可以支持不同用户生命周期的活动旅程策略配置 ，根据用户触发的不同活动行为，进行差异化的营销触达方案。同时各种类型活动的具体执行过程中也有不同的业务处理流程（比如审批流程和业务流转）。业务流程复杂多样，需求变更频繁，项目开发过程中会有以下痛点：

如何将业务逻辑从控制流中剥离出来，让产研人员更聚焦于业务的实现是需要重点解决的问题。而传统OA领域使用的是久经考验的业务流程管理解决方案 —— 工作流（Workflow）。工作流是一套工业级的解决方案，由工作流管理联盟（WfMC）制定了一系列的标准。

2.1 工作流定义

2.2 工作流参考模型

WfMC工作流管理联盟为工作流制定了参考模型，其核心就是中间的工作流引擎，工作流引擎提供流程定义工具（接口1）、给使用者提供信息查询（接口2）、调用外部应用（接口3）、整合其他工作流（接口4）和监控管理（接口5）的能力。  对于大多数工作流产品而言，重点关注的是接口1和接口2的实现。

2.3 工作流引擎关键特性

1. 流程可视化

   提供可视化的流程搭建，流程视图查看能力，以及实时观测任务运行能力。  

2. 业务可编排复用

   将公共业务进行组件化，可以支持任务的自由编排，自由搭建出适合的业务的不同流程。

3. 业务和控制分离

   将流程的控制（如流转、判断、循环、重试等）的任务交由工作流负责，让使用者聚焦于核心业务逻辑。

2.4 工作流引擎的类型

对于工作流的类型没有专门的标准，按照流程任务节点特性可以分为：

• 顺序工作流

  顺序工作流的运行方式类似一种特定的流程图，上一个流程任务完成后依次进入下一个流程任务，过程不可逆。

• 状态机工作流

  状态机工作流侧重关注的是流程任务的状态，驱使任务状态发生变化的因素一般为外部事件，即事件驱动的方式，驱使任务节点从一个状态运行到另外一个状态，节点间可逆。

• 规则驱动工作流

  侧重于节点的运转规则，基于业务规则进行工作流程的执行，在处理具有明确目标但“规则”或规范级别不同的各种项目时，规则驱动的工作流非常有用。

可以看到不同类型的工作流不是完全割裂的，状态机工作流中也可以结合着条件和规则进行操作节点转换的过程。在软件开发中，一般会考虑结合状态机和规则驱动的工作流。

2.5 工作流引擎和状态机的差异

在之前的文章里面，我们有对状态机和工作流引擎做过一次简单的对比，事实上，两者之间并不是一个完全对等的概念：

了解了工作流的基本特点和使用场景之后，我们来看一下比较流行的开源工作流引擎。   

4.1 使用开源工作流引擎的问题

1. 开源工作流最大的优势是可以借助开源的资源，开箱即用，功能全面，但是与之带来的是附带的配置和表数量比较多的维护问题。以Activiti为例，使用Activiti7.0版本至少要引入二十多张表，虽然说看似是无侵入的方式，但是系统演进和维护过程中有一定的成本。特别是业务流程实例很多的时候，开发人员需要对表逻辑有更深的把控。

   
   

2. 由于业务的客观独特性，作为业务流程组件，一般都需要根据自身业务进行二次开发适配。 比如需要根据自身组织架构，进行流程节点用户角色权限的管控；将自身的业务能力插件化，加入工作流程配置中，进行拦截回调等。

4.2 自研引擎核心设计思路

 4.2.1 引擎核心模块

回归工作流的本质， 工作流是通过预定义的流程模板，对现实活动进行实例化的过程。一个基本的工作流引擎主要包括三大核心部分：

• 流程模板创建

  根据业务规则和逻辑，创建流程模板，设置每一个节点的操作和变更路径。基于模板创建，可以延伸出流程设计器、插件式节点，多样化的模板文件格式、模板持久化等。

• 流程实例发布

  根据流程模板，创建一个流程实例，流程模板和流程实例的关系类似类和对象的关系。比如说工单系统管理员定义好一个审批流模板（流程模板），用户点击创建一个工单（流程实例）。基于流程实例发布，又可以延伸出实例实时观测，节点变迁记录回溯，实例状态持久化，失败重试，事务控制等。

• 任务流程执行

  创建好流程实例之后，流程实例只需要按照流程模板的定义独立执行各自实例的任务，不同的实例之间互不影响，完成各自实例的生命周期。

  
  

4.2.2 引擎核心设计

4.3 具体实践

public interface FlowEngine {     /**     * 根据流程定义key，参数列表启动流程实例     *     */    FlowInstance startInstance(String processDefKey, Map<String, Object> args);     /**     * 根据流程定义主键ID，参数列表执行流程任务（推动流程自动流转）     * 统一事务控制     */    void execInstance(Long instanceId, Map<String, Object> args) throws FlowAuthorityException;      /**     * 获取流程定义process服务     *     */    ProcessService process();     /**     * 获取流程实例服务     *     */    InstanceService instance();     /**     * 获取任务节点服务     *     */    TaskService task();}

public interface ProcessService {     /**     * 创建流程定义模板     *     */    void create(String definition);    /**     * 发布流程定义模板     *     */    void deploy(String fileName);     /**     * 获取流程key对应的流程定义     */    FlowProcess getProcessByDefKey(String processDefKey);}

public interface InstanceService {    /**     * 创建流程实例     *     */    FlowInstance createInstance(FlowProcess process, Map<String, Object> args);     /**     * 执行流程实例     *     * @param instanceId 流程实例id     */    void exec(Long instanceId);     /**     * 根据id获取流程实例     *     * @param instanceId     * @return     */    FlowInstance getById(Long instanceId);}

public interface TaskService {     /**     * 根据任务模型、执行对象创建新的任务     *     */    FlowTask createTask(TaskModel taskModel, Execution execution);     /**     * 完成任务     *     */    FlowTask complete(Long taskId,  Map<String, Object> args);     /**     * 获取流程实例中正在进行的任务     *     */    FlowTask getActiveTask(Long instanceId);     /**     * 获取流程实例上一个已完成的任务     *     */    FlowHistTask getLastDoneTask(Long instanceId);}

其中核心的方法就是

4.4 思考和扩展