ac86u做网站服务器wordpress前端用户中心投稿
Java中配置两个r2db连接不同的数据库
在实际项目中不可避免的存在使用两个数据库的情况，下面将系统地讲解相关配置方案，包含配置文件、数据库配置类、注解原理、常见错误排查等维度
🧩 一、配置文件说明（application.yml）
spring:r2dbc:url: r2dbc:pool:postgresql://localhost:5432/db1username: user1password: pass1pool:initial-size: 5max-size: 20secondary:r2dbc:url: r2dbc:postgresql://localhost:5432/your_dbusername: your_userpassword: your_passwordpool:initial-size: 3max-size: 15
🔍 说明
- spring.r2dbc: Spring Boot 默认加载的主数据源配置。
- secondary.r2dbc: 自定义的第二数据源。不会自动装配，需要你手动配置 Bean。
- r2dbc:pool: 和 r2dbc: 区别：
- r2dbc:pool: 表示使用 连接池（推荐）
- r2dbc: 表示原始的非连接池驱动
⚙️ 二、主数据源配置类 PrimaryDatabaseConfig
@Configuration
public class PrimaryDatabaseConfig {@Value("${spring.r2dbc.url}")private String url;@Value("${spring.r2dbc.username}")private String username;@Value("${spring.r2dbc.password}")private String password;@Primary@Bean(name = "primaryConnectionFactory")public ConnectionFactory primaryConnectionFactory() {return ConnectionFactories.get(ConnectionFactoryOptions.parse(url).mutate().option(ConnectionFactoryOptions.USER, username).option(ConnectionFactoryOptions.PASSWORD, password).build());}@Primary@Bean(name = "primaryTemplate")public R2dbcEntityTemplate primaryTemplate(@Qualifier("primaryConnectionFactory") ConnectionFactory connectionFactory) {return new R2dbcEntityTemplate(connectionFactory);}
}
✅ 核心点
- @Primary: 表示这个是默认优先注入的 Bean。在有多个候选 Bean 时，优先使用这个。
- ConnectionFactory: R2DBC 中类似 JDBC 的 DataSource。
- R2dbcEntityTemplate: 相当于 JdbcTemplate，提供操作数据库的工具类（基于反应式编程）。
⚙️ 三、第二数据源配置类 SecondaryDatabaseConfig
@Configuration
public class SecondaryDatabaseConfig {@Value("${secondary.r2dbc.url}")private String url;@Value("${secondary.r2dbc.username}")private String username;@Value("${secondary.r2dbc.password}")private String password;@Bean(name = "secondaryConnectionFactory")public ConnectionFactory secondaryConnectionFactory() {return ConnectionFactories.get(ConnectionFactoryOptions.parse(url).mutate().option(ConnectionFactoryOptions.USER, username).option(ConnectionFactoryOptions.PASSWORD, password).build());}@Bean(name = "secondaryTemplate")public R2dbcEntityTemplate secondaryTemplate(@Qualifier("secondaryConnectionFactory") ConnectionFactory connectionFactory) {return new R2dbcEntityTemplate(connectionFactory);}
}
✅ 核心点
- 没有 @Primary，所以必须使用 @Qualifier(“secondaryTemplate”) 指定注入
- 路径读取的是 secondary.r2dbc.xxx，需要明确在配置文件中写对。
🧪 四、使用方式示例
@Service
public class MyService {private final R2dbcEntityTemplate primaryTemplate;private final R2dbcEntityTemplate secondaryTemplate;public MyService(@Qualifier("primaryTemplate") R2dbcEntityTemplate primaryTemplate,@Qualifier("secondaryTemplate") R2dbcEntityTemplate secondaryTemplate) {this.primaryTemplate = primaryTemplate;this.secondaryTemplate = secondaryTemplate;}public Mono<Void> test() {return primaryTemplate.getDatabaseClient().sql("SELECT 1").fetch().rowsUpdated().then(secondaryTemplate.getDatabaseClient().sql("SELECT 2").fetch().rowsUpdated()).then();}
}
🚫 常见错误排查
| 问题描述 | 原因 | 解决方法 |
|---|---|---|
@Qualifier("secondaryTemplate") 提示找不到 | Spring 容器未识别 Bean 名称 | 确保 @Bean(name = "...") 名称一致 |
primaryTemplate 和 secondaryTemplate 互相冲突 | 缺失 @Primary | 给默认数据源添加 @Primary |
| 自动装配失败 | R2dbcEntityTemplate 没有显式注入 | 必须手动注册多个数据源对应的 R2dbcEntityTemplate |
ConnectionFactories.get() 报错 | URL 配置错误或缺失驱动 | 检查 url 格式是否是 r2dbc:postgresql:，并确保依赖添加了 R2DBC Postgres 驱动 |
📦 五、依赖配置
确保你添加了以下依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency><dependency><groupId>io.r2dbc</groupId><artifactId>r2dbc-postgresql</artifactId>
</dependency><!-- 可选：连接池支持 -->
<dependency><groupId>io.r2dbc</groupId><artifactId>r2dbc-pool</artifactId>
</dependency>
🧠 小贴士
-
ConnectionFactoryOptions.parse() 用于解析字符串并构建连接选项，可组合 .mutate() 来动态设置用户名和密码。
-
推荐使用 r2dbc:pool:postgresql，避免创建太多连接。
-
如果你需要统一管理多个 R2dbcEntityTemplate，可封装一个工具类或注入 Map<String, R2dbcEntityTemplate>