使用R2DBC时，能否通过CrudRepository调用两个不同数据库客户端？

这个需求完全可行，Spring官方支持R2DBC多数据源搭配ReactiveCrudRepository实现响应式数据库操作，报错通常是多数据源的配置逻辑缺失或混淆导致的。以下是落地的最优实现步骤：

1. 多数据源属性配置 #

在application.yml中明确区分两个R2DBC数据源的连接信息：

spring:
  r2dbc:
    db1:
      url: r2dbc:mysql://localhost:3306/db1
      username: root
      password: your_db1_pwd
    db2:
      url: r2dbc:postgresql://localhost:5432/db2
      username: postgres
      password: your_db2_pwd

2. 分数据源配置类 #

为每个数据源单独创建配置类，通过@EnableR2dbcRepositories绑定对应的Repository包和实体操作模板：

数据源1配置类 #

@Configuration
@EnableR2dbcRepositories(
    basePackages = "com.yourpackage.repository.db1", // 指定该数据源对应的Repository包
    entityOperationsRef = "db1R2dbcEntityTemplate" // 关联专属的实体操作模板
)
public class Db1R2dbcConfig {

    @Bean
    @ConfigurationProperties("spring.r2dbc.db1")
    public ConnectionFactoryOptions db1ConnOptions() {
        return ConnectionFactoryOptions.builder().build();
    }

    @Bean
    public ConnectionFactory db1ConnectionFactory() {
        return ConnectionFactories.get(db1ConnOptions());
    }

    @Bean("db1R2dbcEntityTemplate")
    public R2dbcEntityTemplate db1EntityTemplate() {
        return new R2dbcEntityTemplate(db1ConnectionFactory());
    }
}

数据源2配置类 #

@Configuration
@EnableR2dbcRepositories(
    basePackages = "com.yourpackage.repository.db2",
    entityOperationsRef = "db2R2dbcEntityTemplate"
)
public class Db2R2dbcConfig {

    @Bean
    @ConfigurationProperties("spring.r2dbc.db2")
    public ConnectionFactoryOptions db2ConnOptions() {
        return ConnectionFactoryOptions.builder().build();
    }

    @Bean
    public ConnectionFactory db2ConnectionFactory() {
        return ConnectionFactories.get(db2ConnOptions());
    }

    @Bean("db2R2dbcEntityTemplate")
    public R2dbcEntityTemplate db2EntityTemplate() {
        return new R2dbcEntityTemplate(db2ConnectionFactory());
    }
}

3. 分离Repository与实体类 #

将不同数据源对应的Repository和实体类放在独立的包下，避免Spring扫描混淆：

• 数据源1的Repository放在com.yourpackage.repository.db1，实体类放在com.yourpackage.entity.db1
• 数据源2的Repository放在com.yourpackage.repository.db2，实体类放在com.yourpackage.entity.db2

示例Repository：

// 属于db1的Repository
package com.yourpackage.repository.db1;

import com.yourpackage.entity.db1.Db1User;
import org.springframework.data.r2dbc.repository.ReactiveCrudRepository;

public interface Db1UserRepository extends ReactiveCrudRepository<Db1User, Long> {
}

示例实体类：

// 属于db1的实体类
package com.yourpackage.entity.db1;

import org.springframework.data.annotation.Id;
import org.springframework.data.relational.core.mapping.Table;

@Table("user") // 对应db1中的user表
public class Db1User {
    @Id
    private Long id;
    private String username;
    // 省略getter、setter
}

常见报错排查点 #

• 未通过@EnableR2dbcRepositories指定basePackages，导致Spring无法区分Repository归属的数据源
• 两个数据源的ConnectionFactory或R2dbcEntityTemplateBean名称重复，需通过自定义Bean名称（如db1ConnectionFactory）区分
• 实体类与Repository的包未分离，导致扫描时混淆数据源上下文

内容的提问来源于stack exchange，提问作者alt-ctrl-dev