2. 程式人生 > >Activiti接受任務（receiveTask）

Activiti接受任務（receiveTask）

阿新 • • 發佈：2017-06-27
image eve 持久化數據 wait 手動 手工 修改時間 workflow otn

Activiti接受任務（receiveTask）

作者：鄧家海

前言：

Activiti接受任務（receiveTask）其實和Activiti的手動任務是差不多的，不過手動任務是直接通過，而Activiti接受任務（receiveTask）則在任務啟動到該節點的時候停下來等待信號。當任務接收到信號的時候，該流程就會繼續往下執行。

官方解釋：

描述
接收任務是一個等待消息到來的簡單任務。目前，我們僅實現了該任務的 Java 語義。 當流程執行到接收任務時，流程狀
態被提交到持久化數據庫中。這意味著，流程將進入一種等待狀態，直到引擎接收到明確的消息，來觸發流程通過接收
任務繼續執行。
圖形化符號
接收任務被形象化成左上角帶有消息圖標的任務（橢圓）。消息是白色的（黑色的消息圖標表示已經發送的意思）。


XML 表示
<receiveTaskid="waitState"name="wait"/>
要繼續當前等待在這樣一個接收任務的流程實例，需要調用使用了執行到此接收任務的執行路徑的 id 的方法
runtimeService.signal(executionId)。下面的代碼片段展示實際是如何操作的：
ProcessInstance pi = runtimeService.startProcessInstanceByKey("receiveTask");
Execution execution = runtimeService.createExecutionQuery()
.processInstanceId(pi.getId())
.activityId("wait")
.singleResult();
assertNotNull(execution);
runtimeService.signal(execution.getId());

流程設計：

技術分享

流程圖源碼：

 1 <?xml version=‘1.0‘ encoding=‘UTF-8‘?>
 2 
 3 <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
 
 xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/processdef">
 4 
 5   <process id="receiveTaskprocess" isExecutable="true">
 6 
 7     <startEvent id="sid-4AF5399C-5241-4F58-BE58-6B2D0A1249D2" />
 8 
 9     <receiveTask id="receiveTask" name="接受任務">
10 
11       <extensionElements>
12 
13         <activiti:executionListener event="end" class="light.mvc.workflow.serviceTask.receiveTestRunningTask" />
14 
15       </extensionElements>
16 
17     </receiveTask>
18 
19     <sequenceFlow id="sid-46A38F6A-4413-48E2-ADAA-5DC86682086C" sourceRef="sid-4AF5399C-5241-4F58-BE58-6B2D0A1249D2" targetRef="receiveTask" />
20 
21     <endEvent id="sid-156246B5-C81C-4AAB-A183-FCA197EC6901" />
22 
23     <sequenceFlow id="sid-2CCD7E71-70FE-418C-8365-5CD7636E9657" sourceRef="receiveTask" targetRef="sid-156246B5-C81C-4AAB-A183-FCA197EC6901" />
24 
25   </process>
26 
27   <bpmndi:BPMNDiagram id="BPMNDiagram_receiveTaskprocess">
28 
29     <bpmndi:BPMNPlane bpmnElement="receiveTaskprocess" id="BPMNPlane_receiveTaskprocess">
30 
31       <bpmndi:BPMNShape bpmnElement="sid-4AF5399C-5241-4F58-BE58-6B2D0A1249D2" id="BPMNShape_sid-4AF5399C-5241-4F58-BE58-6B2D0A1249D2">
32 
33         <omgdc:Bounds height="30.0" width="30.0" x="173.75" y="107.0" />
34 
35       </bpmndi:BPMNShape>
36 
37       <bpmndi:BPMNShape bpmnElement="receiveTask" id="BPMNShape_receiveTask">
38 
39         <omgdc:Bounds height="80.0" width="100.0" x="324.75" y="81.0" />
40 
41       </bpmndi:BPMNShape>
42 
43       <bpmndi:BPMNShape bpmnElement="sid-156246B5-C81C-4AAB-A183-FCA197EC6901" id="BPMNShape_sid-156246B5-C81C-4AAB-A183-FCA197EC6901">
44 
45         <omgdc:Bounds height="28.0" width="28.0" x="469.75" y="107.0" />
46 
47       </bpmndi:BPMNShape>
48 
49       <bpmndi:BPMNEdge bpmnElement="sid-46A38F6A-4413-48E2-ADAA-5DC86682086C" id="BPMNEdge_sid-46A38F6A-4413-48E2-ADAA-5DC86682086C">
50 
51         <omgdi:waypoint x="203.7497832166316" y="121.91935600421166" />
52 
53         <omgdi:waypoint x="324.75" y="121.26881720430107" />
54 
55       </bpmndi:BPMNEdge>
56 
57       <bpmndi:BPMNEdge bpmnElement="sid-2CCD7E71-70FE-418C-8365-5CD7636E9657" id="BPMNEdge_sid-2CCD7E71-70FE-418C-8365-5CD7636E9657">
58 
59         <omgdi:waypoint x="424.75" y="121.0" />
60 
61         <omgdi:waypoint x="469.75" y="121.0" />
62 
63       </bpmndi:BPMNEdge>
64 
65     </bpmndi:BPMNPlane>
66 
67   </bpmndi:BPMNDiagram>
68 
69 </definitions>

給該流程設置一個監聽器，用來監聽流程是否執行：

 1 /**
 2 
 3  *
 4 
 5  */
 6 
 7 package light.mvc.workflow.serviceTask;
 8 
 9  
10 
11 import org.activiti.engine.delegate.DelegateExecution;
12 
13 import org.activiti.engine.delegate.JavaDelegate;
14 
15  
16 
17 /**  
18 
19  *   
20 
21  * 項目名稱：lightmvc  
22 
23  * 類名稱：ServiceTask  
24 
25  * 類描述：  
26 
27  * 創建人：鄧家海  
28 
29  * 創建時間：2017年6月4日 下午6:18:11  
30 
31  * 修改人：deng  
32 
33  * 修改時間：2017年6月4日 下午6:18:11  
34 
35  * 修改備註：  
36 
37  * @version   
38 
39  *   
40 
41  */
42 
43  
44 
45 public class receiveTestRunningTask implements JavaDelegate{
46 
47  
48 
49 //重寫委托的提交方法
50 
51 @Override
52 
53 public void execute(DelegateExecution execution) throws Exception {
54 
55 //receiveTaskprocess
56 
57 System.out.println("receiveTestRunningTask is running！");
58 
59 }
60 
61  
62 
63 }

在這裏，我們通過一個手動任務來啟動這個接受任務。

手動任務流程設計：

技術分享

手動任務源碼：

 1 <?xml version=‘1.0‘ encoding=‘UTF-8‘?>
 2 
 3 <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/processdef">
 4 
 5   <process id="process" isExecutable="true">
 6 
 7     <startEvent id="sid-8D52A572-DD68-4640-BCEE-AA46FD19F535" />
 8 
 9     <manualTask id="sid-B57FA289-A98B-45B8-8550-211ED155778E" name="手工任務">
10 
11       <extensionElements>
12 
13         <activiti:executionListener event="start" class="light.mvc.workflow.serviceTask.TestRunningTask" />
14 
15       </extensionElements>
16 
17     </manualTask>
18 
19     <endEvent id="sid-DF898F06-5F35-4C64-B84D-6A405ADECA91" />
20 
21     <sequenceFlow id="sid-BD48A7F5-D206-4E76-AB78-0437FBDC5834" sourceRef="sid-B57FA289-A98B-45B8-8550-211ED155778E" targetRef="sid-DF898F06-5F35-4C64-B84D-6A405ADECA91" />
22 
23     <sequenceFlow id="sid-6F9CC662-16AB-4058-BA4A-2A0D3D99C185" sourceRef="sid-8D52A572-DD68-4640-BCEE-AA46FD19F535" targetRef="sid-B57FA289-A98B-45B8-8550-211ED155778E" />
24 
25   </process>
26 
27   <bpmndi:BPMNDiagram id="BPMNDiagram_process">
28 
29     <bpmndi:BPMNPlane bpmnElement="process" id="BPMNPlane_process">
30 
31       <bpmndi:BPMNShape bpmnElement="sid-8D52A572-DD68-4640-BCEE-AA46FD19F535" id="BPMNShape_sid-8D52A572-DD68-4640-BCEE-AA46FD19F535">
32 
33         <omgdc:Bounds height="30.0" width="30.0" x="233.75" y="102.0" />
34 
35       </bpmndi:BPMNShape>
36 
37       <bpmndi:BPMNShape bpmnElement="sid-B57FA289-A98B-45B8-8550-211ED155778E" id="BPMNShape_sid-B57FA289-A98B-45B8-8550-211ED155778E">
38 
39         <omgdc:Bounds height="80.0" width="100.0" x="375.0" y="77.0" />
40 
41       </bpmndi:BPMNShape>
42 
43       <bpmndi:BPMNShape bpmnElement="sid-DF898F06-5F35-4C64-B84D-6A405ADECA91" id="BPMNShape_sid-DF898F06-5F35-4C64-B84D-6A405ADECA91">
44 
45         <omgdc:Bounds height="28.0" width="28.0" x="630.0" y="103.0" />
46 
47       </bpmndi:BPMNShape>
48 
49       <bpmndi:BPMNEdge bpmnElement="sid-BD48A7F5-D206-4E76-AB78-0437FBDC5834" id="BPMNEdge_sid-BD48A7F5-D206-4E76-AB78-0437FBDC5834">
50 
51         <omgdi:waypoint x="475.0" y="117.0" />
52 
53         <omgdi:waypoint x="630.0" y="117.0" />
54 
55       </bpmndi:BPMNEdge>
56 
57       <bpmndi:BPMNEdge bpmnElement="sid-6F9CC662-16AB-4058-BA4A-2A0D3D99C185" id="BPMNEdge_sid-6F9CC662-16AB-4058-BA4A-2A0D3D99C185">
58 
59         <omgdi:waypoint x="263.75" y="117.0" />
60 
61         <omgdi:waypoint x="375.0" y="117.0" />
62 
63       </bpmndi:BPMNEdge>
64 
65     </bpmndi:BPMNPlane>
66 
67   </bpmndi:BPMNDiagram>
68 
69 </definitions>
 1 <?xml version=‘1.0‘ encoding=‘UTF-8‘?>
 2 
 3 <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/processdef">
 4 
 5   <process id="process" isExecutable="true">
 6 
 7     <startEvent id="sid-8D52A572-DD68-4640-BCEE-AA46FD19F535" />
 8 
 9     <manualTask id="sid-B57FA289-A98B-45B8-8550-211ED155778E" name="手工任務">
10 
11       <extensionElements>
12 
13         <activiti:executionListener event="start" class="light.mvc.workflow.serviceTask.TestRunningTask" />
14 
15       </extensionElements>
16 
17     </manualTask>
18 
19     <endEvent id="sid-DF898F06-5F35-4C64-B84D-6A405ADECA91" />
20 
21     <sequenceFlow id="sid-BD48A7F5-D206-4E76-AB78-0437FBDC5834" sourceRef="sid-B57FA289-A98B-45B8-8550-211ED155778E" targetRef="sid-DF898F06-5F35-4C64-B84D-6A405ADECA91" />
22 
23     <sequenceFlow id="sid-6F9CC662-16AB-4058-BA4A-2A0D3D99C185" sourceRef="sid-8D52A572-DD68-4640-BCEE-AA46FD19F535" targetRef="sid-B57FA289-A98B-45B8-8550-211ED155778E" />
24 
25   </process>
26 
27   <bpmndi:BPMNDiagram id="BPMNDiagram_process">
28 
29     <bpmndi:BPMNPlane bpmnElement="process" id="BPMNPlane_process">
30 
31       <bpmndi:BPMNShape bpmnElement="sid-8D52A572-DD68-4640-BCEE-AA46FD19F535" id="BPMNShape_sid-8D52A572-DD68-4640-BCEE-AA46FD19F535">
32 
33         <omgdc:Bounds height="30.0" width="30.0" x="233.75" y="102.0" />
34 
35       </bpmndi:BPMNShape>
36 
37       <bpmndi:BPMNShape bpmnElement="sid-B57FA289-A98B-45B8-8550-211ED155778E" id="BPMNShape_sid-B57FA289-A98B-45B8-8550-211ED155778E">
38 
39         <omgdc:Bounds height="80.0" width="100.0" x="375.0" y="77.0" />
40 
41       </bpmndi:BPMNShape>
42 
43       <bpmndi:BPMNShape bpmnElement="sid-DF898F06-5F35-4C64-B84D-6A405ADECA91" id="BPMNShape_sid-DF898F06-5F35-4C64-B84D-6A405ADECA91">
44 
45         <omgdc:Bounds height="28.0" width="28.0" x="630.0" y="103.0" />
46 
47       </bpmndi:BPMNShape>
48 
49       <bpmndi:BPMNEdge bpmnElement="sid-BD48A7F5-D206-4E76-AB78-0437FBDC5834" id="BPMNEdge_sid-BD48A7F5-D206-4E76-AB78-0437FBDC5834">
50 
51         <omgdi:waypoint x="475.0" y="117.0" />
52 
53         <omgdi:waypoint x="630.0" y="117.0" />
54 
55       </bpmndi:BPMNEdge>
56 
57       <bpmndi:BPMNEdge bpmnElement="sid-6F9CC662-16AB-4058-BA4A-2A0D3D99C185" id="BPMNEdge_sid-6F9CC662-16AB-4058-BA4A-2A0D3D99C185">
58 
59         <omgdi:waypoint x="263.75" y="117.0" />
60 
61         <omgdi:waypoint x="375.0" y="117.0" />
62 
63       </bpmndi:BPMNEdge>
64 
65     </bpmndi:BPMNPlane>
66 
67   </bpmndi:BPMNDiagram>
68 
69 </definitions>

給該流程設置一個監聽器，用來通知接受任務繼續往下執行。

 1 /**
 2 
 3  *
 4 
 5  */
 6 
 7 package light.mvc.workflow.serviceTask;
 8 
 9  
10 
11 import java.util.List;
12 
13  
14 
15 import org.activiti.engine.delegate.DelegateExecution;
16 
17 import org.activiti.engine.delegate.JavaDelegate;
18 
19 import org.activiti.engine.runtime.Execution;
20 
21  
22 
23 /**  
24 
25  *   
26 
27  * 項目名稱：lightmvc  
28 
29  * 類名稱：ServiceTask  
30 
31  * 類描述：  
32 
33  * 創建人：鄧家海  
34 
35  * 創建時間：2017年6月4日 下午6:18:11  
36 
37  * 修改人：deng  
38 
39  * 修改時間：2017年6月4日 下午6:18:11  
40 
41  * 修改備註：  
42 
43  * @version   
44 
45  *   
46 
47  */
48 
49  
50 
51 public class TestRunningTask implements JavaDelegate{
52 
53  
54 
55 //重寫委托的提交方法
56 
57 @Override
58 
59 public void execute(DelegateExecution execution) throws Exception {
60 
61 //receiveTaskprocess
62 
63 List<Execution> executions= execution.getEngineServices().getRuntimeService().createExecutionQuery().processDefinitionKey("receiveTaskprocess")
64 
65 .activityId("receiveTask").list();
66 
67 for(Execution e:executions){
68 
69 execution.getEngineServices().getRuntimeService().signal(e.getId());
70 
71 }
72 
73  
74 
75 System.out.println("TestRunningTask is running！");
76 
77 }
78 
79  
80 
81 }

1）首先部署啟動接受任務，這個時候，接受任務處於等待的狀態

2）然後啟動手動任務，手動任務執行，觸發監聽類，監聽類通知接受任務執行，手動任務結束

3）接受任務收到信號，繼續往下執行，結束

4）整個過程結束。

運行結果：

技術分享

可以看到，兩個監聽器都完成了。下面我們可以用一個圖示來解釋這整個過程：

技術分享

Activiti接受任務（receiveTask）

相關推薦

Activiti接受任務（receiveTask）

image eve 持久化數據 wait 手動 手工 修改時間 workflow otn Activiti接受任務（receiveTask） 作者：鄧家海 前言： Activiti接受任務（receiveTask）其實和Activiti的手動任務是差不多的，不過手動任務是直

05-接受任務（receiveTask）

接收任務（receiveTask） 接收任務（ReceiveTask）即等待任務，接收任務是一個簡單任務，它會等待對應訊息的到達。 當流程達到接收任務，流程狀態會儲存到資料庫中。 在任務建立後，意味著流程會進入等待狀態，直到引擎接收了一個特定的訊息， 這會觸發流程穿

Activiti進階（九）——接收任務（ReceiveTask）

接收任務（ReceiveTask）即等待任務，接收任務是一個簡單任務，它會等待對應訊息的到達。當前，官方只實現 了這個任務的java語義。 當流程達到接收任務，流程狀態會儲存到資料庫中。在任務建立後，意味著流程會進入等 待狀態，直到引擎接收了一個特定的訊息， 這會觸發流程穿過接收任務繼續執行

Activiti的學習（四）——流程變數操作、任務型別

ProcessEngine pe = null; @Before public void init() { pe = ProcessEngines.getDefaultProcessEngine(); } 一、流程變數操作 流程變數指的是

去哪網實習總結：開發定時任務（JavaWeb）

pri simple mod 節點 easy run dsm 16px 發送郵件 本來是以做數據挖掘的目的進去哪網的，結構卻成了系統開發。。。 只是還是比較認真的做了三個月，老師非常認同我的工作態度和成果。。。 實習立即就要結束了。總結一下幾點之前沒有註意過的變成

Spark轉GemFire任務（二）

rip spec parent region turn source desc 6.2 include ADMG-2.2.1.3 - BRAVO CoA Mapping - TB Revision 7/11: If Bravo code is not numeric,

Spark轉GemFire任務（一）

pin val found reg for ever have class chan ADMG-40 2.2.2.4 - Global Tax Warehouse (GTW) CoA mapping -- Both BtB and Project 1 Revision

MYSQL-定時任務（event）

mysql 定時 之前刪除數據或者是更改數據都是在服務器上寫個腳本跑定時任務，crontab寫了很多任務； mysql 5.1之後支持事件之後可以很方便的去執行了； 例如我要每天晚上23點去清空clients表； 查看mysql是否開啟事件； show variables like ‘event_s

linux===linux後臺運行和關閉、查看後臺任務（轉）

我們 top 實現 目錄 這樣的 作業 net 超級 運行命令 fg、bg、jobs、&、ctrl + z都是跟系統任務有關的，雖然現在基本上不怎麽需要用到這些命令，但學會了也是很實用的 一。& 最經常被用到這個用在一個命令的最後，可以把這個命令放到後臺執

Navicat for MySQL 設置定時任務（事件）

schedule 定義 all ever -- star 命令 update nbsp 1.查詢界面輸入命令，查看定時任務是否開啟，未開始時OFF： show variables like ‘%event_scheduler%‘; 2. 查詢界面輸入命令，開啟定時任務： s

ORACLE RAC部署實錄準備任務（二）：BIND（DNS）

bind dns [root@bind ~]# yum install bind [root@bind ~]# vi /etc/named.conf // // named.conf // // Provided by Red Hat bind package to configure the IS

linux計劃任務（轉）

level 郵件 file 配置 nta 但是 路徑和 去掉 無法自動 文章轉自https://blog.csdn.net/jixieyang3701/article/details/79410725 linux 系統則是由 cron (crond) 這個系統服務來控制的。

Django搭配Celery進行非同步/定時任務（一）初步搭建

以下需求場景很常見： 1. 使用者點選頁面按鈕，請求後臺進行一系列耗時非常高的操作，頁面沒有響應/一直Loading，使用者體驗非常不好。 2. 某些資料需要預先處理，每天凌晨的時候進行運算，大約半小時到1小時才能完成。 3. 進行外部系統的介面資料呼叫，介面要求在10秒內返回應答報

Activiti學習筆記（六）Activiti的流程引擎API和服務

引擎API是與Activiti互動的最常見方式。中心起點是ProcessEngine，可以通過多種方式建立，如《Activiti學習筆記（三）獲取ProcessEngine物件的多種方式》。 從ProcessEngine中，可以獲得包含工作流BPM方法的各種服務。一下是Activiti的模型圖 一共有

程式中任務（中斷）間共享資源（臨界區）的保護和互斥

一、軟體法   1.輪轉法 p0 程序： while(turn != 0); //進入區 critical section ; //臨界區 turn = 1;

arcgis 執行查詢任務（QueryTask）還有ExecuteAsync？需進一步瞭解

url = string.Format("http://{0}/arcgis2/rest/services/baidu/MapServer/{1}", ip, layerID);                 QueryTask queryTask = new QueryT

06-使用者任務（userTask）

使用者任務（userTask） 1. 個人任務 1.1 分配個人任務方式一（直接指定辦理人） 1.2 分配個人任務方式二（使用流程變數） 1.3 分配個人任務方式三（使用類） 1.4 個人任務總結 2. 組任務

Activiti的學習（六）——閘道器

閘道器用來控制流程的流向。 閘道器顯示成菱形圖形，內部有有一個小圖示。 圖標表示閘道器的型別。 一、排他閘道器（ExclusiveGateWay） 排他閘道器（也叫異或（XOR）閘道器，或更技術性的叫法 基於資料的排他閘道器）， 用來在流程中實現決策。 圖形標記 排他閘道器

Activiti的學習（五）——監聽器

在流程中我們有時會對整個流程或者一個節點的某種狀態做出相應的處理。這時就會用到監聽器。 在Activiti中流程的監聽主要分為兩大類，執行監聽器和任務監聽器。 一、執行監聽器（ExecutionListener） 執行監聽器可以執行外部java程式碼或執行表示式，當流程定義中發生了某個事

Activiti的學習（三）——Activiti詳細API

建立測試類，先載入流程引擎核心物件： ProcessEngine processEngine = null; @Before public void init() { processEngine = ProcessEngines.getDefaultPr