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