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