Spring Boot MongoDB自定义连接池配置

手打不易，如果转摘，请注明出处！

注明原文：http://zhangxiaofan.blog.csdn.net/article/details/144341407

一、引言

在 Spring Boot 应用中使用 MongoDB 时，合理配置连接池可以显著提升数据库访问的性能和稳定性。默认情况下，Spring Data MongoDB 会使用 MongoDB Java 驱动的默认连接池配置，但在生产环境中，我们通常需要根据业务需求自定义参数（如最大连接数、超时时间等）。本文将详细介绍如何在 Spring Boot 中自定义 MongoDB 连接池，适合新手快速上手。

二、环境准备

技术版本

Spring Boot 2.x.x
MongoDB 3.x（Spring Data MongoDB 自动依赖）
MongoDB 服务（本地或远程，版本 >= 4.0）

依赖配置

在 pom.xml 中添加 MongoDB 依赖（Spring Boot 起步依赖会自动包含驱动）：

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

三、核心参数

1. 连接池大小参数

参数名	作用	推荐值（生产环境）
`maxConnectionPoolSize`	单个主机的最大连接数，超过时请求排队	根据业务并发量调整，一般 `50-200`
`minConnectionPoolSize`	保持的最小空闲连接数，减少新建连接开销	`5-20`（视访问频率）

2. 超时参数

参数名	作用	推荐值
`connectTimeoutMS`	建立连接的超时时间	`10-30 秒`
`socketTimeoutMS`	读写数据的超时时间（0 表示不超时）	`30-60 秒`
`serverSelectionTimeoutMS`	选择可用服务器的超时（如副本集切换）	`5-15 秒`

四、配置连接池

1.properties配置

# application.yml示例  
spring:  data:  mongodb:  uri: mongodb://username:password@localhost:27017/databaseName  # 连接池参数  connection-timeout: 5000  # 连接超时时间（毫秒）  max-wait-time: 1000       # 等待连接的最大时间（毫秒）  max-inactive: 60000       # 连接空闲超时时间（毫秒）  max-size: 50              # 最大连接数  min-size: 10              # 最小连接数  threads-allowed-to-block-multiplier: 5  # 允许阻塞的线程数乘数

2.连接串配置

spring.data.mongodb.uri=mongodb://user:password@host:port/database?maxPoolSize=50&minPoolSize=5&connectTimeoutMS=15000&socketTimeoutMS=30000&serverSelectionTimeoutMS=20000

3.Java代码配置

import com.mongodb.ConnectionString;  
import com.mongodb.MongoClientSettings;  
import com.mongodb.client.MongoClient;  
import com.mongodb.client.MongoClients;  
import org.springframework.context.annotation.Bean;  
import org.springframework.context.annotation.Configuration;  
import org.springframework.data.mongodb.config.AbstractMongoClientConfiguration;  @Configuration  
public class MongoConfig extends AbstractMongoClientConfiguration {  private final String databaseName = "your_database";  private final String connectionUri = "mongodb://host:port";  @Override  protected String getDatabaseName() {  return databaseName;  }  @Override  @Bean  public MongoClient mongoClient() {  // 解析连接字符串  ConnectionString connectionString = new ConnectionString(connectionUri);  // 构建连接池配置  MongoClientSettings settings = MongoClientSettings.builder()  .applyConnectionString(connectionString)  // 自定义连接池参数  .maxConnectionPoolSize(50)          // 最大连接数  .minConnectionPoolSize(5)           // 最小空闲连接数  .connectTimeout(Duration.ofMillis(15000))  // 连接超时  .socketTimeout(Duration.ofMillis(30000))   // 套接字超时  .serverSelectionTimeout(Duration.ofMillis(20000)) // 服务器选择超时  // 其他配置：SSL、认证、负载均衡策略等  .sslEnabled(false)                   // 是否启用 SSL  .build();  return MongoClients.create(settings);  }  
}