一、 引言
在developerWorks中，有許多文章介紹了WPS和WID在流程整合中的應用，比如BPEL開發、CEI監控和selector等等，那么，在實際的應用中，通常會有這樣的場景：流程調用的一些第三方系統都是需要人工去審批，流程引擎發出調用第三方系統的請求后，是一個需要人審批的長流程（Long-runing process）。因此，這個調用是一個異步調用，只有第三方系統把審批結果傳回給主流程，流程才能繼續往下運行。這和直接在BPEL中直接實現的human task節點是不同的，因為用到了SCA組件的裝配技術。
本文將詳細介紹如何在WPS中利用SCA的編程模型實現human task manager對第三方系統的調用，并通過實際的例子加以說明，使讀者能夠掌握使用SCA和human task manager來實現對第三方系統的異步調用。
二、產品及其基本技術框架簡介
1 WebSphere Process Server及其開發工具Integration Developer
WebSphere Process Server V 6.0（WebSphere流程服務器V 6.0）基于SOA體系架構并提供了統一的、簡化的編程模型，是新一代的業務流程服務器，能夠幫助我們基于SOA架構模型實現企業的業務流程轉型。WebSphere流程服務器采用基于開放標準的技術來整合業務流程，實現自動化的流程服務器。采用WebSphere流程服務器可以通過統一的編程模型將企業的人員、工作流程、應用、系統、平臺和基礎設施整合在一起。
基于Eclipse技術的WPS專用開發工具WebSphere Integration Developer V6.0則為快速組裝、開發業務解決方案提供了新一代的開發工具。采用這一工具可以基于統一的編程模型通過BPEL（Business Process Execution Language， 業務流程執行語言）來描述各類流程。它易于使用，僅需要少量的相關技能即可使用，并且提供了開發、測試和將應用部署到流程服務器的功能。
2 基本技術實現框架
2.1 SCA(服務組件編程架構模型)
為了使客戶能夠更加簡單的實現向這種面向服務架構的轉變，IBM在推出一系列WebSphere新產品的同時，提出了一種新的服務組件模型。這是一種全新的、跟語言無關的編程模型，它提供了一種統一的調用方式，從而使得客戶可以把不同的組件類型，比如POJO, EJB, 流程組件，人工交互組件等都可以通過一種標準的接口來封裝和調用。結合SDO的數據模型，這種服務組件的編程模型可以大大的簡化客戶的編程，提高應用的靈活性，這就是面向服務組件的架構（Service Component Architecture，SCA）。
2.2 human task
WPS V6中的人工任務管理器（Human Task Manager）模塊實現了與人工任務相關的下列功能:
- 讓用戶啟動業務流程或者其他Service 組件
- 實現業務流程中的Staff活動
- 流程管理(Administration)
- 動態創建含有與人工或者Service交互的任務
人工任務管理器針對三種基本場景：機器-人(Machine-to-Human)，人-機器(Human-to-Machine)，和人-人（Human-to-Human）。相應的，人工任務有四種不同類型，見下圖。
圖: 人工任務管理器
其中，機器-人場景中的人工任務（participants）是我們這篇文章要主要介紹的，它使流程調用的service的執行中能融入人工交互，典型的例子是一個業務流程為參與業務執行的人創建任務。pTask是一個標準的SCA 組件，可以被用在任何希望引入人工交互的應用中而不僅僅是業務流程。
與其他工作流類的流程整合解決方案不同，WPS中引入了基于SCA service的人工任務，用戶可以靈活地替換系統中基于SCA service的自動service和真正的人工實現。
2.3 Interface開發
在下面的實例中，我們是根據需求來確定出出第三方系統與主流程調用的接口（硬連接的方式），而在企業級應用中，也可以通過實施IBM WebSphere Message Broker來作為連接的應用接口，幫助WPS來連接企業應用。
三、樣例背景及解決方案概述
3.1 方案背景
許多公司在不同時期都開發了企業內部的審批系統，某個部門內部的業務都各自有獨立的系統來進行審批，而有的業務需要不同部門合作，那就只有通過人工來審批，手續相當繁瑣，效率也不高。而為某項業務重新開發新的工作流引擎，又舍不得以前的IT投資，因此，企業就有了這樣的需求：能否有這樣的流程控制器可以將不同部門的獨立系統統一的利用起來，實現跨系統的易更改工作流呢？
在我們這篇文章所舉的范例中，是一個基于BPEL的審批流程，其中涉及到財務系統，項目管理系統2個獨立的系統。其中財務系統是由Deiphi + OCX控件實現的，由SQL server存儲數據；項目管理系統是一個J2EE系統，用DB2 數據庫存儲數據。
在需求中，項目管理系統必須依賴于財務系統才能進行審核等操作，需要把財務系統的數據傳給項目管理系統，適當的時候，項目管理系統也要把相關數據傳給財務系統。在此基礎上，客戶還可能有更高的需求，他們不但想要有流程的整合，還要有門戶的整合，信息的整合。
3.2 IBM的解決方案
用WebSphere Process Server來做流程的整合，需要在不同的節點上完成與Deiphi和J2EE系統的異步調用，同時用Portal來做門戶和信息的整合，并配置SSO， 用戶只需要在Portal進行一次登陸，就可以相應的訪問WPS系統、財務系統（DEiphi）、項目管理系統(J2EE)。相應用戶登陸后可以看到自己的任務列表，如預算編制，項目建立，項目審批等。用戶點擊相應的任務，通過human task接口直接可以訪問到第三方的系統，由第三方的系統得到與任務有關的數據，并直接組織數據發送給WPS.他們之間的通信方式是在SOAP協議上傳輸XML數據。
3.3 可行性分析
在WPS的裝配圖里可以實現的是，第三方的系統只需要提供一個接口，WPS就可以以異步或同步方式來訪問組件。此需求里，客戶要在系統里首先能看到自己的任務列表，點擊不同的任務來決定到那個系統去。如客戶任務列表里有一項的任務是"預算編制"，用戶一點擊"預算編制"，在Portal的另一個iframe就應把財務系統的相應界面調出來。Deiphi根據TaskID到WPS上把相應的數據取到本地并進行處理，用戶進行適當的操作以后，Deiphi再把相應的數據發送給WPS，此過程可如下圖所示：
圖：HumantaskManager調用第三方系統流程
四、解決方案開發
這一章將論述實現這個解決方案的每一個大的步驟，但并不詳細論述如何step by step的實現，比如怎樣定義BO,定義接口等，他們已超出了本次主題。因此，本文的讀者必須對WID和WPS有一定的了解。
4．1 定義BO
BO是工作流平臺與外界進行數據交互的數據格式，第一步我們首先明確工作流平臺與第三方系統進行數據交互的定義，根據業務流程的需要，在每一個流程節點，第三方系統需要向WPS工作流平臺放入哪些數據項，想要從工作流平臺得到什么數據，都要定義出來。 如下圖所示：
在BPEL每次調用第三方系統時，必須前期將輸入輸出的參數確定。主流程傳出業務數據對象（BO），第三方系統接受后，進入自己的子流程，通過人工處理，將主流程需要的參數也以BO的方式傳遞給主流程，使流程能夠繼續運行。
在我們的例子中，主流程與2個子系統每次交互中，我們都定義了兩個BO作為數據輸入輸出的數據格式，分別是OperationNameIN和OperationNameOut。在下圖中，對應"編制預算"這個操作，我們分別定義2個BO，即BudgetBuildIn和BudgetBuildOut.
圖：定義BO
4.2 定義接口
這一步需要定義接口，如操作名稱，輸入數據及輸出數據的定義，在WPS的開發流程里，每一個組件如果能在裝配圖里能被其他的組件所調用，就必須定義接口， Human Task 也不例外。
每個操作的輸入和輸出數據（input和output）的數據類型可以用默認的數據類型，如int、boolean等，也可以用我們定義好的BO。在我們的例子中，由于每次與財務系統或者項目管理系統交互時，都是組合數據，因此都用定義好的BO作為數據類型。如下圖所示，在BudgetBuild接口中，定義了編制預算的操作：其輸入輸出的數據類型分別為budgetBuildIn和budgetBuildOut。
圖：接口的定義
4.3 流程的具體定義
在Process里我們根據用戶的具體業務需求，實現每一個節點，明確每一個節點是與那個系統進行交互的。整個Process有幾次invoke，就表明與財務系統和項目管理系統有幾次交互，即humantask實現的接口。
圖：設計流程（BPEL）
4.4 定義裝配圖
完成了所有的接口定義以后，我們需要在裝配圖里把他們都明確的用線連接起來，可以清楚地明確他們之間的調用關系及數據流向。如下圖所示，把每個接口都拖入到裝配圖中，再分別用humantask來實現。最后，再把主流程Process拖到裝配圖中，通過"Wire to Existing"連接所有組件。
圖：組件裝配SCA
4.5 對外export 一個調用接口
所有的第三方系統通過這個component 來訪問到WPS工作流平臺。我們同樣在裝配圖中建起連接。
圖：暴露調用接口（SCA）
4.6 實現一個統一的調用接口
如圖所示，財務系統需要從WPS工作流平臺得到與這個任務相關的數據，有人工處理以后，要傳回到WPS工作流平臺，并complete 這個任務。這里我們實現一個web service, 并對外提供兩個接口供所有第三方系統進行調用，如Deilhpi, MQ WorkFlow, J2EE等。
該webservice的WSDL描述如下：
<wsdl:operation name="getHTInput">
<wsdlsoap:operation soapAction=""/>
<wsdl:input name="getHTInputRequest">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/"
namespace="http://ForMIS.ibm.com" use="encoded"/>
</wsdl:input>
<wsdl:output name="getHTInputResponse">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/"
namespace="http://ForMIS.ibm.com" use="encoded"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="setHTOutput">
<wsdlsoap:operation soapAction=""/>
<wsdl:input name="setHTOutputRequest">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/"
namespace="http://ForMIS.ibm.com" use="encoded"/>
</wsdl:input>
<wsdl:output name="setHTOutputResponse">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/"
namespace="http://ForMIS.ibm.com" use="encoded"/>
</wsdl:output>
</wsdl:operation>
|
實現操作如下所述：
實現getHTInput operation
1) 得到HumanTaskManager實例
RelationshipService relService = (RelationshipService) ServiceManager.INSTANCE
.locateService("com/ibm/wbiserver/rel/RelationshipService");
InitialContext ctx = new InitialContext();
Object myObj = ctx.lookup(HTM_MANAGER_NAME);
HumanTaskManagerHome myHome = (HumanTaskManagerHome) PortableRemoteObject.narrow
(myObj, com.ibm.task.api.HumanTaskManagerHome.class);
HumanTaskManager humanTaskManager = myHome.create();
|
2） 根據taskID得到第三方系統的需要得到的數據
ClientObjectWrapper input = null;
input = humanTaskManager.getInputMessage(id);
|
實現setOutput operation
1) 得到HumanTaskManager實例
RelationshipService relService = (RelationshipService) ServiceManager.INSTANCE
.locateService("com/ibm/wbiserver/rel/RelationshipService");
InitialContext ctx = new InitialContext();
Object myObj = ctx.lookup(HTM_MANAGER_NAME);
HumanTaskManagerHome myHome = (HumanTaskManagerHome) PortableRemoteObject.narrow(myObj,
com.ibm.task.api.HumanTaskManagerHome.class);
HumanTaskManager humanTaskManager = myHome.create();
|
2) 根據taskID，把第三方上傳的數據賦給WPS相應的Human Task
ClientObjectWrapper outputWrapper = humanTaskManager.createOutputMessage(id);
BusObjImpl busObjImpl = (BusObjImpl) outputWrapper
.getObject();
busObjImpl.set(0, output);
|
3) 完成這個任務complete
humanTaskManager.complete(id,outputWrapper);
|
4． 7 試與部署
首先訪問Http://localhost:9080/bpc 用bpc explorer進行測試,證明所有的節點都可以走通，就可以部署到WPS服務器上，與Portal及第三方系統（Deilphi, MQ WorkFlow, J2EE）進行互聯測試。運行實例演示如下：
4．7．1 下圖是獲取任務列表的演示效果：
登陸系統后，用戶將在系統中看到自己的任務列表，點中任務，就可以在下方的portlet中進行信息輸入和審批。
圖：任務列表和任務的人工處理
4．7．2． 與Deiphi進行交互的頁面
圖：調用財務系統處理界面
流程進入財務系統后，將調用財務系統，在OCX控件中進行相應的操作和處理，然后再把流程往下運行所需要的數據再傳回給process。
4．7．3． 與MQ WorkFlow 的交互頁面
圖：調用項目管理操作界面
與財務系統一樣，當流程調用到項目管理系統時，也出現了項目管理所采用的MQ workflow的界面，進行相應處理和審批后，將數據傳回給WPS，于是流程就可以繼續往下運行。
五． 結束語
本篇文章主要講述了一個解決方案，即如何利用Human Task把第三方系統連接到WPS 里，并實現人工參與及異步通信。這里著重介紹了解決方案的大致步驟，而沒有關注于細節的描述。