Spring Boot和mongo db中的连接池

Question

我正在进行Spring Boot应用程序和MongoDB连接的POC（Proof of Concept，概念验证）。我已经添加了以下依赖项：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

我已经查看了带有属性的mongoB属性：https://docs.spring.io/spring-boot/docs/current/reference/html/common-application-properties.html

请问在这里我们如何定义连接池机制？

- Jagrut Dalwadi

Answer 1

您无法通过应用程序属性来直接完成此操作。您需要使用MongoClientOptions来配置连接池的各个方面。

请查看文档以获取可用选项的各种选项。

这是一个简单的示例。

@Bean(name="mongoTempl")
public MongoTemplate mongoTempl() throws Exception {
     return new MongoTemplate(createMongoClient(new ServerAddress(host, port))
                              ,dbName);
}


Mongo createMongoClient(ServerAddress serverAddress) {
final MongoClientOptions options = MongoClientOptions.builder()
        .threadsAllowedToBlockForConnectionMultiplier(...)
        .connectionsPerHost(...)
        .connectTimeout(...)
        .maxWaitTime(...)
        .socketKeepAlive(...)
        .socketTimeout(...)
        .heartbeatConnectTimeout(...)
        .minHeartbeatFrequency(...)
        .build();

        return new MongoClient(serverAddress, options);
}

- pvpkiran

---

在最新版本中无法找到MongoClientOptions，是否有任何替代方案？ - Rookie007

通过快速查看，我可以看到MongoClientSettings是你应该使用的。 - pvpkiran

Answer 2

您也可以使用MongoClientSettingsBuilderCustomizer，就像在此Spring 示例中一样。

@Bean
public MongoClientSettingsBuilderCustomizer customizer() {
    return (builder) -> builder.applyToConnectionPoolSettings(
            (connectionPool) -> {
                connectionPool.maxSize(10);
                connectionPool.minSize(2);
                connectionPool.maxConnectionIdleTime(5, TimeUnit.MINUTES);
                connectionPool.maxWaitTime(2, TimeUnit.MINUTES);
                connectionPool.maxConnectionLifeTime(30, TimeUnit.MINUTES);
                connectionPool.addConnectionPoolListener();
            });
}

- Isko