`

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。

java代码:
  1. public class MyDecisionHandler implements DecisionHandler{  
  2. @Override  
  3. public String decide(OpenExecution execution) {  
  4. Integer age = (Integer) execution.getVariable("age");  
  5. if (age>=20){  
  6. return "yes";  
  7. }else{  
  8. return "no";  
  9. }  
  10. }  
  11. }  
定义
task活动一般用来处理涉及人机交互的活动,流程引擎会停在这里等待人工的操作。
task活动的assignee属性
assignee属性用来指定任务分配给谁,可以使用变量来定义。
任务的候选者
candidate-users属性可以使用逗号分割的用户ID列表。所有列表中的用户会成为任务的候选者。用户想要接受这个任务,需要人工的takeTask。
相关api—领取任务

java代码:
  1. ProcessEngine processEngine = Configuration.getProcessEngine();  
  2. TaskService taskService = processEngine.getTaskService();  
  3. taskService.takeTask(“task的id”, “领取task的人员");  
任务的候选组
candidate-groups属性可以使用逗号分割的用户组ID列表。所有列表中的用户组中的用户会成为任务的候选者。用户想要接受这个任务,需要人工的takeTask。
相关api—建立用户和用户组

java代码:
  1. ProcessEngine processEngine = Configuration.getProcessEngine();  
  2. IdentityService identityService = processEngine.getIdentityService();  
  3.    
  4. identityService.createGroup("sales");  
  5. identityService.createUser(“zhang", “zhang", “san");  
  6. identityService.createUser(“li", “li", “si");  
  7.    
  8. identityService.createMembership(“zhang", "sales");  
  9. identityService.createMembership(“li", "sales");  
任务分配器
任务分配器AssignmentHandler的方式,可以说是最灵活的任务分配方式了,它支持使用java代码来指定任务的分配者。
相关api:

java代码:
  1. public class MyAssignmentHandler implements AssignmentHandler{  
  2. private String name;  
  3. public String getName() {  
  4. return name;  
  5. }  
  6. public void setName(String name) { this.name = name; }  
  7.    
  8. public void assign(Assignable assignable, OpenExecution execution) throws Exception {  
  9. assignable.setAssignee(name);  
  10. }  
  11. }  
相应的配置示例:

java代码:
  1. <task name="task1" g="339,146,92,52">  
  2.      <assignment-handler class="cn.javass.test.task.handler.MyAssignmentHandler">  
  3.       <field name="name">  
  4.       <string value="ok"/>  
  5.       </field>  
  6.      </assignment-handler>  
  7.       <transition to="end1"/>  
  8.    </task>  
定义
 当需要流程并发执行的时候,就需要使用到fork-join活动的组合,fork活动可以使流程在一条主干上出现并行的分支,join活动则可以使流程的并行分支聚合成一条主干。
定义
java活动可以指定一个Java类的方法,当流程执行到此活动时,马上自动执行此Java方法。
 
相关属性
class属性用来指定此Java类的全类名,要注意这个类要有public无参的默认构造方法。
method属性用来指定调用的方法。
var属性存储方法执行结果的流程变量名称。

java代码:
  1. public class MyJava {  
  2. private String user1;  
  3. private String user2;  
  4. …user1和user2的setter  
  5. public String sayHello(String arg1,String arg2){  
  6.    
  7. System.out.println("user1=="+user1);  
  8. System.out.println("user2=="+user2);  
  9. System.out.println("arg1=="+arg1);  
  10. System.out.println("arg2=="+arg2);  
  11.    
  12. return “Hello";  
  13. }  
  14. }  
为Java类设置属性和为方法传递参数
在注册的时候,可以注册一个固定的值,也可以引用pi级的变量。

java代码:
  1. <java g="246,135,92,52" name="java1" class="cn.javass.test.java.MyJava" method="sayHello" var="manager">  
  2.     <field name="user1"><object expr=“#{user1}”/></field>  
  3.     <field name="user2"><string value="user2“/></field>  
  4.     <arg><string value="xyz“/></arg>  
  5.     <arg><object expr="#{abc}“/></arg>  
  6.      <transition to="task1"/>  
  7.   </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活动示例:
 

java代码:
  1. <sql g="192,438,92,52" name="sql1" unique="true" var="sqlV">  
  2. <query>  
  3. select * from tbl_user where uuid=:uuid  
  4. </query>  
  5. <parameters>  
  6. <object name="uuid" expr="#{uuid}"></object>  
  7. </parameters>  
  8.   <transition to="hql1"/>  
  9. </sql>  
定义
 hql活动能够支持使用hql直接从数据库中查询数据,并将结果返回到流程变量中。
 
nhql活动的属性
var属性存储hql执行结果的流程变量名称。
unique属性,此属性为true时,返回结果为一行,结果将作为一个单独的对象存储;此属性为false时,返回结果为多行,结果将作为一个Set存储。
 
hql活动的子元素
query子元素用来设置hql查询语句。
parameters子元素用来设置hql的外部参数。
HQL活动示例:
 
java代码:
  1. <hql name="hql1" g="404,457,92,52" unique="true" var="hqlV">  
  2. <query>  
  3. select o from Parent o where o.id=:id  
  4. </query>  
  5. <parameters>  
  6. <string name="id" value="22"/>  
  7. </parameters>  
  8.   <transition to="task2"/>  
  9. </hql>  
定义
foreach活动使得通过一条单独的流程路径来执行多条流程分支的功能。
 
相关属性
in:将被迭代的集合。集合中的每个元素会生成一个新的同步分支。in执行任意类型的集合,数组和以逗号分隔的字符串。。
var:用来保存集合中当前元素的变量。这个变量会设置到同步流程分支中,并且只对这个流程分支可见。
 
与join活动连用
通常情况下,foreach活动后面是多次执行的活动,在这个活动后面应该跟一个join活动,并且把join活动的multiplicity设置成为foreach的数量,这样才会等到foreach的多个task执行完成,流程才继续向下,否则,只要有一个foreach的task完成了,流程就向下流转了。
配置示例,如果在jPDL里面配置如下:

java代码:
  1. <foreach name="foreach1" in="D1,D2,D3" var="nowDep">  
  2. <transition to="task5"/>  
  3. </foreach>  
  4. <task name="task5">  
  5. <transition to="join1"/>  
  6. </task>  
  7. <join name="join1" multiplicity="3">  
  8. <transition to="task6"/>  
  9. </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里面配置如下

java代码:
  1. <rules name="rule1">  
  2. <fact var="um"></fact>  
  3. <transition to="exclusive2"/>       
  4. </rules>  
  5. <decision name="exclusive2">  
  6. <transition name="toT7" to="task7">  
  7. <condition expr="#{um.canDrink}"/>  
  8. </transition>  
  9. <transition name="toT8" to="task8">  
  10. <condition expr="#{!um.canDrink}"/>  
  11. </transition>  
  12. </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();
在运行规则活动之前,需要设置好规则需要的变量,比如在启动流程的时候:

java代码:
  1. Map map = new HashMap();  
  2. UserModel um = new UserModel();  
  3. um.setUuid("11");  
  4. um.setAge(50);  
  5. map.put("um", um);  
  6. 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接口即可。
 

java代码:
  1. public class MyEventListener implements EventListener{  
  2. public void notify(EventListenerExecution exection) throws Exception {  
  3. System.out.println("走出Decistion");  
  4. }  
  5. }  
  6. <?xml version="1.0" encoding="UTF-8"?>  
  7.    
  8. <process name="test9" xmlns="http://jBPM.org/4.4/jpdl">  
  9.    <on event="start">  
  10.    <event-listener class="cn.javass.test.event.MyEventListener1">  
  11.    <field name="haha">  
  12.    <object expr="#{uuid}"/>  
  13.    </field>  
  14.    </event-listener>  
  15.    </on>  
  16.    <start name="start1" g="84,115,48,48">  
  17.       <transition to="task1"/>  
  18.    </start>  
  19.    <end name="end1" g="778,120,48,48"/>  
  20. <task name="task1" g="358,124,92,52" assignee="wang">  
  21.    <on event="start">  
  22.    <event-listener class="cn.javass.test.event.MyEventListener3">  
  23.    </event-listener>  
  24.    </on>  
  25.       <transition name="yes" to="end1" g="-47,-17">  
  26.       <event-listener class="cn.javass.test.event.MyEventListener5"/>  
  27.       </transition>  
  28.       <transition name="no" to="task2" g="-53,-17"/>  
  29.    </task>  
  30.    <task name="task2" g="536,218,92,52" assignee="zhang">  
  31.       <transition to="end1"/>  
  32.    </task>  
  33. </process>  
  34.    
 
视频配套PPT,视频地址【最新jbpm4工作流开发实战视频课程 
 
 
 原创内容 转自请注明【 http://sishuok.com/forum/blogPost/list/0/2523.html#7272
6
4
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics