spring整合activiti

【前言】activiti在实际的生产环境下最终还是要与spring进行整合来完成自身的使命，我们知道activiti要运行必须要基于自己的数据源，所以在整合时，我们可以使用一个库（项目所用表和activiti的23张表放在一个库）来配置数据源，也可以分开库，将activiti的23张表单独建库存储，注意对应上数据源即可。一般使用一个库方便一点。

【思路】我们知道activiti中最重要的就是引擎对象ProcessEngine，所有的流程相关操作都要依赖activiti的引擎去实现，所以问题的最终解决方案即将引擎对象ProcessEngine注入到spring中交给spring容器进行管理

【1】创建工程引入jar包
【2】添加spring配置

<!-- 流程引擎配置对象 -->
    <bean id="processEngineConfiguration"
         class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <property name="jdbcDriver"  value="com.mysql.jdbc.Driver"/>
        <property name="jdbcUrl"  value="jdbc:mysql://localhost:3307/bos"/>
        <property name="jdbcUsername"  value="root"/>
        <property name="jdbcPassword"  value="123"/>
        <property name="databaseSchemaUpdate" value="true"/>
    </bean>

    <!-- 使用工厂创建流程引擎对象 -->
    <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
        <property name="processEngineConfiguration" ref="processEngineConfiguration"/>
    </bean>

注意：上边用的spring-jdbc数据源，当然也可以导入c3p0.jar配置其对应数据源
【3】测试类

/**
 * 
 * ClassName: SpringActivitiTest
 * @author lvfang
 * @Desc: 测试spring整合activiti
 * @date 2017-9-6
 */
public class SpringActivitiTest {

    public static void main(String[] args) {
        // 创建spring工厂
        ApplicationContext ctx = new ClassPathXmlApplicationContext("com\\itheima\\activiti\\spring\\applicationContext.xml");
        // 从工厂中获得对象
        ProcessEngine processEngine = (ProcessEngine) ctx.getBean("processEngine");
        List<ProcessDefinition> list = processEngine.getRepositoryService().createProcessDefinitionQuery().list();
        for (ProcessDefinition processDefinition : list) {
            System.out.println(processDefinition);
        }
    }
}

【spring整合activiti在项目中的使用】
【修改spring配置】

spring 配置下添加内容如下


    <!-- activiti整合spring配置 -->
    <bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
        <!-- 注入数据源 -->
        <property name="dataSource" ref="dataSource"/>
        <!-- 注入事务管理器对象 -->
        <property name="transactionManager" ref="txManager"/>
        <property name="databaseSchemaUpdate" value="true" />
    </bean>

    <!-- 使用工厂创建流程引擎对象 -->
    <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
        <property name="processEngineConfiguration" ref="processEngineConfiguration" />
    </bean>
    
    <!-- 注册activiti相关的Service（由于在具体操作流中最终都使用的各种service，所以不需要去action注入流程引擎processEngine） -->
    <bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService"/>
    <bean id="runtimeService" factory-bean="processEngine" factory-method="getRuntimeService"/>
    <bean id="taskService" factory-bean="processEngi,ne" factory-method="getTaskService"/>
    <bean id="identityService" factory-bean="processEngine" factory-method="getIdentityService"/>

2017-09-07_104909.png

以上之所以注入引擎processEngine后没有直接用，而是通过引擎工厂获取其常用的service（repositoryService、getRuntimeService、taskService、identityService）,最终是将各个service注入到action来实现具体的业务

【action实现】

/**
 * 
 * ClassName: ProcessDefinitionAction
 * @author lvfang
 * @Desc: 流程定义管理
 * @date 2017-9-6
 */
@Controller
@Scope("prototype")
public class ProcessDefinitionAction extends ActionSupport {
    
    @Autowired
    private RepositoryService repositoryService;

    /**
     * 查询最新版本的流程定义数据
     * @return
     */
    public String list(){
        ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery();
        query.latestVersion();
        query.orderByProcessDefinitionName().desc();
        List<ProcessDefinition> list = query.list();
        //压栈
        ActionContext.getContext().getValueStack().set("list", list);
        return "list";
    }
    
    /**
     * 部署流程定义
     * @return
     * @throws FileNotFoundException 
     */
    public String deploy() throws FileNotFoundException{
        DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();
        deploymentBuilder.addZipInputStream(new ZipInputStream(new FileInputStream(zipFile)));
        deploymentBuilder.deploy();
        return "toList";
    }

}

注意，在流程定义中不需要实体去包装参数，所以这里不需要去继承baseAction，而是extends ActionSupport 即可。