jbpm5.1介绍（7）
Junit测试评估流程
评估流程的界面如下：
这个示例里边用到了Script Task，Service Task和User Task
Log执行记录日志的功能，打印出一段信息
RegisterRequest调用外部预定义的程序或者其它引擎的程序
Two调用人工任务
看一下调用的测试程序
public void testEvaluationProcess() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-EvaluationProcess.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new SystemOutWorkItemHandler());ksession.getWorkItemManager().registerWorkItemHandler("RegisterRequest", new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();params.put("employee", "UserId-12345");ProcessInstance processInstance = ksession.startProcess("Evaluation", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
在程序中注册工作处理程序
ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new SystemOutWorkItemHandler());
ksession.getWorkItemManager().registerWorkItemHandler("RegisterRequest", new SystemOutWorkItemHandler());
看一下SystemOutWorkItemHandler中的内容
public class SystemOutWorkItemHandler implements WorkItemHandler {public void executeWorkItem(WorkItem workItem, WorkItemManager manager) {System.out.println("Executing work item " + workItem);manager.completeWorkItem(workItem.getId(), null);}public void abortWorkItem(WorkItem workItem, WorkItemManager manager) {System.out.println("Aborting work item " + workItem);manager.abortWorkItem(workItem.getId());}}
看一下WorkItemHandler，这个接口
| Method Summary | |
|---|---|
void
|
abortWorkItem(WorkItem workItem, WorkItemManager manager)The given work item should be aborted. |
void
|
executeWorkItem(WorkItem workItem, WorkItemManager manager)The given work item should be executed. |
有两个方法，一个是要执行的工作任务，一个是忽略的工作任务
运行junit测试，会发现输出了
Loading process BPMN2-EvaluationProcess.bpmn2
Processing evaluation for employee UserId-12345
Executing work item WorkItem 1 [name=RegisterRequest, state=0, processInstanceId=1, parameters{employeeId=UserId-12345}]
Executing work item WorkItem 2 [name=Human Task, state=0, processInstanceId=1, parameters{}]
先是执行RegisterRequest这个里边的executeWorkItem方法
然后执行了Human Task里的executeWorkItem方法
最后使用
assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
判断状态完成，执行成功
Junit测试评估流程2
评估流程的界面如下，同样的流程，打开BPMN2-EvaluationProcess2.bpmn2文件
同前边的示例一下，看一下测试2的示例程序
public void testEvaluationProcess2() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-EvaluationProcess2.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();params.put("employee", "UserId-12345");ProcessInstance processInstance = ksession.startProcess("com.sample.evaluation", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
执行完成后的结果如下：
Loading process BPMN2-EvaluationProcess2.bpmn2
Executing work item WorkItem 1 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=UserId-12345, Comment=You need to perform a self evaluation, Skippable=false, Content=, TaskName=Performance Evaluation, Priority=1}]
Executing work item WorkItem 2 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=john, Comment=You need to perform an evaluation for employee UserId-12345, Skippable=false, Content=, TaskName=Performance Evaluation, Priority=1}]
Executing work item WorkItem 3 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=mary, Comment=You need to perform an evaluation for employee UserId-12345, Skippable=false, Content=, TaskName=Performance Evaluation, Priority=1}]
每个人的工作任务自动向下执行。
Junit测试评估流程3
评估流程的界面如下，同第一个是一样的
看一下示例程序
public void testEvaluationProcess3() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-EvaluationProcess3.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new SystemOutWorkItemHandler());ksession.getWorkItemManager().registerWorkItemHandler("RegisterRequest", new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();params.put("employee", "john2");ProcessInstance processInstance = ksession.startProcess("Evaluation", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
执行之后看结果
Loading process BPMN2-EvaluationProcess3.bpmn2
Processing evaluation for employee john2
Executing work item WorkItem 1 [name=Human Task, state=0, processInstanceId=1, parameters{}]
可以看到只执行了Human Task，默认情况下注册进来的多个Handler如果不指定的话会默认执行Human Task，如果指定了就先指定执行的，如第一个示例再执行Human Task
Junit测试用户任务
接下来的示例是测试用户任务的示例，打开BPMN2-UserTask.bpmn2文件，流程定义文件如下
指定了ActorId为john
看测试用例程序
public void testUserTask() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-UserTask.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);TestWorkItemHandler workItemHandler = new TestWorkItemHandler();ksession.getWorkItemManager().registerWorkItemHandler("Human Task", workItemHandler);ProcessInstance processInstance = ksession.startProcess("UserTask");assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);ksession = restoreSession(ksession, true);WorkItem workItem = workItemHandler.getWorkItem();assertNotNull(workItem);assertEquals("john", workItem.getParameter("ActorId"));ksession.getWorkItemManager().completeWorkItem(workItem.getId(), null);assertProcessInstanceCompleted(processInstance.getId(), ksession);}
先定义了一个TestWorkItemHandler，然后将这个handler定义为人工任务
然后判断节点状态是否是激活状态
然后判断流程中执行的是john在执行这个任务并且完成，最后判断流程完成
TestWorkItemHandler中的内容如下：
public static class TestWorkItemHandler implements WorkItemHandler {private List<WorkItem> workItems = new ArrayList<WorkItem>();public void executeWorkItem(WorkItem workItem, WorkItemManager manager) {workItems.add(workItem);}public void abortWorkItem(WorkItem workItem, WorkItemManager manager) {}public WorkItem getWorkItem() {System.out.println("执行test workitem");if (workItems.size() == 0) {return null;}if (workItems.size() == 1) {WorkItem result = workItems.get(0);this.workItems.clear();return result;} else {throw new IllegalArgumentException("More than one work item active");}}public List<WorkItem> getWorkItems() {List<WorkItem> result = new ArrayList<WorkItem>(workItems);workItems.clear();return result;}}
执行结果如下显示
Loading process BPMN2-UserTask.bpmn2
执行test workitem
Junit测试泳道
接下来的示例是一个测试泳道的例子，泳道的概念可以理解成一个角色或者一个组，就是相当于一组人
看流程图
定义了泳道“MyLane”
在hello上指定了ActorId是john，在Goodbye上没有指定人
看流程示例
public void testLane() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-Lane.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);TestWorkItemHandler workItemHandler = new TestWorkItemHandler();ksession.getWorkItemManager().registerWorkItemHandler("Human Task",workItemHandler);ProcessInstance processInstance = ksession.startProcess("UserTask");assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);ksession = restoreSession(ksession, true);ksession.getWorkItemManager().registerWorkItemHandler("Human Task",workItemHandler);WorkItem workItem = workItemHandler.getWorkItem();assertNotNull(workItem);assertEquals("john", workItem.getParameter("ActorId"));Map<String, Object> results = new HashMap<String, Object>();results.put("ActorId", "mary");ksession.getWorkItemManager().completeWorkItem(workItem.getId(),results);ksession = restoreSession(ksession, true);ksession.getWorkItemManager().registerWorkItemHandler("Human Task",workItemHandler);workItem = workItemHandler.getWorkItem();assertNotNull(workItem);assertEquals("mary", workItem.getParameter("ActorId"));ksession.getWorkItemManager().completeWorkItem(workItem.getId(), null);assertProcessInstanceCompleted(processInstance.getId(), ksession);}
定义任务并且执行，并且可以看到第一个用户任务的执行人是john，然后向里传入了第二个用户，mary
这个用户将被赋到泳道MyLane上
然后在看执行用户变成了mary，最后流程结束
看输出结果
Loading process BPMN2-Lane.bpmn2
执行test workitemWorkItem 1 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=john}]
执行test workitemWorkItem 2 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=mary}]
Junit测试异或流程
接下来的示例是测试gateway的异或流程，看一下示例
流程图如下
就是说只需要执行其中的一个流程，就可以让流程继续向下执行，这个示例是根据传入的变量X来看向哪执行
看测试代码
public void testExclusiveSplit() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplit.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Email",new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();params.put("x", "First");params.put("y", "Second");ProcessInstance processInstance = ksession.startProcess("com.sample.test", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
执行测试流程结果如下
Loading process BPMN2-ExclusiveSplit.bpmn2
x=First
Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=This is an urgent email First, Subject=Urgent email !, To=you@mail.com, From=me@mail.com}]
即当流程执行到其中有一个后则流程自动向下执行
Junit测试异或流程高级1
接下来的示例是测试，看如下流程定义
这个是根据动态传入的看结点的值是不是a如果是a则走上边的流程，如果不是则走下边的流程
public void testExclusiveSplitXPathAdvanced() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitXPath-advanced.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Email",new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();Document doc = DocumentBuilderFactory.newInstance().newDocumentBuilder().newDocument();Element hi = doc.createElement("hi");Element ho = doc.createElement("ho");hi.appendChild(ho);Attr attr = doc.createAttribute("value");ho.setAttributeNode(attr);attr.setValue("a");params.put("x", hi);params.put("y", "Second");ProcessInstance processInstance = ksession.startProcess("com.sample.test", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
根据传入的结点执行流程
执行结果如下
Loading process BPMN2-ExclusiveSplitXPath-advanced.bpmn2
x=[hi: null]
Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=you@mail.com, Subject=Urgent email !, To=you@mail.com, From=me@mail.com}]
Junit测试异或流程高级2
接下来的示例是测试，如下流程图
流程结点定义
还是根据值来判断流向，这次只指定x
看测试程序
public void testExclusiveSplitXPathAdvanced2() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitXPath-advanced-vars-not-signaled.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Email",new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();Document doc = DocumentBuilderFactory.newInstance().newDocumentBuilder().newDocument();Element hi = doc.createElement("hi");Element ho = doc.createElement("ho");hi.appendChild(ho);Attr attr = doc.createAttribute("value");ho.setAttributeNode(attr);attr.setValue("a");params.put("x", hi);params.put("y", "Second");ProcessInstance processInstance = ksession.startProcess("com.sample.test", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
执行的流程结果
Loading process BPMN2-ExclusiveSplitXPath-advanced-vars-not-signaled.bpmn2
y=Second
Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=you@mail.com, Subject=Urgent email !, To=you@mail.com, From=me@mail.com}]
Junit测试异或流程带参数
与上边几个程序基本一致，直接上代码吧
public void testExclusiveSplitXPathAdvancedWithVars() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitXPath-advanced-with-vars.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Email",new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();Document doc = DocumentBuilderFactory.newInstance().newDocumentBuilder().newDocument();Element hi = doc.createElement("hi");Element ho = doc.createElement("ho");hi.appendChild(ho);Attr attr = doc.createAttribute("value");ho.setAttributeNode(attr);attr.setValue("a");params.put("x", hi);params.put("y", "Second");ProcessInstance processInstance = ksession.startProcess("com.sample.test", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
执行结果
Loading process BPMN2-ExclusiveSplitXPath-advanced-with-vars.bpmn2
x=[hi: null]
Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=you@mail.com, Subject=Urgent email !, To=you@mail.com, From=me@mail.com}]
Junit测试异或流程优先和默认
下面的两个流程和上边基本一致只是细节上有些不同，一个是根据优先级流向一个是根据默认值流向
优先
public void testExclusiveSplitPriority() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitPriority.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Email",new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();params.put("x", "First");params.put("y", "Second");ProcessInstance processInstance = ksession.startProcess("com.sample.test", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
默认
public void testExclusiveSplitDefault() throws Exception {KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitDefault.bpmn2");StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);ksession.getWorkItemManager().registerWorkItemHandler("Email",new SystemOutWorkItemHandler());Map<String, Object> params = new HashMap<String, Object>();params.put("x", "NotFirst");params.put("y", "Second");ProcessInstance processInstance = ksession.startProcess("com.sample.test", params);assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);}
分别的执行结果如下：
优先
Loading process BPMN2-ExclusiveSplitPriority.bpmn2
y=Second
Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=This is an urgent email First, Subject=Urgent email !, To=you@mail.com, From=me@mail.com}]
默认
Loading process BPMN2-ExclusiveSplitDefault.bpmn2
y=Second
Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=This is an urgent email NotFirst, Subject=Urgent email !, To=you@mail.com, From=me@mail.com}]
jbpm5.1介绍（7）相关推荐
- 工作流activity_开源、强大的工作流引擎：camunda入门介绍
原创不易,请多多支持!对Java技术感兴趣的童鞋请关注我,后续技术分享更精彩. 简介 Camunda is a Java-based framework supporting BPMN for wor ...
- 德玛西亚之WorkFlow(一)工作流介绍
德玛西亚之WorkFlow(一)工作流介绍 1 什么是工作流 工作流(WorkFlow),就是将一项多人或者多任务的工作按照固定的顺序进行逐项操作,直至此工作结束.举个简单的例子:多个人协同做饭,首先 ...
- Activiti的基本介绍
Activiti简介 Activiti 是由 jBPM 的创建者 Tom Baeyens 离开 JBoss 之后建立的项目,构建在开发 jBPM 版本 1 到 4 时积累的多年经验的基础之上,旨在创建 ...
- 简单介绍互联网领域选择与营销方法
在我看来,互联网领域的选择是"安家",而营销方法的不同则表现了"定家"的方式多种多样,只有选对了,"家"才得以"安定". ...
- 常用开源协议介绍以及开源软件规范列表
1. 开源协议介绍 GPL: General Public License,开源项目最常用的许可证,衍生代码的分发需开源并且也要遵守此协议.该协议也有很多变种,不同变种要求会略微不同. MPL: MP ...
- python：Json模块dumps、loads、dump、load介绍
20210831 https://www.cnblogs.com/bigtreei/p/10466518.html json dump dumps 区别 python:Json模块dumps.load ...
- pytorch学习笔记（九）：PyTorch结构介绍
PyTorch结构介绍 对PyTorch架构的粗浅理解,不能保证完全正确,但是希望可以从更高层次上对PyTorch上有个整体把握.水平有限,如有错误,欢迎指错,谢谢! 几个重要的类型 和数值相关的 T ...
- Python字节码介绍
了解 Python 字节码是什么,Python 如何使用它来执行你的代码,以及知道它是如何帮到你的. 如果你曾经编写过 Python,或者只是使用过 Python,你或许经常会看到 Python 源代 ...
- Pytest - 使用介绍
1. 概述 pytest是一个非常成熟的全功能的Python测试框架,主要特点有以下几点: 1.简单灵活,容易上手,文档丰富: 2.支持参数化,可以细粒度地控制要测试的测试用例: 3.能够支持简单的单 ...
- 遗传算法的简单介绍以及模式定理的简单证明
遗传算法 遗传算法(Genetic Algorithm,GA),最早是由美国的John holland在20世纪70年代提出.算法通过模拟达尔文生物进化论的自然选择以及遗传学机理的生物进化过程来搜 ...
最新文章
- 大神开发arXiv全新H5版，一步告别公式排版错误，手机也能轻松看文献
- 为什么c程序里一定要写main函数
- 仿百度GIF验证码 GIFEncoder 跳动验证码 随机背景色、颜色、字体、子大小、偏移、干扰线等...
- 2021年春季学期-信号与系统-第十三次作业参考答案-第三小题
- 五个非常实用的自然语言处理资源
- jqgrid实现客户端导出Excel、txt、word、json等数据格式的文件
- 输入一个以回车结束的字符串，判断该字符串是否对称(正序与逆序相同，如aBc2cBa为对称字符串)
- awk嵌套awk_与AWK一起喝咖啡
- 获取来源网站php,js实现获取网站搜索来源代码
- 关于慢开始、拥塞控制、快重传、快恢复算法的理解
- 阿里巴巴CTO王坚：省长也是开发者
- Ubuntu 20.04更新源报错W: 校验数字签名时出错。此仓库未被更新，所以仍然使用此前的索引文件。
- ActiveReports 报表应用教程 (7)---交叉报表及数据透视图实现方案
- [轉]PHP执行MYSQL存储过程报错:Commands out of sync; you can't run this command now 问题的解决...
- 虚拟机安装SQLService启用windows功能NetFx3时出错
- ERStudio逆向工程生成ER模型
- （C语言）教师信息管理系统
- c++异常机制（转载）
- S2ANet(Align Deep Features for Oriented Object Detection)解读
- Cesium中获取地形三角网并进行土方计算
热门文章
- case when then end.sql
- ARToolkit介绍
- 安装运行jupyter notebook时报错：ModuleNotFoundError: No module named 'prompt_toolkit.formatted_text'...
- FastReport.Net使用：[1]屏蔽打印对话框
- 2016/7/7 设置wamp2.5 mysql密码 重点是mysql版本
- MySQL二进制包安装简略过程
- [傅里叶变换及其应用学习笔记] 七. 傅里叶正(反)变换复习
- HomeBrew太慢，如何替换默认HomeBrew源，使用阿里云的源
- spring4.x的一些新特性
- java中的控制执行流程