疯狂Activiti6连载（11）Activiti6的流程控制逻辑

本文节选自《疯狂工作流讲义（第2版）》流程控制逻辑本小节将以一个简单的例子，讲述Activiti关于流程处理的逻辑。概述在Activiti5以及jBPM4，对流程的控制使用的是流程虚拟机这套API，英文为ProcessVirtual Machine，简称PVM。PVM将流程中的各种元素抽象出来，形成了一套JavaAPI。新发布的Ac

杨大仙的程序空间

1133人浏览 · 2017-11-03 13:26:48

杨大仙的程序空间 · 2017-11-03 13:26:48 发布

本文节选自《疯狂工作流讲义（第2版）》

京东购买地址：https://item.jd.com/12246565.html

工作流Activiti6电子书：http://blog.csdn.net/boxiong86/article/details/78488562

工作流Activiti6教学视频：http://blog.csdn.net/boxiong86/article/details/78608585

流程控制逻辑

本小节将以一个简单的例子，讲述Activiti关于流程处理的逻辑。

概述

在Activiti5以及jBPM4，对流程的控制使用的是流程虚拟机这套API，英文为Process Virtual Machine，简称PVM。PVM将流程中的各种元素抽象出来，形成了一套Java API。

新发布的Activiti6.0版本中，PVM及相关的API已经被移除，取而代之的是一套全新的逻辑，本小节将以一个例子，讲述这套全新逻辑，是如何进行流程控制的，本小节的案例，目的是为了让读者了解新版本Activiti是如何进行流程控制的。

设计流程对象

基于BPMN规范，Activiti创建了对应的模型，由于BPMN规范过于庞杂，为了简单起见，在本例中，我们也先创建自己的规范。代码清单18-1为一份定义我们自己流程的XML文档。

代码清单18-1：codes\18\18.1\my-bpmn\resource\myBpmn.xml

<?xml version="1.0" encoding="UTF-8"?>

<flows>

</flows>

<nodes>

</nodes>

</process>

代码清单18-1是一份自定义的XML文档，process元素下有一个start节点、end节点、nodes节点以及flows节点，设计对应的Java对象来表示这些节点，代码清单18-2为这些Java类的代码。

代码清单18-2：codes\18\18.1\my-bpmn\src\org\crazyit\activiti\xml

public class BaseElement {

// XML元素的ID

private String id;

...省略setter和getter方法

}

public class FlowElement extends BaseElement {

}

public class FlowNode extends FlowElement {

//流程出口

private SequenceFlow outgoFlow;

//流程入口

private SequenceFlow incomeFlow;

//流程节点的行为

private BehaviorInterface behavior;

...省略getter和setter方法

}

public class Start extends FlowNode {

}

public class End extends FlowNode {

}

public class Task extends FlowNode {

}

public class SequenceFlow extends FlowElement {

private String source;

private String target;

...省略setter和getter方法

}

代码清单18-2中的几个类，分别对应流程XML文件中的几个节点，实际上，Activiti也有一套类似的模型，用于表示BPMN规范中的XML元素。注意FlowNode类中维护一个节点行为的对象，该对象在11.3小节讲述。除了以上的几个类外，还要创建表示流程的类与表示执行流的类，如代码清单18-3所示。

代码清单18-3：

codes\18\18.1\my-bpmn\src\org\crazyit\activiti\xml\MyProcess.java

codes\18\18.1\my-bpmn\src\org\crazyit\activiti\MyExecution.java

public class MyProcess extends BaseElement {

//开始节点

private Start start;

//结束节点

private End end;

//多个顺序流节点

private List<SequenceFlow> flows;

//多个节点

private List<FlowNode> nodes;

...省略setter和getter方法

}

public class MyExecution {

//执行流的当前节点

private FlowNode currentNode;

private MyProcess process;

...省略getter和setter方法

}

在MyExecution类中，维护一个当前执行流的节点对象，表示当前执行流所到达的节点。我们定义的流程规范中，只允许有一个开始事件和一个结束事件，允许出现多个顺序流节点和多个流程节点。接下来，为这些流程节点创建它们的行为类。

创建流程节点行为

新建一个行为接口，表示流程节点所需要执行的行为，本例中只有两个行为实现：流程开始行为与任务行为，源文件如代码清单18-4所示。

代码清单18-4：codes\18\18.1\my-bpmn\src\org\crazyit\activiti\behavior

public interface BehaviorInterface {

/**

*行为执行方法

void execute(MyExecution exe);

}

// 开始行为

public class StartBehavior implements BehaviorInterface {

public void execute(MyExecution exe) {

System.out.println("执行开始节点");

//获取当前节点

FlowNode currentNode = exe.getCurrentNode();

//获取顺序流

SequenceFlow outgoFlow = currentNode.getOutgoFlow();

//设置下一节点

FlowNode nextNode = exe.getProcess().getNode(outgoFlow.getTarget());

exe.setCurrentNode(nextNode);

}

// 任务行为

public class TaskBehavior implements BehaviorInterface {

public void execute(MyExecution exe) {

System.out.println("执行任务节点");

//获取当前节点

FlowNode currentNode = exe.getCurrentNode();

//获取顺序流

SequenceFlow outgoFlow= currentNode.getOutgoFlow();

//获取下一个节点

FlowNode targetNode = exe.getProcess().getNode(outgoFlow.getTarget());

//设置当前节点

exe.setCurrentNode(targetNode);

}

代码清单中的StartBehavior，在流程节点执行时，会自动将当前节点设置为下一个节点。注意获取下一个节点，是通过SequenceFlow对象进行的。在模型中，顺序流是连接两个流程节点的桥梁，因此SequenceFlow知道流程将要往哪里走。

编写业务处理类

业务处理类类似Activiti的服务组件，本例的服务组件只提供启动流程、完成任务这两个业务方法，用于观察流程走向。代码清单18-5为本例的服务组件。

代码清单18-5：codes\18\18.1\my-bpmn\src\org\crazyit\activiti\service\MyRuntimeService.java

public class MyRuntimeService {

/**

*启动流程的方法

public MyExecution startProcess(MyProcess process) {

//创建执行流

MyExecution exe = new MyExecution();

exe.setProcess(process);

Start startNode = process.getStart();

//设置流程当前节点

exe.setCurrentNode(startNode);

//让流程往前进行

startNode.getBehavior().execute(exe);

return exe;

}

/**

*完成任务

public void completeTask(MyExecution exe) {

//获取当前的流程节点

FlowNode current = exe.getCurrentNode();

//执行节点的行为

current.getBehavior().execute(exe);

}

开始流程的方法，会直接创建执行流，然后获取开始节点并执行其行为。完成任务的方法，获取当前节点，再执行其行为。前面定义的两个节点行为，均是获取下一个节点，作为执行流的当前节点，即让流程向“前”执行。接下来，需要编写XML解析类，解析定义的XML文档并转换为流程对象。

流程XML转换为Java对象

本例为了简单起见，使用了XStream作为工具，将读取的XML文件转换为Java对象，代码清单18-6为XStream工具类。

代码清单18-6：codes\18\18.1\my-bpmn\src\org\crazyit\activiti\xml\XStreamUtil.java

public class XStreamUtil {

private static XStream xstream = new XStream();

static {

//配置XStream

xstream.alias("process", MyProcess.class);

xstream.alias("flow", SequenceFlow.class);

xstream.alias("task", Task.class);

xstream.alias("start", Start.class);

xstream.alias("end", End.class);

xstream.useAttributeFor(BaseElement.class, "id");

xstream.useAttributeFor(SequenceFlow.class, "source");

xstream.useAttributeFor(SequenceFlow.class, "target");

}

//将XML文件转换为Process实例

public static MyProcess toObject(File file) {

try {

FileInputStream fis = new FileInputStream(file);

MyProcess p = (MyProcess)xstream.fromXML(fis);

//初始化行为与各节点的顺序流

p.initBehavior();

p.initSequenceFlow();

fis.close();

return p;

} catch (Exception e) {

e.printStackTrace();

return null;

}

在工具类的static语句块中，定义了哪个节点转换为哪个Java类。在toObject方法中，将XML转换得到MyProcess实例后，再调用MyProcess类的initBehavior和initSequenceFlow方法，其中initBehavior方法用于初始化节点的行为，initSequenceFlow用于设置流程的执行顺序，两个方法如代码清单18-7所示。