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>