2. 程式人生 > 其它 >jbpm5.1介紹（10）

jbpm5.1介紹（10）

阿新 • • 發佈：2022-05-04

Junit測試異常事件觸發

下面的示例中測試在程式中觸發異常事件的流程，流程如下

測試程式

public void testTimerBoundaryEventInterrupting() throws Exception {
		KnowledgeBase kbase = createKnowledgeBase("BPMN2-TimerBoundaryEventInterrupting.bpmn2");
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		ksession.getWorkItemManager().registerWorkItemHandler("MyTask",
				new DoNothingWorkItemHandler());
		ProcessInstance processInstance = ksession
				.startProcess("TimerBoundaryEvent");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		Thread.sleep(1000);
		ksession = restoreSession(ksession, true);
		System.out.println("Firing timer");
		ksession.fireAllRules();
		assertProcessInstanceCompleted(processInstance.getId(), ksession);
	}

 結果如下

Loading process BPMN2-TimerBoundaryEventInterrupting.bpmn2 Timer handled Firing timer

Junit測試根據規則執行子流程

下面的示例中測試在程式中加入固定規則，然後如果發現符合規則那麼向下執行子流程

流程介面如下

規則檔案如下

package org.drools.bpmn2

import org.drools.runtime.process.ProcessContext

rule "Auto-activate Hello1" ruleflow-group "Hello"
  when
  then
    System.out.println(drools);
    System.out.println(drools.getContext(ProcessContext.class));
    System.out.println(drools.getContext(ProcessContext.class).getProcessInstance());
    drools.getContext(ProcessContext.class).getProcessInstance().signalEvent("Hello1", null);
end

 測試程式

public void testAdHocSubProcess() throws Exception {
		System.out.println("Loading process BPMN2-AdHocSubProcess.bpmn2");
		KnowledgeBuilder kbuilder = KnowledgeBuilderFactory
				.newKnowledgeBuilder();
		kbuilder.add(ResourceFactory
				.newClassPathResource("junit/BPMN2-AdHocSubProcess.bpmn2"),
				ResourceType.BPMN2);
		kbuilder.add(ResourceFactory
				.newClassPathResource("junit/BPMN2-AdHocSubProcess.drl"),
				ResourceType.DRL);
		KnowledgeBase kbase = kbuilder.newKnowledgeBase();
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		TestWorkItemHandler workItemHandler = new TestWorkItemHandler();
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				workItemHandler);
		ProcessInstance processInstance = ksession
				.startProcess("AdHocSubProcess");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		WorkItem workItem = workItemHandler.getWorkItem();
		assertNull(workItem);
		ksession = restoreSession(ksession, true);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				workItemHandler);
		ksession.fireAllRules();
		System.out.println("Signaling Hello2");
		ksession.signalEvent("Hello2", null, processInstance.getId());
		workItem = workItemHandler.getWorkItem();
		assertNotNull(workItem);
		ksession = restoreSession(ksession, true);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				workItemHandler);
		ksession.getWorkItemManager().completeWorkItem(workItem.getId(), null);
	}

 執行結果如下

Loading process BPMN2-AdHocSubProcess.bpmn2 org.drools.base.DefaultKnowledgeHelper@1bdb58 org.drools.spi.ProcessContext@1568654 WorkflowProcessInstance1 [processId=AdHocSubProcess,state=1] Hello World 1 Signaling Hello2 Hello World 2 執行test workitemWorkItem 1 [name=Human Task, state=0, processInstanceId=1, parameters{}]

Junit測試根據規則執行子流程並自動完成

下面的示例中測試在程式中如下圖

執行流程如下，執行完成之後自動完成並且向下走

測試程式

public void testAdHocSubProcessAutoComplete() throws Exception {
		System.out
				.println("Loading process BPMN2-AdHocSubProcessAutoComplete.bpmn2");
		KnowledgeBuilder kbuilder = KnowledgeBuilderFactory
				.newKnowledgeBuilder();
		kbuilder.add(
				ResourceFactory
						.newClassPathResource("junit/BPMN2-AdHocSubProcessAutoComplete.bpmn2"),
				ResourceType.BPMN2);
		kbuilder.add(ResourceFactory
				.newClassPathResource("junit/BPMN2-AdHocSubProcess.drl"),
				ResourceType.DRL);
		KnowledgeBase kbase = kbuilder.newKnowledgeBase();
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		TestWorkItemHandler workItemHandler = new TestWorkItemHandler();
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				workItemHandler);
		ProcessInstance processInstance = ksession
				.startProcess("AdHocSubProcess");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		WorkItem workItem = workItemHandler.getWorkItem();
		assertNull(workItem);
		ksession = restoreSession(ksession, true);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				workItemHandler);
		ksession.fireAllRules();
		workItem = workItemHandler.getWorkItem();
		assertNotNull(workItem);
		ksession = restoreSession(ksession, true);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				workItemHandler);
		ksession.getWorkItemManager().completeWorkItem(workItem.getId(), null);
		assertProcessInstanceCompleted(processInstance.getId(), ksession);
	}

 執行結果

Loading process BPMN2-AdHocSubProcessAutoComplete.bpmn2 org.drools.base.DefaultKnowledgeHelper@6833f2 org.drools.spi.ProcessContext@1bdb58 WorkflowProcessInstance1 [processId=AdHocSubProcess,state=1] 執行test workitemWorkItem 1 [name=Human Task, state=0, processInstanceId=1, parameters{}] Goodbye World

Junit測試觸發任務

下面的示例中測試在程式中執行並且觸發任務

流程如下

測試程式

public void testAdHocProcess() throws Exception {
		KnowledgeBase kbase = createKnowledgeBase("BPMN2-AdHocProcess.bpmn2");
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		ProcessInstance processInstance = ksession.startProcess("AdHocProcess");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		ksession = restoreSession(ksession, true);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				new DoNothingWorkItemHandler());
		System.out.println("Triggering node");
		ksession.signalEvent("Task1", null, processInstance.getId());
		assertProcessInstanceActive(processInstance.getId(), ksession);
		ksession.signalEvent("User1", null, processInstance.getId());
		assertProcessInstanceActive(processInstance.getId(), ksession);
		ksession.insert(new Person());
		ksession.signalEvent("Task3", null, processInstance.getId());
		assertProcessInstanceCompleted(processInstance.getId(), ksession);
	}

 測試結果

Loading process BPMN2-AdHocProcess.bpmn2 Triggering node Task1 Task3

Junit測試獲取異常事件

下面的示例中測試在程式中得到異常事件

流程如圖

程式中觸發事件

public void testIntermediateCatchEventSignal() throws Exception {
		KnowledgeBase kbase = createKnowledgeBase("BPMN2-IntermediateCatchEventSignal.bpmn2");
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				new DoNothingWorkItemHandler());
		ProcessInstance processInstance = ksession
				.startProcess("IntermediateCatchEvent");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		ksession = restoreSession(ksession, true);
		// now signal process instance
		ksession.signalEvent("MyMessage", "SomeValue", processInstance.getId());
		assertProcessInstanceCompleted(processInstance.getId(), ksession);
	}

 執行結果

Loading process BPMN2-AdHocProcess.bpmn2 Triggering node Task1 Task3

Junit測試獲取事件訊息

下面的示例中測試在程式中得到事件訊息

測試程式

public void testIntermediateCatchEventMessage() throws Exception {
		KnowledgeBase kbase = createKnowledgeBase("BPMN2-IntermediateCatchEventMessage.bpmn2");
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				new DoNothingWorkItemHandler());
		ProcessInstance processInstance = ksession
				.startProcess("IntermediateCatchEvent");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		ksession = restoreSession(ksession, true);
		// now signal process instance
		ksession.signalEvent("Message-HelloMessage", "SomeValue",
				processInstance.getId());
		assertProcessInstanceCompleted(processInstance.getId(), ksession);
	}

 執行結果

Loading process BPMN2-IntermediateCatchEventMessage.bpmn2 SomeValue

Junit測試超時事件

下面的示例中測試在流程中超時觸發事件

流程如下

測試程式如下

public void testIntermediateCatchEventTimerDuration() throws Exception {
		KnowledgeBase kbase = createKnowledgeBase("BPMN2-IntermediateCatchEventTimerDuration.bpmn2");
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				new DoNothingWorkItemHandler());
		ProcessInstance processInstance = ksession
				.startProcess("IntermediateCatchEvent");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		// now wait for 1 second for timer to trigger
		Thread.sleep(1000);
		ksession = restoreSession(ksession, true);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				new DoNothingWorkItemHandler());
		ksession.fireAllRules();
		assertProcessInstanceCompleted(processInstance.getId(), ksession);
	}

 超時觸發事件，結果如下

Loading process BPMN2-IntermediateCatchEventTimerDuration.bpmn2 Timer triggered

Junit測試超時事件1

下面的示例中測試在流程中超時觸發事件，基本操作同上

示例如果同上，不再貼出

Junit測試超時事件2

下面的示例中測試在流程中執行兩次超時事件並且都觸發對應的事件執行

測試程式

public void testIntermediateCatchEventTimerCycle2() throws Exception {
		KnowledgeBase kbase = createKnowledgeBase("BPMN2-IntermediateCatchEventTimerCycle2.bpmn2");
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
				new DoNothingWorkItemHandler());
		ProcessInstance processInstance = ksession
				.startProcess("IntermediateCatchEvent");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		// now wait for 1 second for timer to trigger
		Thread.sleep(1000);
		assertProcessInstanceActive(processInstance.getId(), ksession);
		Thread.sleep(1000);
		assertProcessInstanceActive(processInstance.getId(), ksession);
		ksession.abortProcessInstance(processInstance.getId());
		Thread.sleep(1000);
	}

 執行結果

Loading process BPMN2-IntermediateCatchEventTimerCycle2.bpmn2 Timer triggered Timer triggered

Junit測試條件觸發事件執行

下面的示例中測試在流程中當條件等於jack時觸發事件執行

流程如下

測試程式

public void testIntermediateCatchEventCondition() throws Exception {
		KnowledgeBase kbase = createKnowledgeBase("BPMN2-IntermediateCatchEventCondition.bpmn2");
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		ProcessInstance processInstance = ksession
				.startProcess("IntermediateCatchEvent");
		assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
		ksession = restoreSession(ksession, true);
		// now activate condition
		Person person = new Person();
		person.setName("Jack");
		ksession.insert(person);
		assertProcessInstanceCompleted(processInstance.getId(), ksession);
	}

 執行結果

Loading process BPMN2-IntermediateCatchEventCondition.bpmn2 Condition triggered

Junit測試錯誤事件

下面的示例中測試錯誤事件的執行

測試程式

public void testErrorEndEventProcess() throws Exception {
		KnowledgeBase kbase = createKnowledgeBase("BPMN2-ErrorEndEvent.bpmn2");
		StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
		ProcessInstance processInstance = ksession
				.startProcess("ErrorEndEvent");
		assertProcessInstanceAborted(processInstance.getId(), ksession);
	}

 執行結果

Loading process BPMN2-ErrorEndEvent.bpmn2

執行到錯誤流程流程自動結束

相關推薦

jbpm5.1介紹（10）

Junit測試異常事件觸發 下面的示例中測試在程式中觸發異常事件的流程，流程如下

jbpm5.1介紹（2）

快速開始  首先下載jBPM，http://sourceforge.net/projects/jbpm/files/ 可以有選擇性的下載：

jbpm5.1介紹（3）

在您好的應用程式中使用一個新的流程 流程處理  （1）你需要建立一個知識庫，其中包含過程定義

jbpm5.1介紹（4）

eclipse外掛 需求 Eclipse的3.6或更新版本 Graphiti框架，使用更新站點 可以直接下載更新Graphiti

jbpm5.1介紹（5）

看幾個jbpm5中帶的示例程式吧，包括了很多我們在日常生活中的場景 迴圈示例

jbpm5.1介紹（6）

Junit測試的mini流程helloworld 這是一個在demo中使用的Script Task做的簡單示例，在執行到這個任務結點的時候自動輸出\"hello world\"

jbpm5.1介紹（7）

Junit測試評估流程 評估流程的介面如下： 這個示例裡邊用到了Script Task，Service Task和User Task

jbpm5.1介紹（8）

Junit測試或流程 下面的示例中使用的是或流程，看如下流程圖 判斷節點的值是大於0，大於10還是大於20

jbpm5.1介紹（9）

Junit測試呼叫子流程 下面的示例中測試在程式中呼叫其它程式的子流程的示例，需要載入兩個配置檔案

jbpm5.1介紹（11）

Jbpm-gwt-console原始碼編譯 從svn下載，svn的下載地址是 http://anonsvn.jboss.org/repos/soag/bpm-console/tags/bpm-console-2.1

jbpm5.1介紹（12）

GWT是什麼 如今，編寫網路應用程式是一個單調乏味且易於出錯的過程。開發人員可能要花費 90% 的時間來處理瀏覽器行話。此外，構建、重複使用以及維護大量 JavaScript 程式碼庫和 AJAX 元件可能困難且不可靠。Google

Spark專案實戰從0到1之（10）Spark讀取HDFS寫入Hive

package com.xxxx.report.service; import com.google.common.collect.Lists; import com.xx.report.config.Constants;

一起玩轉微服務（10）——spring boot介紹

對於Spring，相信大家都非常熟悉，從出現開始，一直是企業級開發的主流。但是隨著軟體的發展和應用開發的不斷演化，它的一些缺點也逐漸胡暴露了出來，下面，我們就一起看一下Spring的發展歷程並且認識一下Spring Boo

Git&GitHub學習和運用（1.介紹和使用）

1.版本控制系統主要用途 協同開發 　　通常在軟體專案的開發建設過程中，一般會有多名工作人員同時對專案開展工作，那麼此時的專案工程不可能是一個獨立的資源，這個時候就需要將專案工程提供給各個工作人員對同一份

Flink 從 0 到 1 學習之（10）Flink 專案如何執行？

前言 之前寫了不少 Flink 文章了，也有不少 demo，但是文章寫的時候都是在本地直接執行 Main 類的 main 方法，其實 Flink 是支援在 UI 上上傳 Flink Job 的 jar 包，然後執行得。

每天1題演算法題（10）- 盛最多水的容器

給你 n 個非負整數 a1，a2，...，an，每個數代表座標中的一個點(i,ai) 。在座標內畫 n 條垂直線，垂直線 i的兩個端點分別為(i,ai) 和 (i, 0)。找出其中的兩條線，使得它們與x軸共同構成的容器可以容納最多的水。

Jmeter系列（10）- 控制器Controllers、取樣器 Samplers、Logic Controllers邏輯控制器的入門介紹

一、控制器 Controllers Jmeter有兩種型別的控制器：Samplers（取樣器）和Logical Controllers（邏輯控制器）；它們驅動著測試的進行

Python自動化交易學習筆記（10）——1.新增賣出條件引數配置，2.交易單位大小

Demo10主要介紹如何自定義策略引數。 Demo10主要做了兩處修改： 1.在策略中添加了自定義引數：params = (

陣列學習系列1-VBA二維陣列的基礎介紹（4）

既然你已經知道了如何有規劃地產生一個清單（一維陣列），是時候仔細看一下如何使用資料表了。下面的過程產生一個二維陣列，儲存國家名稱，貨幣名稱和交換匯率。

sqli labs（Less-1至Less-10）

網安興趣愛好者，初次分享學習筆記。 Less-1 型別 字元型回顯注入\' 輸入點 根據新增\'頁面的回顯，可以判斷出\'是閉合