概述

Human Task 是BPM流程中的節點必需通過人為的手動操作才能夠執行。jBPM 5 通過 User Task（jBPM5示例之 User Task） 節點來支援Human Task。Human Task通常要求流程設計者在設計流程時指定流程執行相關的屬性，流程型別，流程的執行者，流程執行相關的資料。流程執行時我們根據這些屬性執行流程。

Human Task 是BPM核心，為什麼可以這樣說呢？一位BPM專家曾在某次BPM技術峰會上這樣定義BPM：“BPM is a blending of process management/workflow with application integration technology...to support rich human interaction and deep application connectivity”。注意他所表達BPM的目的或價值就是為複雜的企業應用提供廣泛的人為操作的可能性。

本文主要目的是通過實驗理解jBPM Human Task ，我們所需要的工具包括git，Maven，JBoss等，這些安裝可參照軟體安裝及資料下載。本文主要內容包括：

• 下載編譯jBPM Human Task 程式碼
• 部署jBPM Human Task 服務到JBoss
• jBPM Human Task 資料模型
• 通過TaskClient與Human Task 服務端互動
• Human Task的生命週期

下載編譯jBPM Human Task 程式碼

git clone --branch=5.2.x [email protected]:droolsjbpm/jbpm.git

克隆完成使用如下maven命令編譯jBPM 5.2.x程式碼：

mvn clean install -Dmaven.test.skip=true
 

如以上步驟沒有出現錯誤則該部分完成，我們需要如下編譯生成的包或Maven本地倉庫中的包來供我們使用：

• jbpm-human-task-war-5.2.6-SNAPSHOT-EE6.war - 位於jbpm-human-task-war/target目錄下

部署jBPM Human Task 服務到JBoss

本部分我們部署jbpm-human-task-war-5.2.6-SNAPSHOT-EE6.war到JBoss 7。具體參照使用4種方式部署應用到JBoss7/WildFly。

我們需要基於jbpm-human-task-war-5.2.6-SNAPSHOT-EE6.war做如下操作：

1. 重新命名

unzip jbpm-human-task-war-5.2.6-SNAPSHOT-EE6.war jbpm-human-task.war

2. 建立資料庫

jBPM Human Task執行過程需要儲存資料在資料庫中，我們本實驗使用mysql資料庫，我們使用如下SQL語句建立資料庫jbpm，jbpm_user用來操作資料庫jbpm，jbpm_user對應密碼jbpm_pass：

CREATE DATABASE jbpm;  
create user 'jbpm_user'@'localhost' identified by 'jbpm_pass';  
grant all on jbpm.* to [email protected]'localhost';  
FLUSH PRIVILEGES;

3. 建立jbpmDS資料來源

使用JBoss 7/WildFly中配置使用Mysql資料庫中描述的方法建立資料來源jbpmDS指向上面步驟2建立的資料庫和使用者，資料來源如下：

<datasource jndi-name="java:jboss/datasources/jbpmDS" pool-name="jbpmPool">  
      <connection-url>jdbc:mysql://localhost:3306/jbpm</connection-url>  
      <driver>mysql</driver>  
      <security>  
         <user-name>jbpm_user</user-name>  
         <password>jbpm_pass</password>  
      </security>  
</datasource> 

4. 修改persistence.xml

修改jbpm-human-task.war/WEB-INF/classes/META-INF/persistence.xml檔案，配置hibernate.dialect屬性為org.hibernate.dialect.MySQL5Dialect，hibernate.show_sql屬性為true。

5. 更新hornetq-core-2.2.10.Final.jar

這一步是可選擇的，hornetq-core-2.2.10.Final.jar包存在Socket leak等不穩定問題，我建議升級此包。

6. 啟動JBoss

使用JBoss啟動指令碼./standalone.sh啟動JBoss，啟動完成後可以看到jbpm-human-task.war部署成功提示。我們會發現如下日誌資訊：

17:19:07,950 INFO  [stdout] (ServerService Thread Pool -- 52) Task service startup completed successfully !

使用netstat命令，輸出所有埠使用情況：

[[email protected] lib]$ netstat -antulop | grep 13179
(Not all processes could be identified, non-owned process info
 will not be shown, you would have to be root to see it all.)
tcp        0      0 127.0.0.1:4447              0.0.0.0:*                   LISTEN      13179/java          off (0.00/0/0)
tcp        0      0 127.0.0.1:5153              0.0.0.0:*                   LISTEN      13179/java          off (0.00/0/0)
tcp        0      0 127.0.0.1:9990              0.0.0.0:*                   LISTEN      13179/java          off (0.00/0/0)
tcp        0      0 127.0.0.1:9999              0.0.0.0:*                   LISTEN      13179/java          off (0.00/0/0)
tcp        0      0 127.0.0.1:8080              0.0.0.0:*                   LISTEN      13179/java          off (0.00/0/0)
tcp        0      0 127.0.0.1:44186             127.0.0.1:5153              ESTABLISHED 13179/java          keepalive (5695.77/0/0)
tcp        0      0 127.0.0.1:34368             127.0.0.1:3306              ESTABLISHED 13179/java          keepalive (5695.77/0/0)
tcp        0      0 127.0.0.1:5153              127.0.0.1:44186             ESTABLISHED 13179/java          keepalive (5695.77/0/0)

注意，5153為 Human Task Service在伺服器端監聽的埠。

jBPM Human Task 資料模型

上面一部分中，我們建立了空白的資料庫jbpm,jBPM使用JPA/Hobernate作為資料持久工具，當JBoss啟動成功後Hibernate會向資料庫jbpm建立表，我們在mysql管理端使用jbpm_user使用者登入後查看錶建立情況。

show tables輸出：

mysql> show tables;
+--------------------------------+
| Tables_in_jbpm                 |
+--------------------------------+
| Attachment                     |
| BooleanExpression              |
| Content                        |
| Deadline                       |
| Delegation_delegates           |
| Escalation                     |
| I18NText                       |
| Notification                   |
| Notification_BAs               |
| Notification_Recipients        |
| Notification_email_header      |
| OrganizationalEntity           |
| PeopleAssignments_BAs          |
| PeopleAssignments_ExclOwners   |
| PeopleAssignments_PotOwners    |
| PeopleAssignments_Recipients   |
| PeopleAssignments_Stakeholders |
| Reassignment                   |
| Reassignment_potentialOwners   |
| SubTasksStrategy               |
| Task                           |
| email_header                   |
| task_comment                   |
+--------------------------------+
23 rows in set (0.00 sec)

即jBPM執行Human Task所需要的表共23個。

我們在jbpm human task 原始碼分析 - I的org.jbpm.task.Task部分解釋了資料模型類，以上這些表是資料實體模型對應資料庫中表的對映。接下來的一個部分我們演示如何使用jBPM Human Task Service提供的介面對資料庫中的資料進行操作。

通過TaskClient與Human Task 服務端互動

在之前步驟的基礎上，本處我們通過TaskClient與Human Task 服務端互動，建立Task，開始Task，結束Task。

建立Task

	TaskClient client = getTaskClientInstance();
        client.connect();
		
        Task task = newTask();
        ContentData content = new ContentData();
        
        BlockingAddTaskResponseHandler addTaskResponseHandler = new BlockingAddTaskResponseHandler();
        client.addTask(task, content, addTaskResponseHandler );
        long taskId = addTaskResponseHandler.getTaskId();
        System.out.println("Add Task to human task service, taskId: " + taskId);

以Java Application的方式執行org.jbpm.conductor.humantask.TaskAdd輸出

Add Task to human task service, taskId: 1

在Mysql資料庫端通過SQL語句查詢得到如下結果：

mysql> select id, status, actualOwner_id, createdBy_id, activationTime from Task;
+----+----------+----------------+--------------+---------------------+
| id | status   | actualOwner_id | createdBy_id | activationTime      |
+----+----------+----------------+--------------+---------------------+
|  1 | Reserved | kylin          | kylin        | 2013-12-02 16:51:24 |
+----+----------+----------------+--------------+---------------------+

獲取Task

        TaskClient client = getTaskClientInstance();
        client.connect();
        
        BlockingTaskSummaryResponseHandler taskSummaryResponseHandler = new BlockingTaskSummaryResponseHandler();
        client.getTasksAssignedAsPotentialOwner("kylin", "en-UK", taskSummaryResponseHandler);
        List<TaskSummary> tasks = taskSummaryResponseHandler.getResults();
        System.out.println("Getting tasks for human task service via user kylin, tasks size: " + tasks.size());

以Java Application的方式執行org.jbpm.conductor.humantask.TaskGetting輸出

Getting tasks for human task service via user kylin, tasks size: 1

開始Task

        TaskClient client = getTaskClientInstance();
        client.connect();
        
        BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
        client.start(1, "kylin", responseHandler);
        responseHandler.waitTillDone(1000);
        System.out.println("kylin starting Task ");

以Java Application的方式執行org.jbpm.conductor.humantask.TaskStart輸出

kylin starting Task

在Mysql資料庫端通過SQL語句查詢得到如下結果：

mysql> select id, status, actualOwner_id, createdBy_id, activationTime from Task;
+----+------------+----------------+--------------+---------------------+
| id | status     | actualOwner_id | createdBy_id | activationTime      |
+----+------------+----------------+--------------+---------------------+
|  1 | InProgress | kylin          | kylin        | 2013-12-02 16:51:24 |
+----+------------+----------------+--------------+---------------------+

完成Task

        TaskClient client = getTaskClientInstance();
        client.connect();
    
        ContentData content = new ContentData();
        
        BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
        client.complete(2, "kylin", content, responseHandler);
        responseHandler.waitTillDone(1000);
        System.out.println("kylin completing Task ");

以Java Application的方式執行org.jbpm.conductor.humantask.TaskComplete輸出

kylin completing Task

在Mysql資料庫端通過SQL語句查詢得到如下結果：

mysql> select id, status, actualOwner_id, createdBy_id, activationTime from Task;
+----+-----------+----------------+--------------+---------------------+
| id | status    | actualOwner_id | createdBy_id | activationTime      |
+----+-----------+----------------+--------------+---------------------+
|  1 | Completed | kylin          | kylin        | 2013-12-02 16:51:24 |
+----+-----------+----------------+--------------+---------------------+

另外我們還可以使用如下SQL在Mysql管理端進行管理查詢：

select DTYPE, id from OrganizationalEntity;
select id, language, text from I18NText;

Human Task的生命週期

當一個 Human Task 節點在流程執行過程中被啟用，一個人為參與的工作產生，流程只有在該人為參與的工作完成或取消後才離開該節點。

Human Task 的生命週期如下：

1. Task被建立，一開始狀態為'created'
2. Task狀態通常會自動轉變為'Ready'，該狀態的Task會在Task列表中，可以被使用者請求
3. Task被使用者請求，狀態變為'Reserved'
4. Task被使用者開始，狀態變為'InProgress'
5. Task被使用者結束，狀態變成'Completed'，如果使用者不能夠結束Task，會返回一個錯誤的結果，這樣Task狀態變成'Failed'

Next