我有一个带有两个冗余 MongoS 路由器主机的 MongoDB。使用 org.springframework.data.mongo 创建 MongoTemplate 和 MongoClient 时，我只能添加一个主机。如果正在使用的主机发生故障，则不会故障转移到备用路由器主机。

我最初引用了 https://dzone.com/articles/multiple-mongodb-connectors-with-spring-boot ，但这里的用例是针对两个完全不同的存储库，而我的情况是具有双路由器的单个数据库。

在下面的代码中，我们想添加一个冗余的第二个主机，以防第一台主机在运行时出现故障。

public class MongoConfiguration extends AbstractMongoConfiguration {

    @Value("${mongo.database}")
    private String databaseName;

    @Value("${mongo.host}")
    private String host;

    @Value("${mongo.readFromSecondary}")
    private String readFromSecondary;

    @Value("${mongo.port}")
    private int port;

    @VaultKey("vault.mongo_username")
    private String username;

    @VaultKey("vault.mongo_password")
    private String password;

    @Override
    protected String getDatabaseName() {
        return databaseName;
    }

    @Override
    @Primary
    public MongoClient mongoClient() {
        final ServerAddress serverAddress = new ServerAddress(host, port);
        final MongoCredential credential = MongoCredential.createCredential(username, 
            getDatabaseName(), password.toCharArray());
        return new MongoClient(serverAddress, credential,
            MongoClientOptions.builder().build());
    }

    @Override
    @Primary
    @Bean(name = "mongoTemplate")
    public MongoTemplate mongoTemplate() throws Exception {
        final MongoTemplate template = super.mongoTemplate();
        if (this.readFromSecondary != null && Boolean.valueOf(this.readFromSecondary)) {
            template.setReadPreference(ReadPreference.secondary());
        }

        return template;
    }
}

目前在启动时，将加载到配置文件中主机的连接而不会出现错误，我们希望在备份主机中轮换。

最佳答案

您可以通过两种方式实现:

<强>1。多个 Mongo 客户端或多个服务器地址(主机):

具有内部连接池的 MongoDB 客户端。对于大多数应用程序，整个 JVM 应该有一个 MongoClient 实例。

以下是等价的，都是连接到默认端口上运行的本地数据库:

MongoClient mongoClient1 = new MongoClient();
MongoClient mongoClient1 = new MongoClient("localhost");
MongoClient mongoClient2 = new MongoClient("localhost", 27017);
MongoClient mongoClient4 = new MongoClient(new ServerAddress("localhost"));
MongoClient mongoClient5 = new MongoClient(new ServerAddress("localhost"), 
    new MongoClientOptions.Builder().build());

您可以通过将 ServerAddress 列表传递给 MongoClient 构造函数来使用 Java 驱动程序连接到副本集。例如:

MongoClient mongoClient = new MongoClient(Arrays.asList(
   new ServerAddress("localhost", 27017),
   new ServerAddress("localhost", 27018),
   new ServerAddress("localhost", 27019)));

您可以使用相同的构造函数连接到分片集群。 MongoClient 将自动检测服务器是副本集成员列表还是 mongos 服务器列表。

默认情况下，所有读写操作都在主节点上进行，但可以通过更改读取首选项从辅助节点读取:

mongoClient.setReadPreference(ReadPreference.secondaryPreferred());

默认情况下，所有写操作都将等待服务器确认，因为默认写关注是WriteConcern.ACKNOWLEDGED

<强>2。使用多个 Mongo 连接器和多个 Mongo 模板:

首先创建以下@ConfigurationProperties 类。

@ConfigurationProperties(prefix = "mongodb")
public class MultipleMongoProperties {
    private MongoProperties primary = new MongoProperties();
    private MongoProperties secondary = new MongoProperties();
}

然后在application.yml

mongodb:
  primary:
    host: localhost
    port: 27017
    database: second
  secondary:
    host: localhost
    port: 27017
    database: second

现在有必要创建 MongoTemplates 来绑定(bind)上一步中给定的配置。

@EnableConfigurationProperties(MultipleMongoProperties.class)
public class MultipleMongoConfig {

    private final MultipleMongoProperties mongoProperties;

    @Primary
    @Bean(name = "primaryMongoTemplate")
    public MongoTemplate primaryMongoTemplate() throws Exception {
        return new MongoTemplate(primaryFactory(this.mongoProperties.getPrimary()));
    }

    @Bean(name = "secondaryMongoTemplate")
    public MongoTemplate secondaryMongoTemplate() throws Exception {
        return new MongoTemplate(secondaryFactory(this.mongoProperties.getSecondary()));
    }

    @Bean
    @Primary
    public MongoDbFactory primaryFactory(final MongoProperties mongo) throws Exception {
        return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
                mongo.getDatabase());
    }

    @Bean
    public MongoDbFactory secondaryFactory(final MongoProperties mongo) throws Exception {
        return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
                mongo.getDatabase());
    }

}

通过上述配置，您将能够根据我们之前在本指南中提供的自定义配置属性拥有两个不同的 MongoTemplate。

在上一步中我们创建了两个 MongoTemplate，primaryMongoTemplate 和 secondaryMongoTemplate

更多详情:https://blog.marcosbarbero.com/multiple-mongodb-connectors-in-spring-boot/

关于java - 如何设置冗余 MongoDB 模板？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/57212148/