activiti学习之基础环境搭建

缺乏、安全感 2022-09-14 16:16 203阅读 0赞

## 写在前面 ##

本文介绍在spring环境中使用activiti。

## 1：pom ##

<dependencies>
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.12</version>
        </dependency>
        
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-orm</artifactId>
          <version>5.1.15.RELEASE</version>
        </dependency>
        <dependency>
          <groupId>org.aspectj</groupId>
          <artifactId>aspectjweaver</artifactId>
          <version>1.9.2</version>
          <scope>runtime</scope>
        </dependency>
        
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-core</artifactId>
          <version>5.1.15.RELEASE</version>
        </dependency>
        
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-context</artifactId>
          <version>5.1.15.RELEASE</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-context-support</artifactId>
          <version>5.1.15.RELEASE</version>
        </dependency>
        
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-beans</artifactId>
          <version>5.1.15.RELEASE</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-web</artifactId>
          <version>5.1.15.RELEASE</version>
        </dependency>
        <dependency>
          <groupId>mysql</groupId>
          <artifactId>mysql-connector-java</artifactId>
          <version>5.1.32</version>
        </dependency>
        
        <dependency>
          <groupId>com.alibaba</groupId>
          <artifactId>druid</artifactId>
          <version>1.1.12</version>
        </dependency>
    
        <dependency>
          <groupId>org.mybatis</groupId>
          <artifactId>mybatis</artifactId>
          <version>3.3.1</version>
        </dependency>
        
        <dependency>
          <groupId>org.mybatis</groupId>
          <artifactId>mybatis-spring</artifactId>
          <version>1.3.2</version>
        </dependency>
        <dependency>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
          <version>1.7.5</version>
        </dependency>
        <dependency>
          <groupId>cglib</groupId>
          <artifactId>cglib</artifactId>
          <version>3.2.5</version>
        </dependency>
    
        
        <dependency>
          <groupId>org.activiti</groupId>
          <artifactId>activiti-engine</artifactId>
          <version>5.22.0</version>
        </dependency>
        <dependency>
          <groupId>org.activiti</groupId>
          <artifactId>activiti-spring</artifactId>
          <version>5.22.0</version>
        </dependency>
    </dependencies>

## 2：配置文件 ##

### 2.1：activiti.properties ###

#<property name="driverClassName" value="${db.driverClassName}"/>
    db.driverClassName=com.mysql.jdbc.Driver
    #<property name="url" value="${db.url}"/>
    db.url=jdbc:mysql://localhost:3366/activitiTest?useUnicode=true&characterEncoding=UTF-8
    #<property name="username" value="${db.username}"/>
    db.username=root
    #<property name="password" value="${db.password}"/>
    db.password=root

### 2.2：spring-activiti.xml ###

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:tx="http://www.springframework.org/schema/tx" xmlns="http://www.springframework.org/schema/beans" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
    
    <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
            <property name="ignoreUnresolvablePlaceholders" value="true"/>
            <property name="locations">
                <list>
    
                    <value>classpath:com/jh/activiti/activiti.properties</value>
                </list>
            </property>
        </bean>
    
        <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
            <property name="driverClassName" value="${db.driverClassName}"/>
            <property name="url" value="${db.url}"/>
            <property name="username" value="${db.username}"/>
            <property name="password" value="${db.password}"/>
            <property name="initialSize" value="3"/>
            <property name="minIdle" value="3"/>
            <property name="maxActive" value="20"/>
            <property name="maxWait" value="60000"/>
            <property name="filters" value="stat,wall"/>
        </bean>
    
        
        <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource"/>
        </bean>
    
        <tx:annotation-driven transaction-manager="transactionManager"/>
    
        
    
        
        <bean id="asyncExecutor" class="org.activiti.engine.impl.asyncexecutor.DefaultAsyncJobExecutor">
            
            <property name="executorService" ref="executorService"/>
        </bean>
        <bean id="executorService" class="org.springframework.scheduling.concurrent.ThreadPoolExecutorFactoryBean">
            <property name="threadNamePrefix" value="activiti-job-"/>
            <property name="corePoolSize" value="10"/>
            <property name="maxPoolSize" value="20"/>
            <property name="queueCapacity" value="100"/>
            
            <property name="rejectedExecutionHandler">
                <bean class="java.util.concurrent.ThreadPoolExecutor$AbortPolicy"/>
            </property>
        </bean>
    
        
        <bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration" p:dataSource-ref="dataSource" p:transactionManager-ref="transactionManager" p:databaseSchemaUpdate="true" p:jobExecutorActivate="true" p:databaseType="mysql" p:activityFontName="宋体" p:labelFontName="黑体" p:xmlEncoding="utf-8">
            
        </bean>
    
        
        <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean" p:processEngineConfiguration-ref="processEngineConfiguration"/>
    
        
        <bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService"/>
        <bean id="runtimeService" factory-bean="processEngine" factory-method="getRuntimeService"/>
        <bean id="taskService" factory-bean="processEngine" factory-method="getTaskService"/>
        <bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService"/>
        <bean id="formService" factory-bean="processEngine" factory-method="getFormService"/>
        <bean id="identityService" factory-bean="processEngine" factory-method="getIdentityService"/>
    
    </beans>

## 3：数据库初始化 ##

// 创建数据库
    @Test
    public void test_createDatabase() { 
        // 创建流程引擎配置信息对象
        ProcessEngineConfiguration pec = ProcessEngineConfiguration
                .createStandaloneProcessEngineConfiguration();
        // 设置数据库的类型
        pec.setDatabaseType("mysql");
        // 设置创建数据库的方式
    // ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE(true);//如果没有数据库表就会创建数据库表，有的话就修改表结构.
        // ProcessEngineConfiguration.DB_SCHEMA_UPDATE_FALSE(false): 不会创建数据库表
        // ProcessEngineConfiguration.DB_SCHEMA_UPDATE_CREATE_DROP(create-drop): 先创建、再删除.
        pec.setDatabaseSchemaUpdate("true");
        // 设置数据库驱动
        pec.setJdbcDriver("com.mysql.jdbc.Driver");
        // 设置jdbcURL
        pec.setJdbcUrl("jdbc:mysql://localhost:3366/activitiTest?useUnicode=true&characterEncoding=UTF-8");
        // 设置用户名
        pec.setJdbcUsername("root");
        // 设置密码
        pec.setJdbcPassword("root");
        // 构建流程引擎对象
        ProcessEngine pe = pec.buildProcessEngine(); // 调用访方法才会创建数据表
        // 调用close方法时，才会删除
        pe.close();
    }

成功后会生成activiti需要用到的表，如下：

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2FuZzA5MDc_size_12_color_FFFFFF_t_70_g_se_x_16]

## 4：测试 ##

搭建一个简单的流程，自己随意搭一个就行，如下是我的：

![在这里插入图片描述][711a343d05c3457f88c9839a83aecfa8.png]

测试代码：

// @Autowired
    private ProcessEngine processEngine;
    // @Autowired
    private static TaskService taskService;
    // @Autowired
    private RuntimeService runtimeService;
    // @Autowired
    private HistoryService historyService;
    private static RepositoryService repositoryService;
    
    @Before
    public void prepareService() { 
        ApplicationContext ac =
                new ClassPathXmlApplicationContext("classpath:com/jh/activiti/spring-activiti.xml");
        processEngine = ac.getBean(ProcessEngine.class);
        taskService = ac.getBean(TaskService.class);
        runtimeService = ac.getBean(RuntimeService.class);
        historyService = ac.getBean(HistoryService.class);
        repositoryService = ac.getBean(RepositoryService.class);
    }
    
    /* * 部署流程定义 */
    @Test
    public void deploy() { 
        Deployment deployment = repositoryService.createDeployment() // 创建部署
                .addClasspathResource("com/jh/activiti/jumpTo.bpmn20.xml") // 加载流程资源文件
                .name("测试任务退回") // 流程名称
                .deploy(); // 部署
        System.out.println("流程部署ID:" + deployment.getId());
        System.out.println("流程部署Name:" + deployment.getName());
    }
    
    /** * 启动流程实例 */
    @Test
    public void start() { 
        // 不会在act_ru_task表中生成数据，即不会生成任务，但是会在act_ru_execution表中生成数据，可以通过queryExecution查询
        // , 通过completeTask执行
        ProcessInstance pi = runtimeService.startProcessInstanceByKey("jumpTo"); // 流程定义表的KEY字段值
        System.out.println("流程实例ID:" + pi.getId());
        System.out.println("流程定义ID:" + pi.getProcessDefinitionId());
    }
    
    @Test
    public void complete() { 
        // 直属领导审批
    // taskService.complete("677507");
        // 部门领导审批
    // taskService.complete("680007");
        // 董事长审批
        taskService.complete("682502");
    }

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2FuZzA5MDc_size_12_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/58ac0b79a7744f6d8be3102d5c5071d4.png
[711a343d05c3457f88c9839a83aecfa8.png]: /images/20220828/b9d9b50542884086945cbecb4807d5b0.png