首頁新文章聯(lián)系

posts - 96,comments - 52,trackbacks - 0

2008年11月

>

日

一

二

三

四

五

六

26

27

28

29

30

31

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

1

2

3

4

5

6

常用鏈接

隨筆分類

隨筆檔案

友情鏈接

www.modaotea.com
茶藝培訓(xùn) 茶樓管理
www.website371.com
鄭州做網(wǎng)站鄭州網(wǎng)站建設(shè) 鄭州做網(wǎng)站公司鄭州網(wǎng)站優(yōu)化鄭州網(wǎng)站制作
河南省大井科技有限公司(www.zzgwt.com)

搜索

積分與排名

積分 - 151632
排名 - 404

最新評論

1.?re: 正則表達(dá)式學(xué)習(xí)筆記（1）行的開始和結(jié)束、字符組、連字符、脫字符、用"."去匹配任意字符
贊
--性感電子
2.?re: Apache httpd+Jk+Tomcat實現(xiàn)JAVA服務(wù)器配置全解析（1）：基礎(chǔ)環(huán)境搭建
什么嘛，我就是不懂這些才搜索的，我最需要的就是你省略的部分，如何配置安裝，唉，又得繼續(xù)找資料了。
--吐槽
3.?re: JavaScript學(xué)習(xí)筆記（1）變量的生命周期
寫的很好
--fwd
4.?re: SELinux學(xué)習(xí)（1）：Can't connect to MySQL server on 'ip' (13) 的解決方案
沒玩過這東西啊呵呵
--臺式萬用表
5.?re: [原創(chuàng)]巧用System.getProperty()編譯現(xiàn)有工程的java文件
你不能用ANT嗎？
--DB Compare Tool

[原創(chuàng)]JBPM實踐之：并發(fā)子流程的實現(xiàn)

         關(guān)于JBPM中并發(fā)子流程的實現(xiàn)方式，網(wǎng)上有很多的說法，但是好像每種辦法都有這樣那樣的缺點，要么實現(xiàn)太復(fù)雜，要么就是會使Token無法繼續(xù)流轉(zhuǎn)。這里我介紹一種我的并發(fā)子流程的實現(xiàn)方式：使用TaskNode使任務(wù)并行的方式，模擬實現(xiàn)JBPM子流程的并發(fā)執(zhí)行。
我先簡單的介紹一下實現(xiàn)思路：
         1、數(shù)據(jù)庫中應(yīng)該有至少三個已經(jīng)發(fā)布過的流程定義(ProcessDefinition)，發(fā)布的順序無所謂，一個主流程兩個子流程
         2、我們在主流程中要實現(xiàn)并發(fā)子流程的環(huán)節(jié)放置TaskNode，設(shè)置create-tasks="false"、signal="last-wait"
         3、我們想要實現(xiàn)幾個子流程的并發(fā)就在第二步放置的TaskNode中放置幾個Task，每個Task的名字都是要并發(fā)的子流程的名稱
         4、在TaskNode的Node-Enter action中，我們手動為每一個Task創(chuàng)建一個任務(wù)實例，同時我們?nèi)〉肨ask的名字也就是要并發(fā)的子流程的名字，創(chuàng)建流程實例
         5、為每個新創(chuàng)建的流程實例設(shè)置流程變量：TaskInstanceID表示創(chuàng)建當(dāng)前子流程的那個主流程任務(wù)實例ID，并使子流程開始流轉(zhuǎn)
         6、子流程結(jié)束，取得流程變量TaskInstanceID，該流程變量TaskInstanceID是創(chuàng)建他的那個主流程的任務(wù)實例，得到該TaskInstance,并TaskInstance.end();
         這個時候因為我們設(shè)置了TaskNode的Signal為"last-wait"，所以當(dāng)所有的子流程均結(jié)束的時候，主流程才會繼續(xù)，這樣我們也就實現(xiàn)了子流程的并發(fā)效果。很簡單的一個思路實現(xiàn)起來也并不復(fù)雜.

    首先讓我們看一下主流程的流程定義：

1

<?xml version="1.0" encoding="UTF-8"?>
2

<process-definition xmlns="" name="super1">
3

<start-state name="start-state1">
4

<transition to="task-node1"></transition>
5

</start-state>
6

7

<task-node name="task-node1" create-tasks="false" signal="last-wait">
8

<description>
9

我們要利用這個TaskNode實現(xiàn)并發(fā)子流程，create-tasks="true"是為了可以手動控制任務(wù)實例的創(chuàng)建，同時創(chuàng)建子流程，
10

signal="last-wait"是為了實現(xiàn)當(dāng)所有子流程均已完成，主流程才能繼續(xù)運(yùn)行的效果
11

</description>
12

<task name="sub1">
13

<description>要并發(fā)的子流程之一</description>
14

</task>
15

<task name="sub2">
16

<description>要并發(fā)的子流程之二</description>
17

</task>
18

<event type="node-enter">
19

<action name="NodeEnterAction" class="jbpmTest.bfzlc.action.NodeEnterAction"></action>
20

</event>
21

<transition to="end-state1"></transition>
22

</task-node>
23

24

<end-state name="end-state1"></end-state>
25

26

<event type="process-start">
27

System.out.println("主流程啟動，并設(shè)置主流程ID");
29

</script>
30

</event>
31

<event type="process-end">
32

System.out.println("主流程結(jié)束");
34

</script>
35

</event>
36

</process-definition>

下面是主流程的Node-EnterAction的代碼：

1

public class NodeEnterAction implements ActionHandler {
2

3

public void execute(ExecutionContext executionContext) throws Exception {
4

//取得本節(jié)點所有的Task
5

Set<Task> tasks = ((TaskNode)executionContext.getNode()).getTasks();
6

7

TaskMgmtInstance tgmt = executionContext.getTaskMgmtInstance();
8

9

for (Task task : tasks) {
10

//為每一個Task創(chuàng)建實例
11

TaskInstance taskInstance = tgmt.createTaskInstance(task, executionContext);
12

//業(yè)務(wù)Service
13

JbpmTestFacade jbpmTestFacade = ((JbpmTestFacade)SpringBeanUtil.getBean("jbpmTestFacade"));
14

//根據(jù)Task的名字，為每一個Task創(chuàng)建相應(yīng)的子流程
15

ProcessInstance processInstance = jbpmTestFacade.createProcessInstance(task.getName());
16

//設(shè)置創(chuàng)建這個子流程的流程實例ID
17

processInstance.getContextInstance().setVariable("TaskInstanceID", taskInstance.getId());
18

//子流程開始流轉(zhuǎn)
19

processInstance.signal();
20

}
21

22

}
23

}

再看其中一個子流程的定義：

1

<?xml version="1.0" encoding="UTF-8"?>
2

<process-definition xmlns="" name="sub1">
3

<start-state name="start-state1">
4

<transition to="Sub1Task"></transition>
5

</start-state>
6

7

<task-node name="Sub1Task">
8

<task name="SubTask1"></task>
9

<transition to="end-state1"></transition>
10

</task-node>
11

12

<end-state name="end-state1"></end-state>
13

14

<event type="process-start">
15

System.out.println("-------------------sub1流程啟動------------------------------");
17

</script>
18

</event>
19

20

<event type="process-end">
21

<action name="SubProcessEndAction" class="jbpmTest.bfzlc.action.SubProcessEndAction"></action>
22

</event>
23

</process-definition>
24

下面是該子流程的ProcessEndAction：

1

public class SubProcessEndAction implements ActionHandler {
2

3

public void execute(ExecutionContext executionContext) throws Exception {
4

System.out.println(executionContext.getProcessDefinition().getName()+"結(jié)束

");
5

//得到創(chuàng)建當(dāng)前子流程的那個TaskInstanceID
6

String taskInstanceID = executionContext.getContextInstance().getVariable("TaskInstanceID").toString();
7

8

//業(yè)務(wù)Service
9

JbpmTestFacade jbpmTestFacade = ((JbpmTestFacade)SpringBeanUtil.getBean("jbpmTestFacade"));
10

//取得創(chuàng)建當(dāng)前子流程的那個主流程taskInstance
11

TaskInstance taskInstance = jbpmTestFacade.geTaskInstance(Long.valueOf(taskInstanceID));
12

taskInstance.end();
13

}
14

15

}

     思路很清楚，代碼也很簡單，按照這種方式我們可以讓子流程實現(xiàn)所有Task能實現(xiàn)的功能。

    文章原創(chuàng)，轉(zhuǎn)載請注明出處！

posted on 2008-11-12 15:00 零全零美閱讀(3323) 評論(6) 編輯收藏所屬分類: jbpm

FeedBack: