论坛首页 → Java企业应用论坛 →

jbpm 并发子流程的解决方案与探讨

浏览 1242 次
已锁定 主题：jbpm 并发子流程的解决方案与探讨
该帖已经被评为隐藏帖
作者 正文
  • jbpm-x
  • 等级: 初级会员
  • 性别:
  • 文章: 16
  • 积分: 50
  • 来自: 大连
   发表时间：2007-09-09  

作者：JeffreyHsu

尽管jbpm非常强大，是目前最适合商业化的开源工作流引擎，可以开发出复杂的流程，但是特别遗憾的是并不支持并发子流程（multiple-subprocess）
有一次我需要做一个复杂的流程，主流程里要求同时启动多个并发执行的子流程，并且子流程的数目和启动的时间都不确定，当所有子流程都结束以后，主流程才继续执行。我们知道jbpm里有子流程的设定，有专门的节点ProcessState来处理，但是后来发现无论如何也实现不了多子流程并发执行，后来看其源码知道因为subprocess是作为ProcessState的一个属性，也就是说ProcessState只能包含一个subprocess的定义，并且最重要的是processInstance.getRootToken()和子流程相关的只有createSubProcessInstance, getSubProcessInstance, setSubProcessInstance三个方法，这意味着主流程的rootToken只能设置一个子流程，jbpm并不直接支持多子流程。
那么我们就必须用一个变通的方法来实现，“并发”很自然的让我们想到了fork，但是这里的fork不能搭配join来使用，具体原因，将在后面讨论。
下面先给出流程图：

state节点用来启动子流程（实际应用可以换成Task-Node），state进入fork后同时进入两个分支，一条去启动子流程，另一条回到自己，这样表面看来state没有动，而同时你又可以启动第2个，第3个……子流程，需要注意的是第2条子流程和第1个子流程并不处于同一级上，而比第一个子流程低一级，具体请看后面一张图就明白了，分解后的：

从图中我们可以看到后一个子流程的整棵树是前一个子流程的兄弟，但是在业务级上是并发的效果，已经实现我们前面的需求。

现在来说说为什么不能用join而直接用end，因为会产生一个问题，state3和sub process 2都到达了join以后，state2下面的fork就结束了，就会立刻越过join到达end，而sub process 1即使执行完毕到达了join却仍然在傻傻等待着他的兄弟分支也到达join（而实际上它已经自跑到end去了）一同结束，这样sub process 1就会永远停在join动弹不得，业务无法进行。

这是我的一个解决方案，但还有一个问题，虽然全部的子流程都能结束，主流程也能结束，但因为没有join，主流程的rootToken仍然停留在fork节点上。目前我尚不知如何解决，希望各位大家能提出其他更好的解决办法。
初学jbpm，水平有限，有不当之处还请高手斧正

最后附上demo代码供参考：

代码
  1.   
  2. import static org.junit.Assert.*;   
  3.   
  4. import org.jbpm.graph.def.ProcessDefinition;   
  5. import org.jbpm.graph.exe.ProcessInstance;   
  6. import org.jbpm.graph.exe.Token;   
  7. import org.jbpm.graph.node.ProcessState;   
  8. import org.junit.Before;   
  9. import org.junit.Test;   
  10.   
  11. public class MultiProcessTest {   
  12.     private ProcessDefinition superProcessDefinition;   
  13.   
  14.     private ProcessDefinition subProcessDefinition;   
  15.   
  16.     @Before   
  17.     public void setUp() throws Exception {   
  18.         superProcessDefinition = ProcessDefinition.parseXmlString(   
  19.                 "<process-definition name='super'>" +                
  20.                 "  <start-state name='start'>" +   
  21.                 "    <transition to='state' />" +   
  22.                 "  start-state>" +   
  23.                 "  <state name='state'>" +   
  24.                 "    <transition name='create sub' to='fork' />" +   
  25.                 "    <transition name='end' to='end' />" +   
  26.                 "  state>" +   
  27.                 "  <fork name='fork'>" +   
  28.                 "    <transition name='back' to='state' />" +   
  29.                 "    <transition name='go to sub' to='sub process' />" +   
  30.                 "  fork>" +   
  31.                 "  <process-state name='sub process'>" +   
  32.                 "    <sub-process name='sub' />" +   
  33.                 "    <transition to='end' />" +   
  34.                 "  process-state>" +   
  35.                 "  <end-state name='end' />" +   
  36.                 "process-definition>");   
  37.            
  38.         subProcessDefinition = ProcessDefinition.parseXmlString(   
  39.                 "<process-definition name='sub'>" +                          
  40.                 "  <start-state name='start'>"  +   
  41.                 "    <transition to='wait' />" +   
  42.                 "  start-state>" +                         
  43.                 "  <state name='wait'>" +   
  44.                 "    <transition to='end' />" +   
  45.                 "  state>" +              
  46.                 "  <end-state name='end' />" +   
  47.                 "process-definition>");   
  48.         ProcessState processState = (ProcessState) superProcessDefinition   
  49.                 .getNode("sub process");   
  50.         processState.setSubProcessDefinition(subProcessDefinition);   
  51.     }   
  52.   
  53.     @Test   
  54.     public void testMultiProcesses() {   
  55.         ProcessInstance pi = new ProcessInstance(superProcessDefinition);   
  56.   
  57.         // 启动一个主流程   
  58.         pi.signal();   
  59.         assertEquals("state", pi.getRootToken().getNode().getName());   
  60.   
  61.         // 进入分支，此处将进入子流程   
  62.         pi.signal("create sub");   
  63.         // 主流程token将停留在fork节点上   
  64.         assertEquals("fork", pi.getRootToken().getNode().getName());   
  65.   
  66.         // fork分为两支，其中一支的节点停留在ProcessState上   
  67.         Token subProcessToken1 = pi.getRootToken().getChild("go to sub");   
  68.         ProcessInstance subPi1 = subProcessToken1.getSubProcessInstance();   
  69.         assertEquals("wait", subPi1.getRootToken().getNode().getName());   
  70.   
  71.         // 另一支返回了state节点，实际上并没有返回，这个state节点不同于先前的state，它们并不在同一个path中   
  72.         Token stateToken1 = pi.getRootToken().getChild("back");   
  73.         assertEquals("state", stateToken1.getNode().getName());   
  74.            
  75.         // 再次进入fork，启动第二个子流程   
  76.         stateToken1.signal("create sub");   
  77.         ProcessInstance subPi2 = stateToken1.getChild("go to sub")   
  78.                 .getSubProcessInstance();   
  79.         // 虽然都是子流程，但它们并不相同，在逻辑上是属于并发的无关系的子流程   
  80.         assertFalse(subPi1.equals(subPi2));   
  81.         // 结束第二个子流程   
  82.         subPi2.signal();   
  83.         assertTrue(subPi2.hasEnded());   
  84.         assertFalse(pi.hasEnded());   
  85.   
  86.         // 结束第一个子流程，但主流程仍未结束   
  87.         subPi1.signal();   
  88.         assertTrue(subPi1.hasEnded());   
  89.         assertFalse(pi.hasEnded());   
  90.            
  91.         // 结束第二个子流程中的state，第一子流程的back分支结束，从而主流程也结束   
  92.         Token stateToken2 = stateToken1.getChild("back");   
  93.         assertEquals("state", stateToken2.getNode().getName());   
  94.         assertFalse(stateToken1.hasEnded());   
  95.         assertFalse(pi.hasEnded());   
  96.         stateToken2.signal("end");   
  97.            
  98.         assertTrue(stateToken1.hasEnded());   
  99.         assertTrue(subPi1.hasEnded());   
  100.         assertTrue(pi.getRootToken().getChild("back").hasEnded());   
  101.         assertTrue(pi.getRootToken().getChild("go to sub").hasEnded());   
  102.         // 主流程结束了   
  103.         assertTrue(pi.hasEnded());   
  104.         // 虽然主流程已经结束了，但是因为子流程没有join，所以其rootToken仍然停留在fork上   
  105.         assertEquals("fork", pi.getRootToken().getNode().getName());   
  106.         // 第二个子流程到达的end和主流程中的end并不是同一个节点   
  107.         assertTrue(!pi.getRootToken().getNode().equals(stateToken2.getNode()));   
  108.     }   
  109. }   
返回顶楼
         
论坛首页 → Java企业应用版

跳转论坛:
Global site tag (gtag.js) - Google Analytics