使用jBpm支持高级用户交互模式

2010 年 1 月 15 日

许多通用业务流程都包含人类参与者。人类活动,从简单场景(如人工批准)到复杂场景(涉及复杂的数据输入),在流程实现中引入了新的方面,如人类交互模式。人类交互模式的一个典型集合 1 包括:

  • 四眼原则(The 4-eyes principle),通常又被称为“职责分离”,它是决策由多人彼此独立作出时的一个常见场景。在很多情况下,很容易就能得到另一个观点 / 签名。
  • 任命(Nomination)是指上级根据团队成员的任务安排、工作负荷或经验人工地将任务分配给他的情形。
  • 任务通常被建模来表达一种预期:它们将在确定时间段内完成。如果任务没有按预期地进展,就需要一种上报(escalation)机制。两种典型的上报实现是:重新分配任务,并常常附带一个上报已经发生的通知;或任务未按时完成的通知(通常发给经理)。
  • 链状执行(Chained execution)是一个流程(片断),其中的一系列步骤是由同一个人来完成。

在本文中,我将讨论如何使用 JBoss jBPM 来实现这些高级的交互模式。

jBPM 中的任务管理

jBPM 的一个核心功能 2 是为人类管理任务和任务列表。jBPM 允许将任务和任务节点作为整个流程设计的一部分使用。

任务一般在 jBPM 中定义成任务节点。单个任务节点可以包含一个或多个任务。包含任务节点的 jBPM 流程的一个公共行为就是等待任务节点中的全部任务完成,然后继续执行。某个任务可被分配 3 给个人、用户组或泳道:

  • 假如任务被分配给某个特定用户,那么就只有这个使用者可以执行它。
  • 假如任务被分配给某个用户组,那么这个组内的任何参与者都能执行这个任务。jBPM 使用的是参与者池(pooled actors)符号(它可以包含组名、组名列表和参与者个人列表等),而不是组 ID。如果用户开始执行在他们组任务列表中的任务,最终可能会引起冲突 4 ——可能有多人开始执行相同的任务。为了避免这种情况,在开始执行任务之前,用户应该将任务从组任务列表移动到他们自己的任务列表中。
  • 泳道代表一个流程角色,它通常被分配给一个用户组。它是一种指定流程中的多个任务要由同一参与者完成的机制 5 。因此,在第一个任务被分配给某个泳道之后,流程就会记住所有在相同泳道内的后续任务都将由同一参与者完成。

jBPM 提供了两种定义任务分配的基本方法:作为流程定义的一部分或通过编程实现。如果是作为流程定义的一部分,分配可以通过指定具体用户、用户组或泳道 完成。此外,可以使用表达式根据流程变量动态确定某个具体用户。完整的编程实现是基于分配处理器(assignment handler)的 6 ,它允许任务根据任意的计算规则去查找用户 ID。

流程定义描述流程实例的方式类似任务描述任务实例的方式。当流程执行时,一个流程实例——流程的运行时表示——就会被创建。类似,一个任务实例——任务的运行时表示——就会被创建。根据任务定义,任务实例被分配给一个参与者 / 参与者组。

任务实例的一个作用就是支持用户交互——把数据显示给用户并从用户那里收集数据。一个 jBPM 任务实例拥有访问流程(令牌)变量 7 的全部权限,而且还可以有自己的变量。任务能够拥有自己的变量对于以下场景非常有用:

  • 在任务实例中创建流程变量的副本,这样对任务实例变量的即时更新只有在该任务完成且这些副本被提交给流程变量时才会影响流程变量。
  • 创建更好支持用户活动的“派生(计算)”变量。

任务自己的变量在 jBPM 中是通过任务控制器处理器(task controller handler)支持的 8 ,它可以在任务实例创建时生成任务实例数据(从流程数据),并在任务实例完成时将任务实例数据提交给流程变量。

实现四眼原则

我们上面已经说过,实现四眼原则意味着要允许多人同时干一个活。它的实现有以下几种可能方法:

  • 在任务外解决:需要大量时间的任务并行循环(parallel looping) 9
  • 使用动作处理器(Action handler):附加到任务节点的进入事件(enter event),基于流程实例变量创建多个节点实例 10
  • 在任务内解决:引入“任务接受量(task take)”(类似 jPDL 4)并允许某个任务实例可被接受多次。

根据 jBPM 最佳实践 11 ——“扩展 jBPM API 而不是去搞复杂的流程建模” 12 ,我决定采用任务内解决的方法。这就要求修改 jBPM 提供的任务和任务实例类。

扩展 Task 类

jBPM 任务的定义被包含在 org.jbpm.taskmgmt.def.Task 类中。为了支持四眼原则,我们需要给类增加以下的字段 / 方法(清单 1):

复制代码
<b><span color="#800080">protected int</span></b> <span color="#0000ff">numSignatures</span> = 1;
<b><span color="#800080">public int</span></b> getNumSignatures(){
<b><span color="#800080">return</span></b> <span color="#0000ff">numSignatures</span>;
}
<b><span color="#800080">public void</span></b> setNumSignatures(<b><span color="#800080">int</span></b> numSignatures){
<b><span color="#800080">this</span></b>.numSignatures = <span color="#0000ff">numSignatures</span>;
}

清单 1 给 Task 类增加字段和方法

这个新的参数允许指定任务完成所需的任务处理人数量。缺省值为 1,这意味着,只有 1 个用户应该 / 可以处理这个任务。

jBPM 使用 Hibernate 来向数据库保存和读取数据。为了让我们新加的变量持久化,我们需要更新 Task 类的 Hibernate 配置文件(Task.hbm.xml),它在 org.jbpm.taskmgmt.def 文件夹中,增加代码如下(清单 2)

复制代码
<property <span color="#800080">name</span>="<span color="#0000ff">numSignatures</span>" <span color="#800080">column</span>="<span color="#0000ff">NUMSIGNATURES_</span>" />

清单 2 在 Task 映射文件中指定新增域

为了让我们新加的属性能被流程定义和数据库正确读取,我们需要修改 org.jbpm.jpdl.xml.JpdlXmlReader 类以正确地读取我们的新属性(清单 3)

复制代码
String numSignatureText = taskElement.attributeValue(<span color="#0000ff">"numSignatures"</span>);
<span color="#800080"><b>if</b></span> (numSignatureText != <span color="#800080"><b>null</b></span>) {
<span color="#800080"><b>try</b></span>{
task.setNumSignatures(Integer.parseInt(numSignatureText));
}
<span color="#800080"><b>catch</b></span>(Exception e){}
}

清单 3 读取 numSignature 属性

最后,因为 JpdlXmlReader 根据模式来验证 XML,因此我们需要在 jpdl-3.2.xsd 中增加一个属性定义(清单 4):

复制代码
<<span color="#008000">xs:element</span> <span color="#800080">name</span>=<span color="#0000ff">"task"</span>>
………………….
<<span color="#008000">xs:attribute</span> <span color="#800080">name</span>="<span color="#0000ff">numSignatures</span>" <span color="#800080">type</span>="<span color="#0000ff">xs:string</span>" />

清单 4 在 jpdl-3.2.xsd 中增加 numSignatures 属性

当完成这些工作,任务定义就被扩展可以使用 numSignatures 属性(清单 5):

复制代码
<span color="#008000"> <task <span color="#800080">name</span>="<span color="#0000ff">task2</span>" <span color="#800080">numSignatures</span> = "<span color="#0000ff">2</span>"><br></br> <assignment <span color="#800080">pooled-actors</span>="<span color="#0000ff">Peter, John</span>"></assignment><br></br> </task></span>

清单 5 给任务定义增加 numSignatures 属性

扩展 TaskInstance 类

在扩展完任务类后,我们还需要创建一个自定义的任务实例类来跟踪分配给该任务实例 13 的参与者,并确保所有被分配的参与者完成类执行(清单 6)。

复制代码
<span color="#800080"><b>package</b></span> com.navteq.jbpm.extensions;
<span color="#800080"><b>import</b></span> java.util.Date;
<span color="#800080"><b>import</b></span> java.util.LinkedList;
<span color="#800080"><b>import</b></span> java.util.List;
<span color="#800080"><b>import</b></span> org.jbpm.JbpmException;
<span color="#800080"><b>import</b></span> org.jbpm.taskmgmt.exe.TaskInstance;
<span color="#800080"><b>public class</b></span> AssignableTaskInstance <span color="#800080">extends</span> TaskInstance {
<span color="#800080"><b>private static final long</b></span> <span color="#0000ff">serialVersionUID</span> = 1L;
<span color="#800080"><b>private</b></span> List<Assignee> <span color="#0000ff">assignees</span> = <span color="#800080"><b>new</b></span> LinkedList<Assignee>();
<span color="#800080"><b>private</b></span> String getAssigneeIDs(){
StringBuffer sb = <span color="#800080"><b>new</b></span> StringBuffer();
<span color="#800080">boolean</span> first = <span color="#800080"><b>true</b></span>;
<span color="#800080"><b>for</b></span>(Assignee a : <span color="#0000ff">assignees</span>){
<span color="#800080"><b>if</b></span>(!first)
sb.append(<span color="#0000ff">" "</span>);
else
first = <span color="#800080"><b>false</b></span>;
sb.append(a.getUserID());
}
<span color="#800080"><b>return</b></span> sb.toString();
}
public List<Assignee> getAssignees() {
<span color="#800080"><b>return</b></span> <span color="#0000ff">assignees;</span>
}
<span color="#800080"><b>public void</b></span> reserve(String userID) throws JbpmException{
<span color="#800080"><b>if</b></span>(task == null)
throw <span color="#800080"><b>new</b></span> JbpmException(<span color="#0000ff">"can't reserve instance with no task"</span>);
// Duplicate assignment is ok
<span color="#800080"><b>for</b></span>(Assignee a : <span color="#0000ff">assignees</span>){
<span color="#800080"><b>if</b></span>(userID.equals(a.getUserID()))
<span color="#800080"><b>return</b></span>;
}
// Can we add one more guy?
<span color="#800080"><b>if</b></span>(<span color="#0000ff">task</span>.getNumSignatures() > <span color="#0000ff">assignees</span>.size()){
<span color="#0000ff">assignees</span>.add(<span color="#800080"><b>new</b></span> Assignee(userID));
<span color="#800080"><b>return</b></span>;
}
throw <span color="#800080"><b>new</b></span> JbpmException(<span color="#0000ff">"task is already reserved by "</span> +
getAssigneeIDs());
}
<span color="#800080"><b>public void</b></span> unreserve(String userID){
<span color="#800080"><b>for</b></span>(Assignee a : <span color="#0000ff">assignees</span>){
<span color="#800080"><b>if</b></span>(userID.equals(a.getUserID())){
<span color="#0000ff">assignees</span>.remove(a);
<span color="#800080"><b>return</b></span>;
}
}
}
<span color="#800080"><b>private</b></span> void completeTask(Assignee assignee, String transition){
assignee.setEndDate(<span color="#800080"><b>new</b></span> Date());
// Calculate completed assignments
int completed = 0;
<span color="#800080"><b>for</b></span>(Assignee a : <span color="#0000ff">assignees</span>){
<span color="#800080"><b>if</b></span>(a.getEndDate() != null)
completed ++;
}
<span color="#800080"><b>if</b></span>(completed < <span color="#0000ff">task</span>.getNumSignatures())
<span color="#800080"><b>return</b></span>;
<span color="#800080"><b>if</b></span>(transition == null)
end();
else
end(transition);
}
<span color="#800080"><b>public void</b></span> complete(String userID, String transition) throws JbpmException{
<span color="#800080"><b>if</b></span>(task == null)
throw <span color="#800080"><b>new</b></span> JbpmException(<span color="#0000ff">"can't complete instance with no task"</span>);
// make sure it was reserved
<span color="#800080"><b>for</b></span>(Assignee a : <span color="#0000ff">assignees</span>){
<span color="#800080"><b>if</b></span>(userID.equals(a.getUserID())){
completeTask(a, transition);
<span color="#800080"><b>return</b></span>;
}
}
throw <span color="#800080"><b>new</b></span> JbpmException(<span color="#0000ff">"task was not reserved by "</span> + userID);
}
public boolean isCompleted(){
<span color="#800080"><b>return</b></span> (<span color="#0000ff">end</span> != <span color="#800080"><b>null</b></span>);
}
}<assignee><assignee><assignee></assignee></assignee></assignee>

清单 6 扩展 TaskInstance 类

这个实现扩展了 jBPM 提供的 TaskInstance 类,并跟踪完成该实例所需的参与者个数。它引入了几个新方法,允许参与者预留(reserve)/ 退还(unreserve)任务实例,以及让指定参与者完成任务执行。

清单 6 的实现依赖一个支持类 Assignee(清单 7)

复制代码
<span color="#800080"><b>package</b></span> com.navteq.jbpm.extensions;
<span color="#800080"><b>import</b></span> java.io.Serializable;
<span color="#800080"><b>import</b></span> java.text.DateFormat;
<span color="#800080"><b>import</b></span> java.text.SimpleDateFormat;
<span color="#800080"><b>import</b></span> java.util.Date;
<span color="#800080"><b>public class</b></span> Assignee <span color="#800080"><b>implements</b></span> Serializable{
<span color="#800080"><b>private static final long</b></span> serialVersionUID = 1L;
<span color="#800080"><b>private static final</b></span> DateFormat dateFormat = <span color="#800080"><b>new</b></span>
SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
<span color="#800080"><b>long</b></span> id = 0;
<span color="#800080"><b>protected</b></span> String startDate = null;
<span color="#800080"><b>protected</b></span> String userID = null;
<span color="#800080"><b>protected</b></span> String endDate = null;
<span color="#800080"><b>public</b></span> Assignee(){}
<span color="#800080"><b>public</b></span> Assignee(String uID){
userID = uID;
startDate = dateFormat.format(<span color="#800080"><b>new</b></span> Date());
}
////////////Setters and Getters ///////////////////
<span color="#800080"><b>public long</b></span> getId() {
<span color="#800080"><b>return</b></span> id;
}
<span color="#800080"><b>public void</b></span> setId(<span color="#800080"><b>long</b></span> id) {
this.id = id;
}
<span color="#800080"><b>public</b></span> String getStartDate() {
<span color="#800080"><b>return</b></span> startDate;
}
<span color="#800080"><b>public void</b></span> setStartDate(String startDate) {
this.startDate = startDate;
}
<span color="#800080"><b>public</b></span> String getUserID() {
<span color="#800080"><b>return</b></span> userID;
}
<span color="#800080"><b>public void</b></span> setUserID(String id) {
userID = id;
}
<span color="#800080"><b>public</b></span> String getEndDate() {
<span color="#800080"><b>return</b></span> endDate;
}
<span color="#800080"><b>public void</b></span> setEndDate(String endDate) {
this.endDate = endDate;
}
<span color="#800080"><b>public void</b></span> setEndDate(Date endDate) {
this.endDate = dateFormat.format(endDate);
}
<span color="#800080"><b>public void</b></span> setEndDate() {
this.endDate = dateFormat.format(<span color="#800080"><b>new</b></span> Date());
}
<span color="#800080"><b>public</b></span> String toString(){
StringBuffer bf = <span color="#800080"><b>new</b></span> StringBuffer();
bf.append(" Assigned to ");
bf.append(userID);
bf.append(" at ");
bf.append(startDate);
bf.append(" completed at ");
bf.append(endDate);
<span color="#800080"><b>return</b></span> bf.toString();
}
}

清单 7 Assignee 类

自定义的 TaskInstance 类和 Assignee 类都必须保存到数据库中。这意味着需要给这两个类实现 Hibernate 映射 14 (清单 8,9):

<span color="#008000"><?xml <span color="#800080">version</span>="<span color="#0000ff">1.0</span>"?><br></br> </br> "-//Hibernate/Hibernate Mapping DTD 3.0//EN" <br></br> "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd"><p> <hibernate-mapping <span color="#800080">auto-import</span>="<span color="#0000ff">false</span>" <span color="#800080">default-access</span>="<span color="#0000ff">field</span>"></p><p> <subclass <span color="#800080">name</span>name="<span color="#0000ff">com.navteq.jbpm.extensions.AssignableTaskInstance</span>" </p><br></br><span color="#800080">extends</span>="<span color="#0000ff">org.jbpm.taskmgmt.exe.TaskInstance</span>"<br></br><span color="#800080">discriminator-value</span>="A"><br></br> <list <span color="#800080">name</span>="<span color="#0000ff">assignees</span>" <span color="#800080">cascade</span>="<span color="#0000ff">all</span>" ><br></br> <key <span color="#800080">column</span>="<span color="#0000ff">TASKINSTANCE_</span>" /><br></br> <index <span color="#800080">column</span>="<span color="#0000ff">TASKINSTANCEINDEX_</span>"/><br></br> <one-to-many <span color="#800080">class</span>="<span color="#0000ff">com.navteq.jbpm.extensions.Assignee</span>" /><br></br> </list><p> </subclass></p><br></br> </hibernate-mapping></span>清单 8 自定义任务实例的 Hibernate 映射文件

<span><span color="#008000"><?xml <span color="#800080">version</span>="<span color="#0000ff">1.0</span>"?><br></br> </br> "-//Hibernate/Hibernate Mapping DTD 3.0//EN"<br></br> "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd"><p> <hibernate-mapping <span color="#800080">auto-import</span>="<span color="#0000ff">false</span>" <span color="#800080">default-access</span>="<span color="#0000ff">field</span>"></p><br></br> <class <span color="#800080">name</span>="<span color="#0000ff">com.navteq.jbpm.extensions.Assignee</span>" <br></br><span color="#800080">table</span>="JBPM_ASSIGNEE"><br></br> <cache <span color="#800080">usage</span>="<span color="#0000ff">nonstrict-read-write</span>"/><br></br> <id <span color="#800080">name</span>="<span color="#0000ff">id</span>" <span color="#800080">column</span>="<span color="#0000ff">ID_</span>"><generator class="<span color="#0000ff">native</span>" /></id><br></br> <!-- Content --><br></br> <property <span color="#800080">name</span>="<span color="#0000ff">startDate</span>" <span color="#800080">column</span>="<span color="#0000ff">STARTDATE_" </span>/><br></br> <property <span color="#800080">name</span>="<span color="#0000ff">userID</span>" <span color="#800080">column</span>="<span color="#0000ff">USERID_"</span> /><br></br> <property <span color="#800080">name</span>="<span color="#0000ff">endDate</span>" <span color="#800080">column</span>="<span color="#0000ff">ENDDATE_" </span>/> <br></br> </class><br></br> </hibernate-mapping></span></span>清单 9 Assignee 类的 Hibernate 映射文件

要让 jBPM 能够使用我们的自定义任务实例实现,我们还需要提供一个自定义的任务实例工厂(清单 10)。

复制代码
<span color="#800080"><b>package</b></span> com.navteq.jbpm.extensions;
<span color="#800080"><b>import</b></span> org.jbpm.graph.exe.ExecutionContext;
<span color="#800080"><b>import</b></span> org.jbpm.taskmgmt.TaskInstanceFactory;
<span color="#800080"><b>import</b></span> org.jbpm.taskmgmt.exe.TaskInstance;
<span color="#800080"><b>public class</b></span> AssignableTaskInstanceFactory implements TaskInstanceFactory {
<span color="#800080">private static final long</span> <span color="#0000ff">serialVersionUID</span> = 1L;
@Override
public TaskInstance createTaskInstance(ExecutionContext executionContext) {
return new AssignableTaskInstance();
}
}

清单 10 自定义的任务实例工厂

最后,为了让 jBPM 运行时使用正确的任务实例工厂(清单 10),还必须创建一个新的 jBPM 配置(清单 11)。

<span><span color="#008000"><jbpm-configuration><p> <bean <span color="#800080">name</span>=<span color="#0000ff">"jbpm.task.instance.factory"</span> </p><br></br><span color="#800080">class</span>="<span color="#0000ff">com.navteq.jbpm.extensions.AssignableTaskInstanceFactory</span>" <span color="#800080">singleton</span>="<span color="#0000ff">true</span>" <br></br>/><p> </jbpm-configuration></p></span></span>清单 11 jBPM 配置

完成所有这些变更之后(清单 1-11),一个典型的任务处理显示如下:

复制代码
List<String> actorIds = new LinkedList<String>();
actorIds.add("Peter");
List<TaskInstance> cTasks = jbpmContext.getGroupTaskList(actorIds)
TaskInstance cTask = cTasks.get(0);
AssignableTaskInstance aTask = (AssignableTaskInstance)cTask;
try{
aTask.reserve("Peter");
// Save
jbpmContext.close();
}
catch(Exception e){
System.out.println("Task " + cTask.getName() + " is already reserved");
e.printStackTrace();
}<string><string><taskinstance></taskinstance></string></string>

清单 12 处理可分配任务实例

这里,在得到某个用户的任务实例并将其转变成可分配任务实例之后,我们将试着预留它 15 。一旦预留成功,我们将关闭 jBPM 运行时以提交事务。

实现任命

JBoss jBPM 可以非常轻易的实现手动将任务分配给特定用户。根据 jBPM 提供的简单 API,可以完成将任务实例从一个任务列表移动到另一个任务列表,因此给某个用户分配任务相当直接(清单 13)

复制代码
List<String> actorIds = new LinkedList<String>();
actorIds.add("<u>admins</u>");
String actorID = "<u>admin</u>";
List<TaskInstance> cTasks = <u>jbpmContext.getGroupTaskList(actorIds)</u>;
TaskInstance cTask = cTasks.get(0);
cTask.setPooledActors((<u>Set</u>)null);
cTask.setActorId(actorID);

清单 13 将任务重新分配给指定用户

jBPM 提供了 2 类不同的 API 来设置参与者池:一类接收字符串 id 数组,另一类则接收 id 集合。如果要清空一个池,就要使用那个接收集合的 API(传入一个 null 集合)。

实现上报

前面已经说过,上报一般被实现为任务的重新分配,并常常附带一个上报已发生的通知;或是实现成一个任务未及时完成的通知。

实现为重新分配的上报

尽管 jBPM 不直接支持上报,但它提供了 2 个基本的机制:超时和重新分配(参见上节)。粗一看,实现上报只需将这二者结合即可,但是仔细一想还是存在一些困难:

  • jBPM 实现中的关系并不总是双向的。如,从一个任务节点我们可以找到所有这个节点定义的任务,但是从一个任务,并没有 API 可以完成找到包含它的任务节点的工作 16 ;由某个任务实例,你可以得到一个任务,但是没有由某个任务得到所有实例的 API,诸如此类。
  • 超时不是发生在任务自身,而是发生在任务节点上。由于某个节点可以关联多个任务,并且 jBPM 关系实现并不是双向的(见上),因此要跟踪当前任务实例就需要其他的支持手段。

以重新分配实现的上报的整个实现 17 涉及 3 个处理器:

  • 负责给任务分配参与者的分配处理器。这个处理器跟踪它是一个首次任务调用还是一个上报任务调用。清单 14 给出了一个分配处理器的例子。
复制代码
<span color="#800080"><b>package</b></span> com.sample.action;
<span color="#800080"><b>import</b></span> org.jbpm.graph.def.Node;
<span color="#800080"><b>import</b></span> org.jbpm.graph.exe.ExecutionContext;
<span color="#800080"><b>import</b></span> org.jbpm.taskmgmt.def.AssignmentHandler;
<span color="#800080"><b>import</b></span> org.jbpm.taskmgmt.exe.Assignable;
<span color="#800080"><b>public class</b></span> EscalationAssignmentHandler <span color="#800080"><b>implements</b></span> AssignmentHandler {
<span color="#800080"><b>private static final long</b></span> serialVersionUID = 1L;
@Override
<span color="#800080"><b>public void</b></span> assign(Assignable assignable, ExecutionContext context)
throws Exception {
Node task = context.getToken().getNode();
if(task != <span color="#800080"><b>null</b></span>){
String tName = task.getName();
String vName = tName + "<span color="#0000ff">escLevel</span>";
Long escLevel = (Long)context.getVariable(vName);
if(escLevel == <span color="#800080"><b>null</b></span>){
// First time through
assignable.setActorId("<span color="#0000ff">admin</span>");
}
<span color="#800080"><b>else</b></span>{
// Escalate
assignable.setActorId("<span color="#0000ff">bob</span>");
}
}
}
}

清单 14 分配处理器示例

这里我们尝试得到一个包含了给定任务上报次数的流程变量。如果变量未定义,则就分配“admin”为任务拥有者,否则任务就被分配给“bob”。在这个处理器中可以使用任何其他的分配策略。

  • 任务实例创建动作处理器(清单 15),它保存流程实例上下文的任务实例 id
复制代码
<span color="#800080"><b>package</b></span> com.sample.action;
<span color="#800080"><b>import</b></span> org.jbpm.graph.def.ActionHandler;
<span color="#800080"><b>import</b></span> org.jbpm.graph.def.Node;
<span color="#800080"><b>import</b></span> org.jbpm.graph.exe.ExecutionContext;
<span color="#800080"><b>import</b></span> org.jbpm.taskmgmt.exe.TaskInstance;
<span color="#800080"><b>public class</b></span> TaskCreationActionHandler <span color="#800080"><b>implements</b></span> ActionHandler {
<span color="#800080"><b>private static final long</b></span> serialVersionUID = 1L;
@Override
<span color="#800080"><b>public void</b></span> execute(ExecutionContext context) <span color="#800080"><b>throws</b></span> Exception {
Node task = context.getToken().getNode();
TaskInstance current = context.getTaskInstance();
<span color="#800080"><b>if</b></span>((task == <span color="#800080"><b>null</b></span>) || (current == <span color="#800080"><b>null</b></span>))
<span color="#800080"><b>return</b></span>;
String tName = task.getName();
String iName = tName + "<span color="">instance</span>";
context.setVariable(iName, <span color="#800080"><b>new</b></span> Long(current.getId()));
}
}

清单 15 任务实例创建处理器

  • 任务节点计时器触发调用的超时处理器(清单 16)。
复制代码
<span color="#800080"><b>package</b></span> com.sample.action;
<span color="#800080"><b>import</b></span> org.jbpm.graph.def.ActionHandler;
<span color="#800080"><b>import</b></span> org.jbpm.graph.def.GraphElement;
<span color="#800080"><b>import</b></span> org.jbpm.graph.exe.ExecutionContext;
<span color="#800080"><b>import</b></span> org.jbpm.taskmgmt.exe.TaskInstance;
<span color="#800080"><b>public class</b></span> EscalationActionHandler <span color="#800080"><b>implements</b></span> ActionHandler {
<span color="#800080"><b>private static final long</b></span> serialVersionUID = 1L;
<span color="#800080"><b>private</b></span> String escalation;
@Override
<span color="#800080"><b>public void</b></span> execute(ExecutionContext context) throws Exception {
GraphElement task = context.getTimer().getGraphElement();
<span color="#800080"><b>if</b></span>(task == <span color="#800080"><b>null</b></span>)
<span color="#800080"><b>return</b></span>;
String tName = task.getName();
String vName = tName + "<span color="#0000ff">escLevel</span>";
<span color="#800080"><b>long</b></span> escLevel = (<span color="#800080"><b>long</b></span>)context.getVariable(vName);
<span color="#800080"><b>if</b></span>(escLevel == <span color="#800080"><b>null</b></span>)
escLevel = <span color="#800080"><b>new</b></span> <span color="#800080"><b>long</b></span>(1);
<span color="#800080"><b>else</b></span>
escLevel += 1;
context.setVariable(vName, escLevel);
String iName = tName + "<span color="#0000ff">instance</span>";
<span color="#800080"><b>long</b></span> taskInstanceId = (<span color="#800080"><b>long</b></span>)context.getVariable(iName);
TaskInstance current =
context.getJbpmContext().getTaskInstance(taskInstanceId);
<span color="#800080"><b>if</b></span>(current != <span color="#800080"><b>null</b></span>){
current.end(escalation);
}
}
}

清单 16 超时处理器

这个处理器首先记录上报计数器,接着完成此节点关联的任务实例。任务实例的完成伴随有一个变迁(一般是回到任务节点)。

使用以上描述的处理器实现上报的简单流程例子显示在清单 17 中。

<span><span color="#008000"><?xml version="<span color="#0000ff">1.0</span>" <span color="#800080">encoding</span>="<span color="#0000ff">UTF-8</span>"?><br></br> <process-definition <br></br><span color="#800080">xmlns</span>="<span color="#0000ff">urn:jbpm.org:jpdl-3.2</span>"<br></br><span color="#800080">name</span>="<span color="#0000ff">escalationHumanTaskTest</span>"><br></br> <start-state <span color="#800080">name</span>="start"><br></br> <transition to="<span color="#0000ff">customTask</span>"></transition><br></br> </start-state><br></br> <task-node <span color="#800080">name</span>="<span color="#0000ff">customTask</span>"><br></br> <task <span color="#800080">name</span>="<span color="#0000ff">task2</span>"><br></br> <assignment <span color="#800080">class</span>="<span color="#0000ff">com.sample.action.EscalationAssignmentHandler</span>"><<br></br>/assignment><br></br> </task><br></br> <event <span color="#800080">type</span>="<span color="#0000ff">task-create</span>"><br></br> <action <span color="#800080">name</span>="<span color="#0000ff">Instance Tracking</span>" <span color="#800080">class</span>="<span color="#0000ff">com.sample.action.TaskCreationActionHandler</span>"></action><br></br> </event><br></br> <timer <span color="#800080">duedate</span>="<span color="#0000ff">10 second</span>" <span color="#800080">name</span>="<span color="#0000ff">Escalation timeout</span>"><br></br> <action <span color="#800080">class</span>="<span color="#0000ff">com.sample.action.EscalationActionHandler</span>"><br></br> <escalation><br></br> escalation<br></br> </escalation><br></br> </action><br></br> </timer><p> <transition <span color="#800080">to</span>="<span color="#0000ff">end</span>" <span color="#800080">name</span>="<span color="#0000ff">to end</span>"></transition></p><br></br> <transition <span color="#800080">to</span>="<span color="#0000ff">customTask</span>" <span color="#800080">name</span>="<span color="#0000ff">escalation</span>"></transition><br></br> </task-node><br></br> <end-state <span color="#800080">name</span>="<span color="#0000ff">end</span>"></end-state><br></br> </process-definition></span></span><task-node></task-node>清单 17 简单流程的上报

实现成通知的上报

jBPM 为邮件传递提供了强大支持 18 ,这使得实现成通知的上报变得极其简单。邮件传递可由给节点附加定时器,然后触发,它使用已经写好的邮件动作来完成通知传递。

实现链状执行

链状执行直接由 jBPM 泳道支持,并不需要额外的开发。

总结

不管我们在自动化方面投入多少努力,面对复杂的业务流程,总免不了要有人工介入的可能。在这篇文章中,我给出了一系列已建立的高级人工交互模式,并展示了用 jBPM 完成它是多么轻而易举。

查看英文原文: Supporting Advanced User Interaction Patterns in jBPM


给 InfoQ 中文站投稿或者参与内容翻译工作,请邮件至 editors@cn.infoq.com 。也欢迎大家加入到 InfoQ 中文站用户讨论组中与我们的编辑和其他读者朋友交流。

2010 年 1 月 15 日 00:358685
用户头像

发布了 255 篇内容, 共 45.2 次阅读, 收获喜欢 1 次。

关注

评论

发布
暂无评论
发现更多内容

中秋佳节,程序员教你AI三步成诗,秒变“李白”

华为云开发者社区

AI 中秋

第三课代码重构课后作业

Geek_michael

极客大学架构师训练营

第三周 作业1

Yangjing

极客大学架构师训练营

设计模式--正确学习姿势

张荣召

架构训练营第二周作业

Geek_ce484f

极客大学架构师训练营

不是我不小心

escray

Java ruby ruby-on-rails 面经 101次面试

架构师训练营第三周--学习总结

张荣召

区块链掀起全民创业热潮!数字资产是未来全球最具前景和价值的!

CECBC区块链专委会

区块链 数字货币

java安全编码指南之:死锁dead lock

程序那些事

java安全编码 java安全 java安全编码指南

【获奖名单】赢千元数码大奖!竟然如此简单!

InfoQ写作平台

美食 摄影 活动专区

一周信创舆情观察(9.21~9.27)

统小信uos

全文!马云对数字时代全球化的全新解读

CECBC区块链专委会

全球化 数字时代

代码重构 - 课后作业

Nick~毓

甲方日常 25

句子

生活 随笔杂谈 日常

架构师训练营第三周-homework

张荣召

区块链有助金融监管效能提升

CECBC区块链专委会

区块链 金融

技术解读丨目标检测之RepPoints系列算法

华为云开发者社区

算法 神经 目标检查

剖析Java15新语法特性

高翔龙

Java 架构 Java 分布式 java15新特性

重塑产业+价值共识,区块链助力供应链金融数字化

CECBC区块链专委会

区块链 供应链物链

区块链如何深刻变革现代金融?

CECBC区块链专委会

区块链 金融

数据库选型入门必读:如何在眼花缭乱的产品中挑出最适合业务的?

华为云开发者社区

数据库 数据库选择 关系型

软件架构(2)-框架设计

Zeke

极客大学架构师训练营

从三个产业侧影,打开万物智能的应用之匙

脑极体

一个草根的日常杂碎(9月30日)

刘新吾

随笔杂谈 生活记录 社会百态

设计模式-单例模式

张荣召

架构训练营第二周作业

Geek_ce484f

极客大学架构师训练营

区块链技术在司法行业的服务应用

CECBC区块链专委会

区块链 司法

在vue2中使用ts

正经工程师

typescript vue.js

架构师训练营 1 期第 3 周:代码重构 - 作业

piercebn

极客大学架构师训练营

设计模式--模板模式/策略模式

张荣召

Template Pattern Strategy Pattern

设计模式--组合模式/装饰模式

张荣召

Composite Pattern Decorator Pattern

使用jBpm支持高级用户交互模式-InfoQ