jBPM4工作流引擎 网络知识点整理汇总 提升

定义

start活动的意义在于指定了一个流程实例应该从哪里开始，即流程定义的入口。

 

start活动的子元素

<transition>用来指定流出的转移，指向流程的下一个活动。

定义

end活动的意义在于结束了一个流程实例，即流程定义的结束点。

 

特殊的end-cancel和end-error

在一些特定的流程里，需要区分到底是为什么结束的，怎么结束的。比如，前面的差旅费报销申请流程，可以被批准进而正常的结束；也可以被某位领导不批准进而被取消。在一般的流程里，不需要区分end和end-cancel，但是如果再做的精细一点，可以让不同的结果，流向不同的结束。

定义

state活动作为一个等待状态活动。

流程处理的流向会在外部调用提供的触发器API之前一直等待。与task相同的是，流程引擎会停在这里等待外界的调用；但不同的是，它不会将任务分配给某个人。

 

相关api

如果是同时只有单个state的情况，可以简单的使用：

executionService.signalExecutionById(“这里默认使用流程实例的id");

如果是同时有多个state的话，应该要先查找到Execution的id，如下使用：

ExecutionService exe =  engine.getExecutionService();

Execution e = exe.createProcessInstanceQuery()

.processInstanceId(piid).uniqueResult()

.findActiveExecutionIn(“state活动名称");

exe.signalExecutionById(e.getId());

定义

decision活动会运行并判断其中的每一个transition元素里的转移条件。当遇到一个transition的condition值为true的时候，那么流程就立即流向这个transition。

流程引擎并不会等待decision活动，它会马上执行完这个decision。

decision活动的expr属性

用一个三目运算符来判断到底要流向哪个transition。

decision活动的transition元素的condition子元素

用expr属性来判断是否流向这个transition。

decision活动的handler子元素

以上两种判断方式仍然没法完全满足我们的要求，还可以通过实现DecisionHandler接口来在java代码中决定到底到底流向哪个transition。

public class MyDecisionHandler implements DecisionHandler{
@Override
public String decide(OpenExecution execution) {
Integer age = (Integer) execution.getVariable("age");
if (age>=20){
return "yes";
}else{
return "no";
}
}
}

 

定义

task活动一般用来处理涉及人机交互的活动，流程引擎会停在这里等待人工的操作。

task活动的assignee属性

assignee属性用来指定任务分配给谁，可以使用变量来定义。

任务的候选者

candidate-users属性可以使用逗号分割的用户ID列表。所有列表中的用户会成为任务的候选者。用户想要接受这个任务，需要人工的takeTask。

相关api—领取任务

ProcessEngine processEngine = Configuration.getProcessEngine();
TaskService taskService = processEngine.getTaskService();
taskService.takeTask(“task的id”, “领取task的人员");

 

任务的候选组

candidate-groups属性可以使用逗号分割的用户组ID列表。所有列表中的用户组中的用户会成为任务的候选者。用户想要接受这个任务，需要人工的takeTask。

相关api—建立用户和用户组

ProcessEngine processEngine = Configuration.getProcessEngine();
IdentityService identityService = processEngine.getIdentityService();
 
identityService.createGroup("sales");
identityService.createUser(“zhang", “zhang", “san");
identityService.createUser(“li", “li", “si");
 
identityService.createMembership(“zhang", "sales");
identityService.createMembership(“li", "sales");

 

任务分配器

任务分配器AssignmentHandler的方式，可以说是最灵活的任务分配方式了，它支持使用java代码来指定任务的分配者。

相关api：

public class MyAssignmentHandler implements AssignmentHandler{
private String name;
public String getName() {
return name;
}
public void setName(String name) { this.name = name; }
 
public void assign(Assignable assignable, OpenExecution execution) throws Exception {
assignable.setAssignee(name);
}
}

 相应的配置示例：

<task name="task1" g="339,146,92,52">
     <assignment-handler class="cn.javass.test.task.handler.MyAssignmentHandler">
      <field name="name">
      <string value="ok"/>
      </field>
     </assignment-handler>
      <transition to="end1"/>
   </task>

 

定义

 当需要流程并发执行的时候，就需要使用到fork-join活动的组合，fork活动可以使流程在一条主干上出现并行的分支，join活动则可以使流程的并行分支聚合成一条主干。

定义

java活动可以指定一个Java类的方法，当流程执行到此活动时，马上自动执行此Java方法。

 

相关属性

class属性用来指定此Java类的全类名，要注意这个类要有public无参的默认构造方法。

method属性用来指定调用的方法。

var属性存储方法执行结果的流程变量名称。

public class MyJava {
private String user1;
private String user2;
…user1和user2的setter
public String sayHello(String arg1,String arg2){
 
System.out.println("user1=="+user1);
System.out.println("user2=="+user2);
System.out.println("arg1=="+arg1);
System.out.println("arg2=="+arg2);
 
return “Hello";
}
}

 

为Java类设置属性和为方法传递参数

在注册的时候，可以注册一个固定的值，也可以引用pi级的变量。

 <java g="246,135,92,52" name="java1" class="cn.javass.test.java.MyJava" method="sayHello" var="manager">
     <field name="user1"><object expr=“#{user1}”/></field>
     <field name="user2"><string value="user2“/></field>
     <arg><string value="xyz“/></arg>
     <arg><object expr="#{abc}“/></arg>
      <transition to="task1"/>
   </java>

 

定义

script活动可以指定一个表达式，当流程执行到此活动时，马上自动执行此表达式，默认用的是juEL。

 

相关属性

使用script活动有两种方式，一种是通过脚本表达式的方式，另外一种是通过脚本文本的方式。

1：脚本表达式的方式：就是在script活动上，使用expr属性来指定脚本表达式，用var属性来表示存储执行结果的流程变量名称。

2：脚本文本的方式：就是在script活动下添加text子活动，在text子活动里面写脚本表达式，同样使用var来表示存储执行结果的流程变量名称。

 

定义

 sql活动能够支持使用sql直接从数据库中查询数据，并将结果返回到流程变量中。

 

sql活动的属性

var属性存储sql执行结果的流程变量名称。

unique属性，此属性为true时，返回结果为一行，结果将作为一个单独的对象存储；此属性为false时，返回结果为多行，结果将作为一个Set存储。

 

sql活动的子元素

query子元素用来设置sql查询语句。

parameters子元素用来设置sql的外部参数。

Sql活动示例：

<sql g="192,438,92,52" name="sql1" unique="true" var="sqlV">
<query>
select * from tbl_user where uuid=:uuid
</query>
<parameters>
<object name="uuid" expr="#{uuid}"></object>
</parameters>
  <transition to="hql1"/>
</sql>

 

定义

 hql活动能够支持使用hql直接从数据库中查询数据，并将结果返回到流程变量中。

 

nhql活动的属性

var属性存储hql执行结果的流程变量名称。

unique属性，此属性为true时，返回结果为一行，结果将作为一个单独的对象存储；此属性为false时，返回结果为多行，结果将作为一个Set存储。

 

hql活动的子元素

query子元素用来设置hql查询语句。

parameters子元素用来设置hql的外部参数。

HQL活动示例：

<hql name="hql1" g="404,457,92,52" unique="true" var="hqlV">
<query>
select o from Parent o where o.id=:id
</query>
<parameters>
<string name="id" value="22"/>
</parameters>
  <transition to="task2"/>
</hql>

 

定义

foreach活动使得通过一条单独的流程路径来执行多条流程分支的功能。

 

相关属性

in：将被迭代的集合。集合中的每个元素会生成一个新的同步分支。in执行任意类型的集合，数组和以逗号分隔的字符串。。

var：用来保存集合中当前元素的变量。这个变量会设置到同步流程分支中，并且只对这个流程分支可见。

 

与join活动连用

通常情况下，foreach活动后面是多次执行的活动，在这个活动后面应该跟一个join活动，并且把join活动的multiplicity设置成为foreach的数量，这样才会等到foreach的多个task执行完成，流程才继续向下，否则，只要有一个foreach的task完成了，流程就向下流转了。

配置示例，如果在jPDL里面配置如下：

<foreach name="foreach1" in="D1,D2,D3" var="nowDep">
<transition to="task5"/>
</foreach>
<task name="task5">
<transition to="join1"/>
</task>
<join name="join1" multiplicity="3">
<transition to="task6"/>
</join>

 

那么当流程运行到foreach1的时候，会转移到task5活动3次，也就是会生成3个task5的实例。

获取变量示例，在task5的实例里面，如何获取自己的nowDep呢？

很简单，根据自己的task实例的id来获取变量就可以了，如下：

String nowDep = ts.getVariable(taskInstance.getId(),“nowDep”);

定义

ules是一个自动活动，它会创建一个有状态的知识会话，在它中间放入一系列事实，然后触发所有规则。这些规则可以更新或创建流程变量，以后可以在流程中使用。事实可以被指定为rules活动的子元素。

相关子元素

fact：事实，相当于规则引擎的一条规则。

fact的属性：

var：变量名，作为fact 插入的变量名称。

expr：表达式，表达式的结果会作为一个事实插入。

 var 或 expr 必填一个。

 

注意：如果一个rules 活动只有一个外向转移，就会自动使用它。 而多个外向转移可以在rules活动后面显示的使用decision活动。

 

配置示例，如果在jPDL里面配置如下：

<rules name="rule1">
<fact var="um"></fact>
<transition to="exclusive2"/>     
</rules>
<decision name="exclusive2">
<transition name="toT7" to="task7">
<condition expr="#{um.canDrink}"/>
</transition>
<transition name="toT8" to="task8">
<condition expr="#{!um.canDrink}"/>
</transition>
</decision>

 

配套的UserModel就是一个普通的VO

对应的规则文件示例如下：

rule "CheckCanDrink"

  when

    um : cn.javass.jbpm4.hello.UserModel( age > 18,uuid=="11")

  then

    um.setCanDrink( true );

end

启动流程的时候需要同步发布规则文件

rs.createDeployment().addResourceFromClasspath("cn/javass/jbpm4/hello/h2.jpdl.xml")

.addResourceFromClasspath("cn/javass/jbpm4/hello/rule1.drl")

.deploy();

在运行规则活动之前，需要设置好规则需要的变量，比如在启动流程的时候：

Map map = new HashMap();
UserModel um = new UserModel();
um.setUuid("11");
um.setAge(50);
map.put("um", um);
exe.startProcessInstanceByKey("h2",map);

 

jBPM事件机制介绍

jBPM的事件机制使得我们可以很方便的在流程、活动、任务生命周期的各个阶段插入定制的代码逻辑，以便实现特定的业务逻辑操作。正是这种机制赋予了jBPM无限的可扩展性。

事件(event)用来定位在流程执行过程中的特定的时间点，例如“流程实例开始”、“状态活动结束”等，可以在这些时间点上注册一系列的监听器。当流程的执行通过这些时间点时，监听器的代码就会被执行。

 

on活动

监听器在jpdl中可以被定为on活动。

on活动的event属性{start|end}指明了监听器是在进入还是结束时触发。

on活动的作用范围

on活动作为谁的子活动，就是为谁定义开始或结束事件，常见的活动，都可以定义为on的父活动。

比如on活动作为<process>的子活动，就表示监听流程的开始或结束。

on活动作为一些活动活动的子活动，如<state>、<task>、<decision>，表示监听这个活动的开始或结束。

on活动的子活动

on活动的子活动用来表示：当监听事件发生的时候，都可以触发什么样的“自定义代码”。

 典型的为<event-listener>，可以注册一个实现了EventListener接口的类。其他一些典型的自动活动(流程引擎不会停下来等的活动)，也可以作为on活动的子活动。如前面学过的<java>、<sql>和<hql>。

 

监听器还可以作为<transition>元素的子元素

<event-listener>、<java>、<sql>、<hql>等自动活动还可以作为<transition>元素的子元素，在流经这个<transition>的时候被执行。

 

事件监听器实现示例

只需要实现EventListener接口即可。

 

public class MyEventListener implements EventListener{
public void notify(EventListenerExecution exection) throws Exception {
System.out.println("走出Decistion");
}
}
<?xml version="1.0" encoding="UTF-8"?>
 
<process name="test9" xmlns="http://jBPM.org/4.4/jpdl">
   <on event="start">
   <event-listener class="cn.javass.test.event.MyEventListener1">
   <field name="haha">
   <object expr="#{uuid}"/>
   </field>
   </event-listener>
   </on>
   <start name="start1" g="84,115,48,48">
      <transition to="task1"/>
   </start>
   <end name="end1" g="778,120,48,48"/>
<task name="task1" g="358,124,92,52" assignee="wang">
   <on event="start">
   <event-listener class="cn.javass.test.event.MyEventListener3">
   </event-listener>
   </on>
      <transition name="yes" to="end1" g="-47,-17">
      <event-listener class="cn.javass.test.event.MyEventListener5"/>
      </transition>
      <transition name="no" to="task2" g="-53,-17"/>
   </task>
   <task name="task2" g="536,218,92,52" assignee="zhang">
      <transition to="end1"/>
   </task>
</process>