通過并行活動(dòng)模式創(chuàng)建靈活可配置的業(yè)務(wù)流程

申請(qǐng)免費(fèi)試用、咨詢電話：400-8352-114

這個(gè)文章系列主要介紹了組合業(yè)務(wù)服務(wù)(CBS)的開發(fā)，本文是其中的第9部分?？梢酝ㄟ^組合現(xiàn)有的SOA服務(wù)得到CBS，或者作為一個(gè)新的服務(wù)創(chuàng)建CBS，它們的目的都是提供可配置性。本文介紹了用于為CBS設(shè)計(jì)業(yè)務(wù)流程執(zhí)行語(yǔ)言(BPEL)流程的并行活動(dòng)模式。本文提供了一個(gè)銀行用例示例，該用例實(shí)現(xiàn)了這種模式，以便在從CBS構(gòu)建的簡(jiǎn)單應(yīng)用程序中創(chuàng)建靈活的、可配置的業(yè)務(wù)流程。本文描述了一個(gè)利用BPEL并行活動(dòng)來實(shí)現(xiàn)實(shí)際用例的解決方案?？梢詫?shí)例化多個(gè)并發(fā)流程，并發(fā)流程的數(shù)目是不確定的，可以由業(yè)務(wù)對(duì)象在運(yùn)行時(shí)指定。本文首先簡(jiǎn)單介紹了并行活動(dòng)模式，然后提供了一個(gè)貸款請(qǐng)求用例，通過這個(gè)用例您將了解如何使用并行活動(dòng)模式以實(shí)現(xiàn)靈活性和可配置性。

回顧貸款請(qǐng)求用例

您可以查看本系列中的其他文章以獲得到目前為止有關(guān)這個(gè)用例場(chǎng)景的詳細(xì)信息。在這個(gè)場(chǎng)景中，貸款請(qǐng)求用例是在某個(gè)銀行客戶使用該銀行的Web門戶申請(qǐng)貸款產(chǎn)品時(shí)觸發(fā)的。來自銀行的、基于Web的用戶界面的貸款應(yīng)用程序的提交操作，將調(diào)用貸款審批BPEL流程。這個(gè)流程將從該客戶的配置文件中檢索他的社會(huì)保險(xiǎn)號(hào)，并使用這個(gè)編號(hào)來調(diào)用一個(gè)信用檢查BPEL流程，從而實(shí)現(xiàn)了并行活動(dòng)模式。信用檢查BPEL從多個(gè)代理處獲得一份信用評(píng)分的列表，并將該列表返回給貸款審批流程。根據(jù)信用檢查BPEL流程所返回的列表中的實(shí)際信用評(píng)分，可以自動(dòng)地拒絕或批準(zhǔn)這個(gè)貸款請(qǐng)求，或者將其轉(zhuǎn)發(fā)以便進(jìn)行人工審核。根據(jù)信用檢查BPEL流程所返回的列表計(jì)算平均信用評(píng)分，通過一組基于這個(gè)評(píng)分的業(yè)務(wù)規(guī)則作出相應(yīng)的決策。

當(dāng)一個(gè)貸款請(qǐng)求需要人工審核時(shí)，貸款審批流程將調(diào)用另一個(gè)BPEL子流程，其中包括人工任務(wù)的使用。將信用評(píng)分列表轉(zhuǎn)發(fā)到這個(gè)BPEL子流程。該銀行將檢查這個(gè)信用評(píng)分列表以及與申請(qǐng)者相關(guān)的附加信息，并決定是否應(yīng)該批準(zhǔn)這個(gè)貸款請(qǐng)求。

使用并行活動(dòng)模式

在開始設(shè)計(jì)BPEL流程時(shí)，您可以使用任何模式，如同步模式、基于狀態(tài)模式、或者并行活動(dòng)模式的不同類型(請(qǐng)參見參考資料)。這個(gè)部分介紹了一種并行活動(dòng)模式，這種模式在進(jìn)行BPEL設(shè)計(jì)的時(shí)候不需要知道并行活動(dòng)的數(shù)目。對(duì)于直到運(yùn)行時(shí)才能確定要調(diào)用的實(shí)例數(shù)目的情況，這種模式可以并發(fā)地調(diào)用多個(gè)BPEL流程實(shí)例。這種模式還可以確保在工作流結(jié)束之前完成所有的流程實(shí)例。即將推出的WS-BPEL 2.0規(guī)范中計(jì)劃包含這種并行活動(dòng)模式，其中使用了一個(gè)新的BPEL forEach活動(dòng)，以及子流程并行調(diào)用的一個(gè)關(guān)聯(lián)標(biāo)志。本文描述了如何遵循并行活動(dòng)模式并使用現(xiàn)有的WebSphere Integration Developer 6.0工具來實(shí)現(xiàn)其中每項(xiàng)活動(dòng)的功能。圖1闡釋了這個(gè)模式：

圖1. 并行活動(dòng)模式

名為MultiInvokeRun的父BPEL流程(如圖1中的上半部分所示)使用一個(gè)名為InvokeAll的循環(huán)元素(如圖1中的左上部分所示)進(jìn)行重復(fù)的、單向的(異步)調(diào)用。第二個(gè)循環(huán)稱為WaitReplies(如圖1中的右上部分所示)，它并行地運(yùn)行，并且在子流程(如圖1的下半部分中描述的MultiInvokeChild流程)完成時(shí)用于接收通知。在第一次調(diào)用之前，對(duì)于每次循環(huán)，都會(huì)在MultiInvokeRun流程的SetUpcounters活動(dòng)中初始化一個(gè)計(jì)數(shù)器。可以在運(yùn)行時(shí)通過這個(gè)計(jì)數(shù)器來幫助指定子流程的數(shù)目。直到接收到來自所有子流程的通知，WaitReplies循環(huán)才會(huì)結(jié)束。當(dāng)WaitReplies循環(huán)結(jié)束時(shí)，父BPEL流程MultiInvokeRun也就完成了。