JBPM節點分支之Group節點分析

JBPM的眾多節點類型中，唯獨Group節點比較有個性；Group節點作為眾多的節點中的一員，其并不能完成業務功能，但其作為一種節點的容器，可以對現有的節點類型進行“混搭”，從而構造出可以完成新的業務功能的節點類型！今天我們來簡單的學習一下Group節點，后續我們會進行深入分析JBPM的并發設計時候再次提到Group節點。
Group節點功能分析
作為父容器，可以將復雜的業務功能進行封裝為新的節點類型,便于業務復用和維護；
可以將各種復雜的業務過程嵌套到Group中，簡化復雜的業務流程；
可以作為流程并發的邊界容器；
可以作為子流程的承載容器，將子流程封裝為單獨的一種節點類型；
Group的個性特點
作為容器節點，可以嵌套任意類型的節點，可以滿足復雜的業務需求；
前一節點出弧可以直接跨越Group節點，與Group的子節點相連，子節點的出弧也可以直接Group的后一個節點；
嵌套多起點的時候可以進行并發；
下面我們看一下幾個有Group節點的流程，來體味一下Group的功能和使用
簡單的Group流程
在這個簡單的公文流轉（權且這樣稱謂吧）流程中，我們將這個簡單的業務流程嵌套到Group節點中，封裝了這個業務流程，當然從重用的角度來說，這并不是一個很好的例子，但是這同樣足夠體現了Group節點的功能！

流程圖如下

流程定義JPDL

  

     測試用例代碼 
  
  ProcessInstance processInstance = executionService
       .startProcessInstanceByKey("GroupSimple");
String pid = processInstance.getId();
assertEquals("distribute document", processInstance.getActivityName());

processInstance = executionService.signalExecutionById(pid);
assertEquals("collect feedback", processInstance.getActivityName());

processInstance = executionService.signalExecutionById(pid, "rejected");
assertEquals("update document", processInstance.getActivityName());

processInstance = executionService.signalExecutionById(pid);
assertEquals("distribute document", processInstance.getActivityName());

processInstance = executionService.signalExecutionById(pid);
assertEquals("collect feedback", processInstance.getActivityName());

processInstance = executionService.signalExecutionById(pid, "approved");
assertEquals("publish document", processInstance.getActivityName());  

    

    
      帶有定時器的Group流程
      

    
     Group作為可等待外部喚醒的節點（此喚醒不同task、state的人工外部喚醒，此處喚醒是由流程引擎進行喚醒繼續執行的），其出弧是可以設置定時器的，對于定時器我們后續會進行學習。在這個流程中，在Group開始執行后的2個業務小時后就會執行定時器所在的分支。
  
  

     流程圖如下
  
  

    
      
    
  
  

     流程定義JPDL 
  
  <process name="GroupTimer" xmlns="http://jbpm.org/4.4/jpdl">

  <start>
    <transition to="evaluate document" />
  </start>
  
  <group name="evaluate document">
    <start>
      <transition to="approve" />
    </start>
    <state name="approve">
      <transition to="done" />
    </state>
    <end name="done" />
    
    <transition to="publish document" />
    <transition name="timeout" to="escalate">
      <timer duedate="2 business hours" />
    </transition>
    
  </group>
  
  <state name="escalate" />
  <state name="publish document" />

</process>  

     測試用例 
  
  ProcessInstance processInstance = executionService
       .startProcessInstanceByKey("GroupTimer");
Execution approveExecution = processInstance
       .findActiveExecutionIn("approve");
assertNotNull(approveExecution);

List<Job> jobs = managementService
  .createJobQuery()
  .processInstanceId(processInstance.getId())
  .list();

assertEquals(1, jobs.size());

Timer timer = (Timer) jobs.get(0);

managementService.executeJob(timer.getDbid());

processInstance = executionService
       .findProcessInstanceById(processInstance.getId());
assertNotNull(processInstance.findActiveExecutionIn("escalate") );  

  
  

    
      具有多起點的Group流程（非并發流程）
      

    
     在這個流程中，判斷節點連接到Group中的不同分支上，通過運行時變量承載的弧名稱來選擇執行不同的分支，這種情況下只能有一個分支執行。
  
  

     流程圖如下
  
  

    
      
    
  
  

     流程定義JPDL 
  
  <process name="GroupMultipleEntries" xmlns="http://jbpm.org/4.4/jpdl">

  <start>
    <transition to="choose strategy" />
  </start>
  
  <decision name="choose strategy" expr="#{time}">
    <transition name="plenty" to="play" />
    <transition name="running out" to="plan" />
  </decision>
  
  <group name="evaluate project">
    <start name="play">
      <transition to="distribute document" />
    </start>
    <state name="distribute document" />

    <start name="plan">
      <transition to="make planning" />
    </start>
    <state name="make planning" />
  </group>
  
</process>  

     測試用例 
  
  Map<String, Object> variables = new HashMap<String, Object>();
variables.put("time", "plenty");

ProcessInstance pi = executionService
    .startProcessInstanceByKey("GroupMultipleEntries", variables);

assertNotNull(pi.findActiveExecutionIn("distribute document"));
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("time", "running out");

ProcessInstance pi = executionService
    .startProcessInstanceByKey("GroupMultipleEntries", variables);

assertNotNull(pi.findActiveExecutionIn("make planning"));  

    

    
      帶有Group的并發流程
      

    
     帶有Group的并發流程與WF4中的Parallel活動類似，在下面的流程中，由于Group的子節點中由兩個沒有入弧的節點（不一定得是開始節點），所以運行時會產生兩個并發分支。
    

     流程圖如下
  
  

    
      
    
  
  

     流程定義JPDL 
  
  <process name="GroupConcurrency" xmlns="http://jbpm.org/4.4/jpdl">

  <start>
    <transition to="evaluate project" />
  </start>
  
  <group name="evaluate project">
    <start>
      <transition to="distribute document" />
    </start>
    <state name="distribute document">
      <transition to="collect feedback" />
    </state>
    <state name="collect feedback">
      <transition to="document finished" />
    </state>
    <end name="document finished" />

    <start>
      <transition to="make planning" />
    </start>
    <state name="make planning">
      <transition to="estimate budget" />
    </state>
    <state name="estimate budget">
      <transition to="planning finished" />
    </state>
    <end name="planning finished" />

    <transition to="public project announcement" />
  </group>
  
  <state name="public project announcement" />

</process>  

     測試用例代碼 
  
  ProcessInstance pi = executionService
    .startProcessInstanceByKey("GroupConcurrency");

String documentExecutionId = pi
    .findActiveExecutionIn("distribute document").getId();

String planningExecutionId = pi
    .findActiveExecutionIn("make planning").getId();

pi = executionService.signalExecutionById(documentExecutionId);
assertNotNull(pi.findActiveExecutionIn("collect feedback"));
assertNotNull(pi.findActiveExecutionIn("make planning"));

pi = executionService.signalExecutionById(planningExecutionId);
assertNotNull(pi.findActiveExecutionIn("collect feedback"));
assertNotNull(pi.findActiveExecutionIn("estimate budget"));

pi = executionService.signalExecutionById(planningExecutionId);
assertNotNull(pi.findActiveExecutionIn("collect feedback"));

pi = executionService.signalExecutionById(documentExecutionId);
assertNotNull(pi.findActiveExecutionIn("public project announcement"));  

     對Group的學習今天就到此為止，接下來我們會對JBPM中的并發節點以及并發機制進行分析。
  
  

    

  
  

    
      JBPM節點分支之Group節點分析