SpringBoot 集成多 MongoDB 实例的配置实践

从数据源配置

第二个实例的配置逻辑类似，只是去掉了 @Primary 注解，并使用了不同的 Bean 名称以便业务代码按需调用。

public class TwoMongoConfig {
    private MongoClient mongo;

    @Bean
    public MongoTemplate twoMongoTemplate(@Autowired @Qualifier("twoMongoDbFactory") MongoDbFactory mongoDbFactory, MongoConverter converter) {
        return new MongoTemplate(mongoDbFactory, converter);
    }

    @Bean
    public MongoDbFactory twoMongoDbFactory(@Autowired @Qualifier("twoMongoProperties") MongoProperties properties, Environment environment, ObjectProvider<MongoClientOptions> options) {
        MongoClientOptions _options = options.getIfAvailable();
        MongoClientFactory mongoClientFactory = new MongoClientFactory(properties, environment);
        this.mongo = mongoClientFactory.createMongoClient(_options);
        return new SimpleMongoDbFactory(this.mongo, properties.getMongoClientDatabase());
    }

    @PreDestroy
    public void close() {
        if (this.mongo != null) {
            this.mongo.close();
        }
    }

    @Bean
    @ConfigurationProperties(prefix = "sys.mongodb.two")
    public MongoProperties twoMongoProperties() {
        return new MongoProperties();
    }
}

整合与启动类

最后，将上述配置导入到总配置类中，并在启动类里排除默认的 MongoDB 自动配置，防止冲突。

@Configuration
@Import({OneMongoConfig.class, TwoMongoConfig.class})
public class MongoConfig {
}

@SpringBootApplication(exclude = {MongoAutoConfiguration.class})
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

这样配置后，你可以通过注入 mongoTemplate 获取主库，或通过 twoMongoTemplate 获取从库，实现多数据源的灵活切换。