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>