activiti5第四弹----serviceTask中的java服务任务

activiti.cfg.xml内容:

<?xml version="1.0"?>
<beans default-lazy-init="false"xsi:schemaLocation=" http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"xmlns:aop="http://www.springframework.org/schema/aop" xmlns:mvc="http://www.springframework.org/schema/mvc"xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jee="http://www.springframework.org/schema/jee"xmlns:util="http://www.springframework.org/schema/util" xmlns:context="http://www.springframework.org/schema/context"xmlns:p="http://www.springframework.org/schema/p" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns="http://www.springframework.org/schema/beans"><beanclass="org.activiti.engine.impl.cfg.StandaloneInMemProcessEngineConfiguration"id="processEngineConfiguration"><property name="jdbcUrl" value="jdbc:mysql://localhost:3306/activi1" /><property name="jdbcDriver" value="com.mysql.jdbc.Driver" /><property name="jdbcUsername" value="root" /><property name="jdbcPassword" value="root" /><property name="databaseSchemaUpdate" value="true" /><property name="jobExecutorActivate" value="true" /><property name="mailServerHost" value="mail.my-corp.com" /><property name="mailServerPort" value="5025" /><property name="history" value="full"></property></bean>
</beans>


方式一:使用java class来实现java服务任务



HelloService内容:

package org.mpc.final_activiti;import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.JavaDelegate;/*** * 作为activiti的ServiceTask的实现,必须实现JavaDelegate接口,但是不需要实现序列化接口* * activiti会使用反射机制将类初始化,因此在实现JavaDelegate接口的时候需要提供一个* 无参数的构造器,否则会抛出异常。* * @author mpc**/
public class HelloService implements JavaDelegate {@Overridepublic void execute(DelegateExecution arg0) throws Exception {System.out.println("---------------------------------------------");System.out.println();System.out.println("Hello Service " + this.toString()+ "Is Saying Hello To Every One !");System.out.println("---------------------------------------------");System.out.println();}}

测试方法:

package final_activiti.progress;import org.activiti.engine.impl.test.PluggableActivitiTestCase;
import org.activiti.engine.test.Deployment;
import org.junit.Test;public class ServiceTask1Test extends PluggableActivitiTestCase {@Test@Deployment(resources = "final_activiti/progress/serviceTask_01.bpmn")public void test() {assertProcessEnded(runtimeService.startProcessInstanceByKey("service1").getId());}}

测试结果:


从测试结果可以看到,我们在流程中定义的连个Service task都执行了,而且可以从红线标注处看到这两个Service是不一样的,也就是说activiti在每次需要执行一个Service task 的时候都重新创建了服务对象。


方式二:使用 Delegate expression来实现java服务任务


delegate对应的java类:

package org.mpc.final_activiti;import java.io.Serializable;import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.JavaDelegate;public class Helloservice1 implements Serializable, JavaDelegate {/*** 实现JavaDelegate接口,使用其中的execute方法 由于要放入流程定义中,所以要实现可序列话接口* */private static final long serialVersionUID = 5593437463482732772L;@Overridepublic void execute(DelegateExecution arg0) throws Exception {System.out.println("---------------------------------------------");System.out.println();System.out.println("Hello Service " + this.toString()+ "Is Saying Hello To Every One !");System.out.println("---------------------------------------------");System.out.println();}}

测试类:

package final_activiti.progress;import java.util.HashMap;
import java.util.Map;import org.activiti.engine.impl.test.PluggableActivitiTestCase;
import org.activiti.engine.test.Deployment;
import org.junit.Test;
import org.mpc.final_activiti.Helloservice1;public class ServiceTask2Test extends PluggableActivitiTestCase {@Test@Deployment(resources = "final_activiti/progress/serviceTask_02.bpmn")public void test() {//定义delegate放入流程定义中启动流程Map<String, Object> map = new HashMap<String, Object>();map.put("delegate", new Helloservice1());runtimeService.startProcessInstanceByKey("service2", map);}}

测试结果:


结果显示两个Service task 都执行了,而且可以发现,使用的是同一个服务对象。这样更节省系统开销吧。。。


方式三:使用expression


第二个Service task 的main config内容:


myBean对应的服务类:

package org.mpc.final_activiti;import java.io.Serializable;import org.activiti.engine.runtime.Execution;/*** * 不需要实现javadelegate,但是由于要放入到流程定义中,所以需要实现可序列话接口* * */
public class HelloService2 implements Serializable {private static final long serialVersionUID = 2356L;private String name = "test_mpc";/*** @Title: getName* @Description: 这里的get方法是必要的,因为在流程中直接使用对象.属性的方式调用属性的话,就相当于调用这里的get方法* @param @return 设定文件* @return String 返回类型* @throws* @author mpc*/public String getName() {return name;}public void print(Execution ex) {System.out.println("This is HellService2 Called by  process "+ ex.getId() + "who's saying hello ! ");}
}

测试类:

package final_activiti.progress;import java.util.HashMap;
import java.util.Map;import org.activiti.engine.impl.test.PluggableActivitiTestCase;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.test.Deployment;
import org.junit.Test;
import org.mpc.final_activiti.HelloService2;public class ServiceTask3Test extends PluggableActivitiTestCase {@Test@Deployment(resources = "final_activiti/progress/serviceTask_03.bpmn")public void test() {Map<String, Object> map = new HashMap<String, Object>();map.put("myBean", new HelloService2());ProcessInstance pi = runtimeService.startProcessInstanceByKey("service3", map);String s = (String) runtimeService.getVariable(pi.getId(), "myVar");assertTrue("test_mpc".equals(s));taskService.complete(taskService.createTaskQuery().singleResult().getId());assertProcessEnded(pi.getId());}}

测试结果:



本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/569344.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

1 ~ express ~ 初始化。安装第三方模块express。中间件

一&#xff0c;初始化 二&#xff0c;安装第三方模块express 三&#xff0c;安装中间件 1&#xff0c;bodyParser : 解析 post 请求数据 2&#xff0c;cookies : 读写 cookie 3&#xff0c;swig &#xff1a;模板解析引擎 4&#xff0c;mongoose &#xff1a; 操作 mongodb 数据…

activiti5第五弹 serviceTask中的webserviceTask 以及 shellTask

web service task是BPMN2.0中的一种任务类型&#xff0c;在activiti5中它并没有专门的标签表示&#xff0c;而是使用了service task 来表示。而且有很多要配置的内容是无法用图形化工具来完成的。要使用web service task&#xff0c;当然要先有web service。所以首先要编写一个…

bloc

示例分为两个文件 main.dart import package:flutter/material.dart;import bloc.dart;void main()>runApp(MyApp());class MyApp extends StatelessWidget { override Widget build(BuildContext context) { return MaterialApp( home: HomePage(), ); }}cla…

activiti5第六弹 手动任务、接收任务、邮件任务

手动任务和接收任务几乎不在程序中做什么事情---只是在流程的历史中留下一点痕迹&#xff0c;表明流程是走过某些节点的。。。而且这两个任务是无法用taskservice查询到的 但是接收任务比手动任务多一个功能&#xff0c;就是确认功能。。。 activiti.cfg.xml配置 <?xml v…

手把手教你用原始方式上传项目至GitHub

小编GitHub&#xff1a;https://github.com/ds1889 首先你得注册一个自己的GitHub账号&#xff0c;注册网址&#xff1a;https://github.com/join 有了自己的账号以后&#xff0c;就可以进行登录&#xff0c;开始创建一个新的项目 创建一个新的项目&#xff0c;填写项目名称&am…

office如何快速删除重复数据

1、首先打开如下文档&#xff0c;在A列删除重复日期星期一&#xff0c;星期二&#xff1b; 2、选中编号栏&#xff0c;&#xff21;1-&#xff21;10&#xff0c;如下图: 3、点击数据——删除重复项&#xff1b;如下图红色剪头所指: 4、删除后&#xff0c;重复项就被删除成功。…

亲依止缘

前前诸善法对后后诸善法以亲依止缘为缘。前前诸善法对后后诸不善法有时以亲依止缘为缘。前前诸善法对后后诸无记法以亲依止缘为缘。 前前诸不善法对后后诸不善法以亲依止缘为缘。前前诸不善法对后后诸善法有时以亲依止缘为缘。前前诸不善法对后后诸无记法以亲依止缘为缘。 前前…

Activiti5第七弹,自己实现一个ProcessEngineConfiguration同时自定义拦截器

首先是我自己定义的MyProcessEngineConfiguration的activiti.cfg.xml文件的内容 <?xml version"1.0"?> <beans default-lazy-init"false"xsi:schemaLocation" http://www.springframework.org/schema/util http://www.springframework.org…

SQL中and和or的区别是?

今天有这样得一个需求&#xff0c;如果登陆人是客服的话&#xff0c;会查询订单是’该客服’以及还没有匹配客服的&#xff0c;刚开始想的是直接在sql语句上拼写 or assigned_id is null 的&#xff0c;测试了一下发现这样的话&#xff0c;前面的其他条件都没有用了 这样的话…

Java编程设计---数组Arrays

数组的的定义 数组是存放在连续存储空间的元素集合 数组定义的格式&#xff1a; int[] arrnew int[5]; int&#xff1a;数组元素的数据类型&#xff0c;可以是基本数据类型&#xff0c;也可以是引用 arr&#xff1a;数组名称 5&#xff1a;数组中元素个数 第一步&#xff1a;定…

装饰器模式 decorator

所有的说明和解释都在代码中有注释来标明 package mode.decorator;/*** * 这里定义一个接口&#xff0c;在接口中定义我们要执行的操作。* * 以后所有的装饰器以及我们要装饰的对象都要实现这个接口。有了这样的大前提&#xff0c;我们就可以其用 Sourcable来定义我们的装饰器和…

bzoj1176: [Balkan2007]Mokia cdq

链接 bzoj 思路 cdq入门题&#xff0c;拆成4个矩阵&#xff0c;然后cdq。 代码 /**************************************************************Problem: 1176User: gryz2016Language: CResult: AcceptedTime:2652 msMemory:13012 kb *************************************…

桥接模式(Bridge)

桥接模式&#xff0c;就是把向多个方向发展的变化由继承的实现变为了耦合的实现。 package mode.bridge.test;/*** * 首先是一个抽象的咖啡类&#xff0c;有一个抽象的倒咖啡的方法* * 在这个类中有一个咖啡伴侣的属性&#xff0c;为什么会有这个属性。因为我们在冲咖啡的时候可…

python 中的if else 和in

python中if else 和in的用法php python a3 //python中‘:’是引入一个缩进的代码块 if a1:print(1) elif a3:print(3) else:print("查不到") python中的in 查看一个对象是否在另一个对象中 a[1,2,3,4,5,6] b3 if b in a:print("b在a中") else: 转载于:http…

15年1月的每天小程序

package everyworkdayprogramming._2015_1_04;public class Java_1_4 {/*** * * 打印出所有的水仙花数&#xff0c;所谓水仙花数是指一个三位数&#xff0c;其各位数字立方和等于该数本身。* * */public static void main(String[] args) {int bit 0, ten 0, hun 0;for (int…

SpringBoot整合升级Spring Security 报错 【The request was rejected because the URL was not normalized】...

前言 最近LZ给项目框架升级&#xff0c; 从Spring1.x升级到Spring2.x, 在这里就不多赘述两个版本之间的区别以及升级的原因。 关于升级过程中踩的坑&#xff0c;在其他博文中会做比较详细的记录&#xff0c;以便给读者参考&#xff0c;不要掉进同样的坑里。 这里我们讨论一个关…

个人测试作业

作业所属课程&#xff1a;https://edu.cnblogs.com/campus/xnsy/SoftwareEngineeringClass2 作业地址&#xff1a;https://edu.cnblogs.com/campus/xnsy/SoftwareEngineeringClass2/homework/3340 作业目标&#xff1a;测试其他同学项目 姓名&#xff1a;潘云峰201731062423 所…

安装Nvida 显示环境

查看是否能正确加载nvidia 驱动 在终端输入 &#xff08;glxinfo 需要安装mesa-utils&#xff09; 如果可以正确加载了nvidia驱动 那么在输入的内容中可以看到NVIDIA 字样 如果GPU是IntelGPU 正确加载类似 卸载 老版本 驱动 sudo apt-get purge nvidia* 把显卡驱动加入PPA sudo…

Activiti5第十一弹,流程监听器与任务监听器

首先创建流程监听器和任务监听器的实体类&#xff0c;个人比较喜欢使用Delegate Expression方式&#xff0c;其他两种方式也可以 流程监听器 package org.mpc.final_activiti;import java.io.Serializable;import org.activiti.engine.delegate.DelegateExecution; import org.…

06_go语言基础

// 07枚举 package main import ( "fmt" ) func main() { // 1.iota常量自动生成器&#xff0c;每个一行&#xff0c;自动累加1 // 2.iota给常量赋值使用 const ( a iota // 0 b iota // 1 c iota // 2 ) fmt.Printf("a %d,b %d,c %d\n", a, b, c) /…