许多通用业务流程都包含人类参与者。人类活动，从简单场景（如人工批准）到复杂场景（涉及复杂的数据输入），在流程实现中引入了新的方面，如人类交互模式。人类交互模式的一个典型集合 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 中文站用户讨论组中与我们的编辑和其他读者朋友交流。
暂无签名
Java 避坑指南：Java 高手笔记代码篇
本迷你书包括 86 个业务开发中常见踩坑点。每一个知识点都相当的实用，是程序员业务开发中的必备避坑指南...
评论