【前言】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"/>
以上之所以注入引擎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 即可。