2：spring_activiti.xml文件
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.springframework.org/schema/beans" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> <!-- 配置数据源连接池 --> <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> <!-- 数据库连接属性 -->--> <property name="url" value="jdbc:mysql://localhost:3306/pmsdb?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&useSSL=false"/> <property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="username" value="root"/> <property name="password" value="root"/> <!-- 启用系统监控过滤器 --> <property name="filters" value="stat"/> <!-- 最大连接池数量 --> <property name="maxActive" value="200"/> <!-- 初始化时建立物理连接的个数--> <property name="initialSize" value="5"/> <!-- 最小连接池数量--> <property name="minIdle" value="5"/> <!-- 获取连接时最大等待时间，单位毫秒--> <property name="maxWait" value="60000"/> <!-- 销毁线程会检测连接的间隔时间，（单位毫秒） 如果连接空闲时间大于等于minEvictableIdleTimeMillis则关闭物理连接--> <property name="timeBetweenEvictionRunsMillis" value="60000"/> <!-- 连接保持空闲而不被驱逐的最小时间 --> <property name="minEvictableIdleTimeMillis" value="300000"/> <!--申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis， 执行validationQuery检测连接是否有效--> <property name="testWhileIdle" value="true"/> <!-- 申请连接时执行validationQuery检测连接是否有效 --> <property name="testOnBorrow" value="false"/> <!-- 归还连接时执行validationQuery检测连接是否有效--> <property name="testOnReturn" value="false"/> <!-- 是否缓存preparedStatement, mysql建议关闭--> <property name="poolPreparedStatements" value="false"/> <!-- 伪SQL，用于检查连接是否可用 --> <property name="validationQuery" value="select 1"/> </bean> <!-- 装配DataSource的事务管理器--> <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <!-- 需要注入一个DataSource --> <property name="dataSource" ref="dataSource"/> </bean> <!--创建一个流程引擎的配置对象 这里我们使用的是Spring提供的流程引擎对象--> <bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration"> <property name="dataSource" ref="dataSource"/> <property name="transactionManager" ref="txManager"/> <!-- 是否自动创建25张表 --> <property name="databaseSchemaUpdate" value="true"/> <!--是否启动jobExecutor--> <property name="jobExecutorActivate" value="false"/> <property name="databaseType" value="mysql"/> <property name="activityFontName" value="宋体"/> <property name="labelFontName" value="黑体"/> </bean> <!--<property name="xmlEncoding" value="utf-8"/>--> <!-- 创建一个流程引擎bean --> <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean"> <property name="processEngineConfiguration" ref="processEngineConfiguration"/> </bean> <!--配置服务Bean,定义Service服务--> <!--工作流仓储服务，对所有atc_re开头的表进行操作--> <bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService"/> <!--工作流运行服务 对所有act_ru开头的表进行操作 --> <bean id="runtimeService" factory-bean="processEngine" factory-method="getRuntimeService"/> <!--工作流任务服务--> <bean id="taskService" factory-bean="processEngine" factory-method="getTaskService"/> <!--工作流历史数据服务 对所有的act_hi开头的表进行操作--> <bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService"/> <!--工作流管理服务--> <bean id="managementService" factory-bean="processEngine" factory-method="getManagementService"/> <!--工作流唯一服务， 对所有以act_id开头的表进行增删改查--> <bean id="identityService" factory-bean="processEngine" factory-method="getIdentityService"/> <!--工作流管理服务--> <bean id="formService" factory-bean="processEngine" factory-method="getFormService"/> </beans>3：别忘了将spring.activiti.xml注入到spring容器中，交给spring容器管理
<!--引入工作流配置文件--> <import resource="classpath*:spring-activiti.xml"/>4.启动项目时，将生成25张框架自带的表
4.1：部分表的含义
序号
表名
说明
1
act_ge_bytearray
二进制数据表
2
act_ge_property
属性数据表存储整个流程引擎级别的数据,初始化表结构时，会默认插入三条记录，
3
act_hi_actinst
历史节点表
4
act_hi_attachment
历史附件表
5
act_hi_comment
历史意见表
6
act_hi_identitylink
历史流程人员表
7
act_hi_detail
历史详情表，提供历史变量的查询
8
act_hi_procinst
历史流程实例表
9
act_hi_taskinst
历史任务实例表
10
act_hi_varinst
历史变量表
11
act_id_group
用户组信息表
12
act_id_info
用户扩展信息表
13
act_id_membership
用户与用户组对应信息表
14
act_id_user
用户信息表
15.
act_re_deployment
部署信息表
16.
act_re_model
流程设计模型部署表
17
act_re_procdef
流程定义数据表
18
act_ru_event_subscr
throwEvent、catchEvent时间监听信息表
19
act_ru_execution
运行时流程执行实例表
20
act_ru_identitylink
运行时流程人员表，主要存储任务节点与参与者的相关信息
21
act_ru_job
运行时定时任务数据表
22
act_ru_task
运行时任务节点表
23
act_ru_variable
运行时流程变量数据表
5：测试流程，首先使用idea下载activiti插件actiBPM，下载后重启idea，画出流程图，并生成png图片
apply.bpmnapply.png图片
5：WorkFlowTest package com.htzs.pms.service.address.impl; import org.activiti.engine.*; import org.activiti.engine.repository.Deployment; import org.activiti.engine.task.Task; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringRunner; import org.springframework.test.context.web.WebAppConfiguration; import java.util.List; /** * @author : ywb * @createdDate : 2019/9/18 * @updatedDate */ @RunWith(SpringRunner.class) @ContextConfiguration(locations = {"classpath:dispatcher-dao.xml", "classpath:dispatcher-service.xml"}) @WebAppConfiguration public class WorkFlowTest { /** * 测试activiti是否与spring整合成功,成功标志如下 * 控制台输出org.activiti.engine.impl.ProcessEngineImpl@4721ee77说明已经整合成功 */ @Test public void test() { // 1.创建Activiti配置对象的实例 ProcessEngineConfiguration configuration = ProcessEngineConfiguration .createStandaloneProcessEngineConfiguration(); // 2.设置数据库连接信息 // 设置数据库的类型 configuration.setDatabaseType("mysql"); // 设置数据库驱动 configuration.setJdbcDriver("com.mysql.jdbc.Driver"); // 设置jdbcURL configuration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&useSSL=false"); // 设置用户名 configuration.setJdbcUsername("root"); // 设置密码 configuration.setJdbcPassword("root"); // 设置数据库建表策略 /** * DB_SCHEMA_UPDATE_TRUE：如果不存在表就创建表，存在就直接使用 * DB_SCHEMA_UPDATE_FALSE：如果不存在表就抛出异常 * DB_SCHEMA_UPDATE_CREATE_DROP：每次都先删除表，再创建新的表 */ configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_CREATE_DROP); // 3.使用配置对象创建流程引擎实例（检查数据库连接等环境信息是否正确） ProcessEngine processEngine = configuration.buildProcessEngine(); System.out.println(processEngine); } /** * 第二种创建方式 一般使用最多的就是这种创建方式 */ @Test public void initActiviti() { ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); System.out.println(processEngine); } @Autowired private RepositoryService repositoryService; @Autowired private RuntimeService runtimeService; @Autowired private TaskService taskService; /** * 部署流程定义 */ @Test public void deployProcess(){ //得到流程部署的service Deployment deploy = repositoryService.createDeployment().name("请假流程001") .addClasspathResource("apply.bpmn") .addClasspathResource("apply.png").deploy(); System.out.println("部署成功，流程id:"+deploy.getId()); } /** * 启动流程 */ @Test public void startProcess(){ //使用key启动流程 runtimeService.startProcessInstanceByKey("myProcess_1"); //使用id启动流程 // runtimeService.startProcessInstanceById("myProcess_1:1:4"); System.out.println("流程启动成功"); } /** * 查询流程 */ @Test public void findProcess(){ List<Task> tasks = taskService.createTaskQuery().taskAssignee("王五").list(); for (Task task : tasks) { System.out.println("任务id"+task.getId()); System.out.println("流程实例id"+task.getProcessInstanceId()); System.out.println("执行实例id"+task.getExecutionId()); System.out.println("流程定义id"+task.getProcessDefinitionId()); System.out.println("任务名称"+task.getName()); System.out.println("任务办理人"+task.getAssignee()); } } @Test public void completeProcess(){ taskService.complete("10002"); System.out.println("任务完成"); } }
三：使用配置类代替spring.activiti.xml1：需要使用的maven
<dependency> <groupId>org.activiti</groupId> <artifactId>activiti-spring</artifactId> <version>6.0.0</version> </dependency>
2：配置类
package edu.nf.project.config; import org.activiti.engine.*; import org.activiti.spring.ProcessEngineFactoryBean; import org.activiti.spring.SpringProcessEngineConfiguration; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.Resource; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import org.springframework.transaction.PlatformTransactionManager; import javax.sql.DataSource; import java.io.IOException; /** * @author : ywb * @createdDate : 2019/9/20 * @updatedDate */ @Configuration public class ActivitiConfiguration { @Autowired private DataSource dataSource; @Autowired private PlatformTransactionManager platformTransactionManager; /** * 创建一个流程引擎的配置对象 这里我们使用的是Spring提供的流程引擎对象 * 创建一个流程引擎的配置对象 这里我摸嗯使用的事Spring提供的流程引擎对象 * @return */ @Bean public SpringProcessEngineConfiguration springProcessEngineConfiguration(){ SpringProcessEngineConfiguration spec = new SpringProcessEngineConfiguration(); spec.setDataSource(dataSource); spec.setTransactionManager(platformTransactionManager); spec.setDatabaseSchemaUpdate("true"); Resource[] resources = null; // 启动自动部署流程 try { resources = new PathMatchingResourcePatternResolver().getResources("classpath*:bpmn/*.bpmn"); } catch (IOException e) { e.printStackTrace(); } spec.setDeploymentResources(resources); return spec; } /** * 创建一个流程引擎bean * @return */ @Bean public ProcessEngineFactoryBean processEngine(){ ProcessEngineFactoryBean processEngineFactoryBean = new ProcessEngineFactoryBean(); processEngineFactoryBean.setProcessEngineConfiguration(springProcessEngineConfiguration()); return processEngineFactoryBean; } /** * 工作流仓储服务，对所有atc_re开头的表进行操作- * @return * @throws Exception */ @Bean public RepositoryService repositoryService() throws Exception{ return processEngine().getObject().getRepositoryService(); } /** * 工作流运行服务 对所有act_ru开头的表进行操作 * @return * @throws Exception */ @Bean public RuntimeService runtimeService() throws Exception{ return processEngine().getObject().getRuntimeService(); } /** * 工作流任务服务 * @return * @throws Exception */ @Bean public TaskService taskService() throws Exception{ return processEngine().getObject().getTaskService(); } /** * 工作流历史数据服务 对所有的act_hi开头的表进行操作 * @return * @throws Exception */ @Bean public HistoryService historyService() throws Exception{ return processEngine().getObject().getHistoryService(); } /** * 工作流唯一服务，对所有以act_id开头的表进行增删改查 * @return * @throws Exception */ public IdentityService identityService() throws Exception{ return processEngine().getObject().getIdentityService(); } /** * 工作流管理服务 * @return * @throws Exception */ public FormService formService() throws Exception{ return processEngine().getObject().getFormService(); } /** * 工作流管理服务 * @return * @throws Exception */ public ManagementService managementService() throws Exception{ return processEngine().getObject().getManagementService(); } }转载于:https://www.cnblogs.com/ywbmaster/p/11557070.html
相关资源：activiti spring srping Mvc mybatis maven整合