Spring Batch跨Couchbase集群数据复制的多仓库配置难题

API 探路者

2026-7-8

问题

我正尝试基于Spring Data Couchbase构建Spring Batch任务，实现将数据从一个Couchbase集群复制到另一个集群，但始终无法配置出对应两个不同集群的独立仓库。

网上大多是基于OperationsMapping实现同一集群多Bucket的示例，而我的数据模型完全相同，这类方案不适用。
测试时发现，用目标仓库（对应空Bucket）查询源仓库中的文档是否存在，返回结果为true，说明实际查询的是源仓库。
我已经尝试为CouchbaseTemplate、CouchbaseClientFactory、CouchbaseClusterEnvironment和CouchbaseCluster声明自定义命名Bean，但问题仍未解决。

以下是其中一个配置类示例（另一个配置类仅将所有source替换为target）：

@Configuration
@EnableCouchbaseRepositories(repositoryBaseClass = SourceDocumentRepository.class, couchbaseTemplateRef = "sourceCouchbaseTemplate")
public class SourceCouchbaseConfiguration extends AbstractCouchbaseConfiguration {

  ... 已重写getter方法：connectionString、user、pwd、bucket、scope

  @Bean(name = "sourceCouchbaseCluster", destroyMethod = "disconnect")
  public Cluster sourceCouchbaseCluster(ClusterEnvironment sourceCouchbaseClusterEnvironment) {
    return Cluster.connect(getConnectionString(), ClusterOptions.clusterOptions(authenticator()).environment(sourceCouchbaseClusterEnvironment));
  }

  @Bean(name = "sourceCouchbaseClusterEnvironment", destroyMethod = "shutdown")
  public ClusterEnvironment sourceCouchbaseClusterEnvironment() {
    ClusterEnvironment.Builder builder = ClusterEnvironment.builder();
    builder.jsonSerializer(JacksonJsonSerializer.create(couchbaseObjectMapper()));
    configureEnvironment(builder);
    return builder.build();
  }
  
  @Bean("sourceCouchbaseClientFactory")
  public CouchbaseClientFactory sourceCouchbaseClientFactory() {
    return new SimpleCouchbaseClientFactory(getConnectionString(), authenticator(), getBucketName(), getScopeName());
  }

  @Bean("sourceCouchbaseTemplate")
  public CouchbaseTemplate sourceCouchbaseTemplate() {
    return new CouchbaseTemplate(sourceCouchbaseClientFactory(), new MappingCouchbaseConverter());
  }

  @Bean("sourceReactiveCouchbaseTemplate")
  public ReactiveCouchbaseTemplate sourceReactiveCouchbaseTemplate() {
    return new ReactiveCouchbaseTemplate(sourceCouchbaseClientFactory(), new MappingCouchbaseConverter());
  }
  
  @Bean("sourceCouchbaseRepositoryOperationsMapping")
  public RepositoryOperationsMapping sourceCouchbaseRepositoryOperationsMapping(CouchbaseTemplate sourceCouchbaseTemplate) {
    return new RepositoryOperationsMapping(sourceCouchbaseTemplate);
  }
}

解决方案

要解决两个Couchbase集群的独立仓库配置问题，核心是确保两个配置类的仓库扫描范围完全隔离，并且所有关联Bean的依赖注入正确绑定到对应集群的实例上，具体调整如下：

隔离仓库扫描范围
在@EnableCouchbaseRepositories注解中添加basePackages属性，分别指定源仓库和目标仓库所在的不同包路径。比如源仓库放在com.example.repo.source，目标仓库放在com.example.repo.target，这样Spring会为不同包下的仓库绑定对应的模板：
- 源配置类：@EnableCouchbaseRepositories(basePackages = "com.example.repo.source", couchbaseTemplateRef = "sourceCouchbaseTemplate")
- 目标配置类：@EnableCouchbaseRepositories(basePackages = "com.example.repo.target", couchbaseTemplateRef = "targetCouchbaseTemplate")

避免继承AbstractCouchbaseConfiguration的冲突
AbstractCouchbaseConfiguration会自动注册一些无名称的默认Bean（比如Cluster、ClusterEnvironment），这些默认Bean可能会被两个配置类重复创建，导致依赖注入混乱。建议不要继承该抽象类，手动配置所有必要的Bean：

// 源配置类示例，目标配置类同理替换前缀
@Configuration
@EnableCouchbaseRepositories(basePackages = "com.example.repo.source", couchbaseTemplateRef = "sourceCouchbaseTemplate")
public class SourceCouchbaseConfiguration {

    @Value("${source.couchbase.connection-string}")
    private String connectionString;
    @Value("${source.couchbase.username}")
    private String username;
    @Value("${source.couchbase.password}")
    private String password;
    @Value("${source.couchbase.bucket}")
    private String bucketName;
    @Value("${source.couchbase.scope}")
    private String scopeName;

    @Bean(name = "sourceCouchbaseClusterEnvironment")
    public ClusterEnvironment sourceClusterEnvironment() {
        return ClusterEnvironment.builder()
                .jsonSerializer(JacksonJsonSerializer.create(couchbaseObjectMapper()))
                .build();
    }

    @Bean(name = "sourceCouchbaseCluster")
    public Cluster sourceCluster(@Qualifier("sourceCouchbaseClusterEnvironment") ClusterEnvironment env) {
        return Cluster.connect(connectionString,
                ClusterOptions.clusterOptions(username, password)
                        .environment(env));
    }

    @Bean(name = "sourceCouchbaseClientFactory")
    public CouchbaseClientFactory sourceClientFactory(@Qualifier("sourceCouchbaseCluster") Cluster cluster) {
        return new SimpleCouchbaseClientFactory(cluster, bucketName, scopeName);
    }

    @Bean(name = "sourceCouchbaseTemplate")
    public CouchbaseTemplate sourceTemplate(@Qualifier("sourceCouchbaseClientFactory") CouchbaseClientFactory factory) {
        MappingCouchbaseConverter converter = new MappingCouchbaseConverter();
        converter.setApplicationContext(new AnnotationConfigApplicationContext());
        return new CouchbaseTemplate(factory, converter);
    }
}

明确依赖注入的Bean名称
在注入相关Bean时，必须使用@Qualifier注解指定对应的Bean名称，避免Spring自动注入错误的实例。比如在仓库实现类或者Spring Batch的Step中注入仓库时：
```
@Autowired
@Qualifier("sourceDocumentRepository")
private SourceDocumentRepository sourceRepo;

@Autowired
@Qualifier("targetDocumentRepository")
private TargetDocumentRepository targetRepo;
```
验证仓库绑定关系
可以在配置类中添加日志，打印模板对应的集群连接信息，或者在测试中直接打印仓库关联的CouchbaseTemplate的Bucket名称，确认是否绑定到了正确的集群。

内容的提问来源于stack exchange，提问作者CEDDM