（文章來賓與北美紅帽公司高級解決方案架構(gòu)師杰伊·保拉杰共同撰寫）

幾周的提示與技巧文章將深入探討JBoss BPM Suite，特別是有關(guān)如何在兩個(gè)流程之間進(jìn)行通信的問題。 在進(jìn)入解決方案詳細(xì)信息之前，讓我們首先約束將要討論的用例。

關(guān)于兩個(gè)進(jìn)程之間的通信方式可能會有很多解釋，但是我們將從這里開始，以一種簡單的方式讓一個(gè)進(jìn)程調(diào)用另一個(gè)進(jìn)程。 我們還將通過提供的RestAPI展示這種簡單用法，我們將利用該API提供可部署的工件，您可以將其用作任何BPM流程中的自定義工作處理程序。

該工件是一個(gè)我們標(biāo)記為RestApi.java的類，它包含設(shè)置和詳細(xì)信息，使您可以從現(xiàn)有過程中啟動另一個(gè)過程。

在本文結(jié)尾處，我們提供了完整的課程，但首先，我們仔細(xì)研究了各個(gè)活動部分。

每個(gè)類的頂部包括將要使用的各種導(dǎo)入的對象或類，我們對“知識就是一切”（KIE）API組件最感興趣，您會在其中找到它們以及代表我們的醫(yī)療保健示例領(lǐng)域模型的一些對象。

package org.jboss.demo.heathcare;import java.net.MalformedURLException; import java.net.URL; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map;// JBoss BPM Suite API import org.kie.api.runtime.KieSession; import org.kie.api.runtime.manager.RuntimeEngine; import org.kie.api.runtime.process.ProcessInstance; import org.kie.services.client.api.RemoteRestRuntimeEngineFactory;// Domain model. import com.redhat.healthcare.CaseContext; import com.redhat.healthcare.Doctor; import com.redhat.healthcare.PatientInfo; import com.redhat.healthcare.Prescription; import com.redhat.healthcare.Rxdetail;

接下來，我們將找到RestAPI類的實(shí)際開始，我們在其中設(shè)置使用API??所需的一些屬性以及一個(gè)構(gòu)造函數(shù)，以確保JBoss BPM Suite服務(wù)器正在運(yùn)行。 請注意，流程部署ID以及用戶名和密碼都是虛構(gòu)的，因此與實(shí)際流程數(shù)據(jù)的任何相似之處都是偶然的。

String deploymentId = "com.redhat.healthcare:patients:1.0"; String bpmUrl = "http://localhost:8080/business-central"; String userId = "admin"; String password = "bpmsuite1!"; URL deploymentUrl;// Constructor to check for availability of BPM server. // public RestApi() {super();try {this.deploymentUrl = new URL();} catch (MalformedURLException e) {e.printStackTrace();} }

測試的URL假定是基本的默認(rèn)本地安裝，因此，如果您的安裝使用其他設(shè)置，則需要對此進(jìn)行調(diào)整。

下一個(gè)代碼片段重點(diǎn)介紹了一種核心幫助程序方法，該方法為我們提供了對運(yùn)行時(shí)引擎的引用。 這是通過RestAPI將我們綁定到特定部署com.redhat.healthcare：Patients：1.0的引擎，使我們可以啟動該部署中的流程。

// Get a runtime engine based on RestAPI and our deployment. // public RuntimeEngine getRuntimeEngine() {RemoteRestRuntimeEngineFactory restSessionFactory = new RemoteRestRuntimeEngineFactory(deploymentId, deploymentUrl, userId, password);// create REST requestRuntimeEngine engine = restSessionFactory.newRuntimeEngine();return engine; }

有了運(yùn)行時(shí)引擎，我們現(xiàn)在可以訪問和創(chuàng)建會話，然后我們就可以在其中啟動流程實(shí)例。

調(diào)用以下方法來啟動流程實(shí)例，并且僅出于清楚起見，該方法包含創(chuàng)建要提交到我們的流程中的數(shù)據(jù)集合。 您應(yīng)該很容易看到可以根據(jù)需要將其抽象出來，以便將過程變量映射到您的類中。

// Setup our session, fill the data needed for process // instances and starting our process. // public void startProcess() {String taskUserId = userId;// create REST request.RuntimeEngine engine = getRuntimeEngine();KieSession ksession = engine.getKieSession();// setup data for submission to process instance.Doctor doctor = new Doctor();doctor.setAddress("3018 winter");doctor.setCity("madison");doctor.setGender("M");doctor.setGroupId("UW1001");doctor.setHospital("1001");doctor.setName("jey");doctor.setState("WI");PatientInfo pat = new PatientInfo();pat.setAge(12);pat.setName("jey");pat.setSymbtom("Diabetes Insipidus");pat.setType("Diabetes");Rxdetail rxdetail = new Rxdetail();List<rxdetail> details = new ArrayList<rxdetail>();rxdetail.setDrugName("xx");rxdetail.setOther("red");rxdetail.setQty(11);rxdetail.setRxNum(11);details.add(rxdetail);CaseContext cont = new CaseContext();cont.setApprovalReq("N");cont.setApprovalReq("Supervisor");Prescription prescription = new Prescription();prescription.setDoctor(doctor);prescription.setPatientInfo(pat);prescription.setRxdetails(details);// collect all data in our map.Map<string object=""> params = new HashMap<string object="">();params.put("prescription", prescription);params.put("caseContext", cont);// start process.ProcessInstance processInstance = ksession.startProcess("healthcare.patientCaseProcess", params);// verify process started.System.out.println("process id " + processInstance.getProcessId());System.out.println("process id " + processInstance.getId()); }

通過這種方法，我們可以設(shè)置流程所需的醫(yī)生，患者和其他醫(yī)療詳細(xì)信息，將它們收集到地圖中，然后將其提交給流程實(shí)例以將其全部啟動。

現(xiàn)在，我們可以將所有這些聯(lián)系在一起，以便在調(diào)用此方法時(shí)運(yùn)行的主類將設(shè)置我們的RestAPI，并在每次調(diào)用它時(shí)啟動一個(gè)新的流程實(shí)例。

// Start our process by using RestAPI. // public static void main(String[] ar) {RestApi api = new RestApi();api.startProcess(); }

我們希望通過本醫(yī)學(xué)示例的簡單介紹可以使您了解如何利用提供的JBoss BPM Suite RestAPI來發(fā)揮自己的優(yōu)勢。 在這種情況下，我們將其用于與BPM服務(wù)器上部署的任何其他進(jìn)程與特定部署中的特定進(jìn)程進(jìn)行通信。

這是RestApi類：

package org.jboss.demo.heathcare;import java.net.MalformedURLException; import java.net.URL; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map;// JBoss BPM Suite API import org.kie.api.runtime.KieSession; import org.kie.api.runtime.manager.RuntimeEngine; import org.kie.api.runtime.process.ProcessInstance; import org.kie.services.client.api.RemoteRestRuntimeEngineFactory;// Domain model. import com.redhat.healthcare.CaseContext; import com.redhat.healthcare.Doctor; import com.redhat.healthcare.PatientInfo; import com.redhat.healthcare.Prescription; import com.redhat.healthcare.Rxdetail;String deploymentId = "com.redhat.healthcare:patients:1.0"; String bpmUrl = "http://localhost:8080/business-central"; String userId = "admin"; String password = "bpmsuite1!"; URL deploymentUrl;// Constructor to check for availability of BPM server. // public RestApi() {super();try {this.deploymentUrl = new URL();} catch (MalformedURLException e) {e.printStackTrace();} }// Get a runtime engine based on RestAPI and our deployment. // public RuntimeEngine getRuntimeEngine() {RemoteRestRuntimeEngineFactory restSessionFactory = new RemoteRestRuntimeEngineFactory(deploymentId, deploymentUrl, userId, password);// create REST requestRuntimeEngine engine = restSessionFactory.newRuntimeEngine();return engine; }// Setup our session, fill the data needed for process // instances and starting our process. // public void startProcess() {String taskUserId = userId;// create REST request.RuntimeEngine engine = getRuntimeEngine();KieSession ksession = engine.getKieSession();// setup data for submission to process instance.Doctor doctor = new Doctor();doctor.setAddress("3018 winter");doctor.setCity("madison");doctor.setGender("M");doctor.setGroupId("UW1001");doctor.setHospital("1001");doctor.setName("jey");doctor.setState("WI");PatientInfo pat = new PatientInfo();pat.setAge(12);pat.setName("jey");pat.setSymbtom("Diabetes Insipidus");pat.setType("Diabetes");Rxdetail rxdetail = new Rxdetail();List<rxdetail> details = new ArrayList<rxdetail>();rxdetail.setDrugName("xx");rxdetail.setOther("red");rxdetail.setQty(11);rxdetail.setRxNum(11);details.add(rxdetail);CaseContext cont = new CaseContext();cont.setApprovalReq("N");cont.setApprovalReq("Supervisor");Prescription prescription = new Prescription();prescription.setDoctor(doctor);prescription.setPatientInfo(pat);prescription.setRxdetails(details);// collect all data in our map.Map<string object=""> params = new HashMap<string object="">();params.put("prescription", prescription);params.put("caseContext", cont);// start process.ProcessInstance processInstance = ksession.startProcess("healthcare.patientCaseProcess", params);// verify process started.System.out.println("process id " + processInstance.getProcessId());System.out.println("process id " + processInstance.getId()); }// Start our process by using RestAPI. // public static void main(String[] ar) {RestApi api = new RestApi();api.startProcess(); }

翻譯自: https://www.javacodegeeks.com/2014/12/quick-guide-dissecting-jboss-bpm-cross-process-communication.html

總結(jié)

以上是生活随笔為你收集整理的快速指南：剖析JBoss BPM跨进程通信的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。