Flowable入门系列文章14 - 整合Spring 01

Posted 2021-10-24 分享牛

你肯定可以地使用Flowable without Spring，但是我们会介绍一些非常好的集成特性。

1、ProcessEngineFactoryBean

该ProcessEngine可配置为一个普通的Spring bean。整合的起点是班级org.flowable.spring.ProcessEngineFactoryBean。该bean采用流程引擎配置并创建流程引擎。这意味着Spring的属性的创建和配置与配置部分中记录的相同。对于Spring集成，配置和引擎bean将如下所示：

<bean id="processEngineConfiguration" class="org.flowable.spring.SpringProcessEngineConfiguration">
...
</bean>
<bean id="processEngine" class="org.flowable.spring.ProcessEngineFactoryBean">
<property name="processEngineConfiguration" ref="processEngineConfiguration" />
</bean>

请注意，这个processEngineConfigurationbean现在使用这个org.flowable.spring.SpringProcessEngineConfiguration类。

2、交易

我们将SpringTransactionIntegrationTest逐步解释在Spring的例子中发现的分布。下面是我们在这个例子中使用的Spring配置文件（你可以在SpringTransactionIntegrationTest-context.xml中找到它）。下面显示的部分包含dataSource，transactionManager，processEngine和Flowable引擎服务。

将DataSource传递给SpringProcessEngineConfiguration（使用属性“dataSource”）时，Flowable在
org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy内部使用包装传递的DataSource。这样做是为了确保从
DataSource和Spring事务检索到的SQL连接能够很好地协同工作。这意味着它不再需要代理的数据源自己在Spring的配置，虽然它仍然可能通过一个TransactionAwareDataSourceProxy进入SpringProcessEngineConfiguration。在这种情况下，不会发生额外的包装。

确保TransactionAwareDataSourceProxy在Spring配置中声明自己并不是将它用于已经知道Spring事务的资源（例如
DataSourceTransactionManager和JPATransactionManager需要未经代理的数据源）。

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
<bean id="dataSource" class="org.springframework.jdbc.datasource.SimpleDriverDataSource">
<property name="driverClass" value="org.h2.Driver" />
<property name="url" value="jdbc:h2:mem:flowable;DB_CLOSE_DELAY=1000" />
<property name="username" value="sa" />
<property name="password" value="" />
</bean>
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
<bean id="processEngineConfiguration" class="org.flowable.spring.SpringProcessEngineConfiguration">
<property name="dataSource" ref="dataSource" />
<property name="transactionManager" ref="transactionManager" />
<property name="databaseSchemaUpdate" value="true" />
<property name="asyncExecutorActivate" value="false" />
</bean>
<bean id="processEngine" class="org.flowable.spring.ProcessEngineFactoryBean">
<property name="processEngineConfiguration" ref="processEngineConfiguration" />
</bean>
<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="managementService" factory-bean="processEngine" factory-method="getManagementService" />
...

这个Spring配置文件的其余部分包含了我们在这个特例中使用的bean和配置：

<beans>
...
<tx:annotation-driven transaction-manager="transactionManager"/>
<bean id="userBean" class="org.flowable.spring.test.UserBean">
<property name="runtimeService" ref="runtimeService" />
</bean>
<bean id="printer" class="org.flowable.spring.test.Printer" />
</beans>

首先，应用程序上下文是使用Spring支持的任何方式创建的。在这个例子中，您可以使用类路径XML资源来配置我们的Spring应用程序上下文：

ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(
"org/flowable/examples/spring/SpringTransactionIntegrationTest-context.xml");

或者，用这个方法试一试：

@ContextConfiguration(
"classpath:org/flowable/spring/test/transaction/SpringTransactionIntegrationTest-context.xml")

然后我们可以得到服务bean并调用它们的方法。ProcessEngineFactoryBean将向Flowable服务方法上应用Propagation.REQUIRED事务语义的服务添加一个额外的拦截器。所以，例如，我们可以使用repositoryService像这样部署一个进程：

RepositoryService repositoryService =
(RepositoryService) applicationContext.getBean("repositoryService");
String deploymentId = repositoryService
.createDeployment()
.addClasspathResource("org/flowable/spring/test/hello.bpmn20.xml")
.deploy()
.getId();

反过来也可以。在这种情况下，Spring事务将在userBean.hello（）方法的周围，并且Flowable服务方法调用将加入同一个事务。

UserBean userBean = (UserBean) applicationContext.getBean("userBean");
userBean.hello();

UserBean看起来像这样。请记住，从上面的Spring bean配置中，我们将repositoryService注入到userBean中。

public class UserBean {
/** injected by Spring */
private RuntimeService runtimeService;
@Transactional
public void hello() {
// here you can do transactional stuff in your domain model
// and it will be combined in the same transaction as
// the startProcessInstanceByKey to the Flowable RuntimeService
runtimeService.startProcessInstanceByKey("helloProcess");
} p
ublic void setRuntimeService(RuntimeService runtimeService) {
this.runtimeService = runtimeService;
}
}

上面文章来自盘古BPM研究院：http://vue.pangubpm.com/
文章翻译提交：https://github.com/qiudaoke/flowable-userguide
了解更多文章可以关注微信公众号：