七、 BPMN的简介
读者了解到这里,应付一般的工作流开发已经足够了。此处应该有华丽的分割线,在工作流项目中核心开发人员主要是对工作流业务设计以及实现,而初级开发人员是对业务功能的代码实现。以后将主要对流程图设计的概念和具体设计进行描述,如果你感兴趣可以继续了解。
7.1 什么是BPMN?
BPMN的全称是Business Process Model and Notation,它是一套BPM的规范,从2004年起,BPMN规范的推动有OMG组织维护,开始推出的BPMN1.0主要是对设计图中图形的设计,一经推出便受到了业务流程设计者的欢迎,后面推出了BPMN2.0。
在Eclipse IDE中点击File--->New--->Other--->搜索Activiti Diagram即可,
创建好了bpmn文件后,用xml editor打开就是如下所示,xml文件的根节点是definitions,在里面可以定义多个流程定义。虽然建议是一个流程定义文件中只有一个流程定义,方便后期的维护。在definitions里面含有属性xmlns、targetNamespace,targetNamespace的值随意。
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:activiti="http://activiti.org/bpmn" targetNamespace="Examples"> <process id="myProcess" name="My First Process"> .. </process> </definitions>
process含有两个属性:
- id:该属性是必需的,Id将会转换为ProcessDefinition的key值, 在启动流程实例的时候调用startProcessInstanceByKey方法会用到key,不过注意的是RuntimeService操作的流程定义都是最新的。
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myProcess");
需要区分 startProcessInstanceById方法传入的id是以key:version形式格式化的,不要和流程定义xml文件中的Id混淆,流程定义xml中的id仅仅是以key的形式的组成部分而已,通过processDefinition.getId()方法可以获取id,它的长度为64个字符,所以不要将流程定义的xml文件的id设置过长,以至于数据库无法生成流程定义id抛出ActivitiException。
- name:可选的属性值配置,流程引擎不会使用该值,不过一般我们都需要设置,方便设计时查看。
这里选取官方的一个例子进行实践:
设计的流程图很简单:
这个流程定义文件中包含了start event(起点,就是左边的圆圈)、end event(终点,右边的圆圈)、User Tasks(用户任务,中间两个方块)。
其中user task就是设计的任务节点,第一个user task被指定了用户组为accountancy的执行,第二个user task被指定了用户组为management的执行,使用Eclipse IDE设计的时候可以这样为两个task添加属性值:
设置好了的FinancialReportProcess.bpmn20.xml文件用xml editor打开就是这样:
1 <?xml version="1.0" encoding="UTF-8" ?> 2 <definitions id="definitions" 3 targetNamespace="http://activiti.org/bpmn20" 4 xmlns:activiti="http://activiti.org/bpmn" 5 xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" 6 xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" 7 xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" 8 xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"> 9 10 <process id="financialReport" name="Monthly financial report process"> 11 12 <startEvent id="theStart" /> 13 14 <sequenceFlow id="flow1" sourceRef="theStart" targetRef="writeReportTask" /> 15 16 <userTask id="writeReportTask" name="Write monthly financial report" > 17 <documentation> 18 Write monthly financial report for publication to shareholders. 19 </documentation> 20 <potentialOwner> 21 <resourceAssignmentExpression> 22 <formalExpression>accountancy</formalExpression> 23 </resourceAssignmentExpression> 24 </potentialOwner> 25 </userTask> 26 27 <sequenceFlow id="flow2" sourceRef="writeReportTask" targetRef="verifyReportTask" /> 28 29 <userTask id="verifyReportTask" name="Verify monthly financial report" > 30 <documentation> 31 Verify monthly financial report composed by the accountancy department. 32 This financial report is going to be sent to all the company shareholders. 33 </documentation> 34 <potentialOwner> 35 <resourceAssignmentExpression> 36 <formalExpression>management</formalExpression> 37 </resourceAssignmentExpression> 38 </potentialOwner> 39 </userTask> 40 41 <sequenceFlow id="flow3" sourceRef="verifyReportTask" targetRef="theEnd" /> 42 43 <endEvent id="theEnd" /> 44 45 </process> 46 47 <bpmndi:BPMNDiagram> 48 <bpmndi:BPMNPlane bpmnElement="financialReport"> 49 <bpmndi:BPMNShape bpmnElement="theStart"> 50 <omgdc:Bounds height="30.0" width="30.0" x="75.0" y="225.0" /> 51 </bpmndi:BPMNShape> 52 <bpmndi:BPMNShape bpmnElement="writeReportTask"> 53 <omgdc:Bounds height="80.0" width="100.0" x="165.0" y="200.0" /> 54 </bpmndi:BPMNShape> 55 <bpmndi:BPMNShape bpmnElement="verifyReportTask"> 56 <omgdc:Bounds height="80.0" width="100.0" x="330.0" y="200.0" /> 57 </bpmndi:BPMNShape> 58 <bpmndi:BPMNShape bpmnElement="theEnd"> 59 <omgdc:Bounds height="28.0" width="28.0" x="480.0" y="226.0" /> 60 </bpmndi:BPMNShape> 61 <bpmndi:BPMNEdge bpmnElement="flow1"> 62 <omgdi:waypoint x="105.0" y="240.0" /> 63 <omgdi:waypoint x="165.0" y="240.0" /> 64 </bpmndi:BPMNEdge> 65 <bpmndi:BPMNEdge bpmnElement="flow2"> 66 <omgdi:waypoint x="265.0" y="240.0" /> 67 <omgdi:waypoint x="330.0" y="240.0" /> 68 </bpmndi:BPMNEdge> 69 <bpmndi:BPMNEdge bpmnElement="flow3"> 70 <omgdi:waypoint x="430.0" y="240.0" /> 71 <omgdi:waypoint x="480.0" y="240.0" /> 72 </bpmndi:BPMNEdge> 73 </bpmndi:BPMNPlane> 74 </bpmndi:BPMNDiagram> 75 76 </definitions>
其中xml中的sequenceFlow就是流程图里面的连接线,一般我们会eclipse的流程设计图形化界面(Activiti Designer)上面设置name的属性值,方便查看。其中连线的起点和终点用sourceRef和targetRef表示。
我们创建了流程定义文件后,创建流程定义对象需要发布流程定义文件,工作流引擎做了两件事情:1.将配置文件存进数据库中。 2.将配置文件解析为内存中的java对象。
Deployment deployment = repositoryService.createDeployment() .addClasspathResource("FinancialReportProcess.bpmn20.xml") .deploy();
获取流程实例可以通过流程定义文件中的id(也就是存入数据库的记录的key)获取。
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("financialReport");
调用startProcessInstanceByKey后台会做很多事情,启动流程实例将会通过前面流程图的start event(就是第一个圆圈),流程引擎将会沿着sequence flow(就是线路,目前只有一条)到达第一个任务节点,流程引擎将会将持久化第一个任务到数据库中。这时用户或者用户组可以拾取任务(具体你需要编写代码查询有相关权限用户或者用户组和当前任务,在调用拾取的API绑定用户和任务),并将这个结果保存进数据库,这时流程引擎将会等待任务完成。可见流程实例是一路执行的除非进入等待状态。在进入等待状态时,流程引擎也会将流程实例状态保存进入数据库,如果用户完成了任务,流程引擎会继续执行下去或者到达流程的结束。即使期间发生系统重启崩溃,存入数据库的流程实例的状态也是安全有效的。
在任务被成功创建后,startProcessInstanceByKey将会返回值并且当前活动的任务处于等待状态,如果当前任务被分配给用户组,那么用户组里的成员都是执行任务的候选者。
使用TaskService可以获取任务,进一步我们可以操作任务(Task):
List<Task> tasks = taskService.createTaskQuery().taskCandidateUser("kermit").list();
因为kermit也是在用户组accountancy里面,所以可以查询出任务,至于accountancy用户组是之前我们在流程定义文件中配置过的:
<potentialOwner> <resourceAssignmentExpression> <formalExpression>accountancy</formalExpression> </resourceAssignmentExpression> </potentialOwner>
我们也可以直接使用用户组来进行查询任务:
TaskService taskService = processEngine.getTaskService(); List<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("accountancy").list();
使用Activiti Explorer项目可以帮助我们投入更多的精力在流程图的设计上面,少敲代码,点击鼠标即可验证设计图功能。具体做法是启动项目Activiti Explorer,以管理员kermit/密码kermit登录系统,点击流程--->流程设计工作区---->导入后,将上面FinancialReportProcess.bpmn20.xml文件上传,
上传的效果:列表中会有一个叫Monthly financial report process的流程
选择流程Monthly financial report process,然后在处理模型选择部署,我们设计的流程图就生效了。
部署后,我使用了用户fozzie作为本次实践的用户(为什么没选其他的用户呢,因为activiti里面有现成的用户咯),然后发现里面没有用户组accountancy,添加用户组并把用户fozzie加进用户组中:
点击管理--->组---添加组,输入如下点击添加组即可。
添加成员:
弹出框输入用户名,选择该用户 点击done即可:
退出当前用户使用账户fozzie/fozzie登录系统后,可以发现他的权限变少了(这不是重点),点击流程--->已部署的流程定义,选中Monthly financial report process点击启动流程。
这时流程实例就会生成,流程引擎将会执行到第一个user task,现在我们使用账户fozzie登录系统,会发现有一个组任务,可以看见详情:
组任务如果被拾取的话,就会在组任务中消失,相应组下面的其他用户将不能获得该任务:
taskService.claim(task.getId(), "fozzie");
fozzie用户拾取了任务,被拾取的任务现在就会成为个人任务,个人可以查询自己的任务:
List<Task> tasks = taskService.createTaskQuery().taskAssignee("fozzie").list();
在Activiti Explorer的UI页面里,上述代码可以通过点击签收按钮完成:
假如fozzie开始进行工作,现在工作完成:
taskService.complete(task.getId());
上面这段代码是Activiti工作流引擎继续执行的信号,同时完成的任务本身将会在正在运行表(ACT_RU_EXECUTION)中去除,这时任务节点流转到第二个任务上面,而在Activiti Explorer的UI页面上面就是点击完成按钮即可。第二个任务和第一个任务类似,就不再提了。
重复操作后第二个任务就完成了,现在流程引擎进入了end event,流程实例完成,然后运行表中数据清空.使用historyService可以验证流程的执行情况:
HistoryService historyService = processEngine.getHistoryService(); HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId(procId).singleResult(); System.out.println("Process instance end time: " + historicProcessInstance.getEndTime());