flowable与主程序配置两个数据源

<think>好的，用户现在想了解如何在Flowable与主程序之间配置两个数据源。之前他们问过Spring Boot中配置数据源的方法，现在的问题更具体，涉及到多数据源的配置，特别是Flowable工作流引擎和主应用的数据源分开的情况。 首先，我需要回忆一下Flowable的基本配置。Flowable通常需要自己的数据库来存储流程定义、运行时数据等。在Spring Boot中，默认会自动配置一个数据源，但如果主应用和Flowable使用不同的数据库，就需要配置两个数据源。 接下来，用户可能的需求是让主程序使用一个数据源，而Flowable使用另一个。这时候需要考虑多数据源的配置方法，同时确保Flowable正确使用其指定的数据源，而不会与主程序的数据源冲突。 首先，需要创建两个数据源的配置类，分别为主数据源和Flowable数据源。可能需要使用@Primary注解来指定主数据源，避免自动配置时的冲突。然后，配置Flowable的相关Bean，明确指定使用Flowable的数据源。 另外，需要注意事务管理器的配置，每个数据源应该有自己的事务管理器，并且需要为Flowable配置独立的事务管理器，避免事务冲突。 还需要考虑排除Spring Boot的自动配置，特别是DataSourceAutoConfiguration和Flowable的自动配置类，这样才能手动控制数据源的创建和配置。 用户可能在配置过程中遇到的问题包括：数据源冲突导致启动失败，Flowable没有使用指定的数据源，事务管理不正确等。因此，在回答时需要详细说明每个步骤，并提醒注意事项，比如排除自动配置、正确使用@Primary注解、事务管理器的配置等。 此外，用户可能希望看到具体的代码示例，包括Java配置类和application.yml的配置，以及如何验证配置是否生效。测试部分可以通过单元测试来检查两个数据源是否正常工作，比如分别获取连接并验证。 最后，需要总结最佳实践，比如敏感信息的处理（使用配置中心而非硬编码）、多数据源下的性能调优建议，以及可能的扩展方向，比如动态数据源配置等。</think>在Spring Boot应用中为Flowable工作流引擎和主程序配置独立数据源的完整方案如下： --- ### **1. 基础配置结构** ```yaml # application.yml spring: datasource: primary: jdbc-url: jdbc:mysql://localhost:3306/main_db username: main_user password: main_pass driver-class-name: com.mysql.cj.jdbc.Driver flowable: jdbc-url: jdbc:h2:mem:flowable username: sa password: driver-class-name: org.h2.Driver ``` --- ### **2. 主数据源配置（带@Primary）** ```java @Configuration public class PrimaryDataSourceConfig { @Primary @Bean(name = "primaryDataSource") @ConfigurationProperties(prefix = "spring.datasource.primary") public DataSource primaryDataSource() { return DataSourceBuilder.create().build(); } @Primary @Bean(name = "primaryTransactionManager") public PlatformTransactionManager primaryTransactionManager( @Qualifier("primaryDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } } ``` --- ### **3. Flowable专属数据源配置** ```java @Configuration public class FlowableDataSourceConfig { @Bean(name = "flowableDataSource") @ConfigurationProperties(prefix = "spring.datasource.flowable") public DataSource flowableDataSource() { return DataSourceBuilder.create().build(); } @Bean(name = "flowableTransactionManager") public PlatformTransactionManager flowableTransactionManager( @Qualifier("flowableDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } } ``` --- ### **4. Flowable引擎配置类** ```java @Configuration public class FlowableConfig { @Bean public SpringProcessEngineConfiguration processEngineConfiguration( @Qualifier("flowableDataSource") DataSource dataSource, @Qualifier("flowableTransactionManager") PlatformTransactionManager transactionManager) { SpringProcessEngineConfiguration config = new SpringProcessEngineConfiguration(); config.setDataSource(dataSource); config.setTransactionManager(transactionManager); config.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE); config.setAsyncExecutorActivate(true); // 启用异步执行器 return config; } @Bean public ProcessEngine processEngine(SpringProcessEngineConfiguration config) { return config.buildProcessEngine(); } } ``` --- ### **5. 排除自动配置** ```java @SpringBootApplication(exclude = { DataSourceAutoConfiguration.class, DataSourceTransactionManagerAutoConfiguration.class, FlowableAutoConfiguration.class }) public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } } ``` --- ### **6. 多数据源验证测试** ```java @SpringBootTest class MultiDataSourceTest { @Autowired @Qualifier("primaryDataSource") private DataSource primaryDataSource; @Autowired @Qualifier("flowableDataSource") private DataSource flowableDataSource; @Test void testPrimaryConnection() throws SQLException { try (Connection conn = primaryDataSource.getConnection()) { assertTrue(conn.isValid(2)); assertEquals("main_db", conn.getCatalog()); } } @Test void testFlowableConnection() throws SQLException { try (Connection conn = flowableDataSource.getConnection()) { assertTrue(conn.isValid(2)); assertEquals("flowable", ((JdbcConnection) conn).getCatalog()); } } } ``` --- ### **关键注意事项** 1. **事务管理器隔离**：必须为每个数据源单独配置事务管理器，避免事务交叉污染 2. **JPA/Hibernate配置**：若使用ORM框架，需指定`@EntityScan`和`@EnableJpaRepositories`的basePackages ```java @EnableJpaRepositories( basePackages = "com.example.main", entityManagerFactoryRef = "primaryEntityManager", transactionManagerRef = "primaryTransactionManager" ) ``` 3. **连接池优化**：建议为Flowable配置独立连接池参数 ```yaml spring.datasource.flowable: hikari: maximum-pool-size: 10 connection-timeout: 3000 ``` 4. **Schema初始化**：生产环境建议关闭自动更新Schema ```java config.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_FALSE); ``` --- ### **典型问题排查** 1. **启动时报数据源冲突**：检查是否漏掉@Primary注解 2. **Flowable表创建到错误数据库**：确认ProcessEngineConfiguration使用的数据源 3. **事务不生效**：验证@Transactional注解是否指定了正确的事务管理器 通过这种配置方式，可以实现业务数据与流程数据的物理隔离，同时保证两个系统的独立扩展能力。