为什么需要连接池？

在深入代码之前,理解为什么需要连接池至关重要。

1. 性能提升：建立数据库连接是一个相对耗时的操作，涉及网络通信和身份验证，连接池通过预先创建并维护一组可重用的连接，避免了每次请求都创建新连接的开销，极大地提高了响应速度。
2. 资源控制：连接池限制了应用程序可以同时打开的最大连接数，这可以防止因为连接数过多而耗尽数据库服务器的资源（如内存、文件描述符），导致整个数据库甚至服务器崩溃。
3. 高可用性：现代的连接池（如 HikariCP、MongoDB 官方的 MongoClient 内部实现）通常具备连接健康检查和自动重连机制，当某个连接失效时，连接池能检测到并创建一个新的可用连接，保证了应用程序的健壮性。

MongoDB Java 驱动中的连接池

从 MongoDB 3.x 版本开始，Java 驱动（mongodb-driver-sync）在 MongoClient 内部已经集成了一个高性能的连接池，你不需要额外引入第三方连接池库（如 HikariCP），你只需要正确配置 MongoClient 即可。

核心类：com.mongodb.MongoClientSettings 和 com.mongodb.client.MongoClient

连接池核心配置参数

在 MongoClientSettings.Builder 中，你可以配置以下与连接池相关的关键参数：

实战代码示例

下面是一个完整的、可运行的 Java 示例，展示如何配置并使用带有自定义连接池设置的 MongoClient。

Maven 依赖

确保你的 pom.xml 文件中包含了 MongoDB Java 驱动依赖。

<dependencies>
    <!-- MongoDB Java Driver (同步版本) -->
    <dependency>
        <groupId>org.mongodb</groupId>
        <artifactId>mongodb-driver-sync</artifactId>
        <version>4.11.1</version> <!-- 建议使用最新稳定版 -->
    </dependency>
    <!-- 如果需要日志，可以添加 SLF4J 和 Logback -->
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-api</artifactId>
        <version>1.7.36</version>
    </dependency>
    <dependency>
        <groupId>ch.qos.logback</groupId>
        <artifactId>logback-classic</artifactId>
        <version>1.2.12</version>
    </dependency>
</dependencies>

Java 代码

import com.mongodb.MongoClientSettings;
import com.mongodb.MongoClientSettings.Builder;
import com.mongodb.MongoException;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import org.bson.conversions.Bson;
import java.util.Arrays;
import java.util.concurrent.TimeUnit;
public class MongoConnectionPoolExample {
    public static void main(String[] args) {
        // 1. 配置连接池设置
        ConnectionPoolSettings connectionPoolSettings = ConnectionPoolSettings.builder()
                // 最大连接数
                .maxSize(100)
                // 最小连接数 (连接池预热)
                .minSize(10)
                // 获取连接的最大等待时间
                .maxWaitTime(15000, TimeUnit.MILLISECONDS)
                // 等待队列大小
                .maxWaitQueueSize(200)
                // 连接的最大生命周期 ( 1小时)
                .maxConnectionLifeTime(3600, TimeUnit.SECONDS)
                // 连接的最大空闲时间 ( 30分钟)
                .maxConnectionIdleTime(1800, TimeUnit.SECONDS)
                // 构建器
                .build();
        // 2. 配置 MongoClientSettings
        // 在实际应用中，连接字符串应该从配置文件或环境变量中读取
        String connectionString = "mongodb://localhost:27017";
        MongoClientSettings mongoClientSettings = MongoClientSettings.builder()
                .applyConnectionString(new ConnectionString(connectionString))
                // 应用连接池设置
                .applyToConnectionPoolSettings(builder -> builder.applySettings(connectionPoolSettings))
                // 其他设置，如读写偏好、SSL等
                .applyToClusterSettings(builder -> builder.hosts(Arrays.asList(new ServerAddress("localhost", 27017))))
                .build();
        // 3. 创建 MongoClient
        // MongoClient 是线程安全的，通常在应用启动时创建一次，然后全局共享
        try (MongoClient mongoClient = MongoClients.create(mongoClientSettings)) {
            System.out.println("成功创建 MongoClient 并连接到 MongoDB");
            // 4. 获取数据库和集合
            MongoDatabase database = mongoClient.getDatabase("testdb");
            MongoCollection<Document> collection = database.getCollection("users");
            // 5. 执行一个简单的操作 (CRUD)
            // 插入一个文档
            Document doc = new Document("name", "张三")
                    .append("age", 30)
                    .append("city", "北京");
            collection.insertOne(doc);
            System.out.println("插入文档成功: " + doc.toJson());
            // 查询文档
            Bson filter = new Document("name", "张三");
            Document foundDoc = collection.find(filter).first();
            if (foundDoc != null) {
                System.out.println("查找到文档: " + foundDoc.toJson());
            } else {
                System.out.println("未找到文档");
            }
            // 更新文档
            Bson updateOperation = new Document("$set", new Document("age", 31));
            collection.updateOne(filter, updateOperation);
            System.out.println("更新文档成功");
            // 删除文档
            collection.deleteOne(filter);
            System.out.println("删除文档成功");
        } catch (MongoException e) {
            System.err.println("MongoDB 操作出错: " + e.getMessage());
            e.printStackTrace();
        }
        // MongoClient 实现了 AutoCloseable，在 try-with-resources 语句块结束时，它会自动关闭所有连接并清理资源。
        // 这在应用关闭时非常重要。
        System.out.println("MongoClient 已关闭，连接已释放回连接池或被销毁。");
    }
}

最佳实践

1. 单例模式：MongoClient 实例是线程安全的，并且内部管理着连接池，在你的整个应用程序生命周期中，只应该创建一个 MongoClient 实例，并在所有需要访问数据库的地方共享它，不要为每个请求或每个线程都创建一个新的 MongoClient。

2. 配置外部化：不要将连接字符串和连接池参数硬编码在代码中，应该使用配置文件（如 application.properties 或 application.yml）或环境变量来管理它们，以便在不同环境（开发、测试、生产）之间轻松切换。

   示例 (使用 application.properties):

   
   （图片来源网络，侵删）

   # application.properties
   mongodb.uri=mongodb://user:password@localhost:27017/?authSource=admin
   mongodb.pool.maxSize=50
   mongodb.pool.minSize=5

   然后在 Java 代码中读取这些属性。

3. 合理设置连接池大小：

   • maxSize 的设置需要综合考虑你的应用并发数、MongoDB 服务器的资源（连接数限制）以及每个连接的负载，一个经验法则是 maxSize 可以设置为应用中最高并发线程数的 1.5 到 2 倍，但不要超过 MongoDB 服务器配置的 maxIncomingConnections。
   • minSize 设置为 0 是可以的，但如果你的应用对启动后首次请求的延迟敏感，可以设置一个较小的值（如 5-10）来预热连接池。

4. 处理 MongoTimeoutException：当应用请求连接的速度超过了连接池能够提供连接的速度，并且超过了 maxWaitTime，就会抛出 MongoTimeoutException，这通常意味着连接池配置过小或应用负载过高，你应该捕获这个异常，并实现重试机制或向用户返回一个友好的错误提示，而不是直接让应用崩溃。

5. 总是关闭 MongoClient：如果你的应用是运行在 Servlet 容器（如 Tomcat）或 Spring Boot 等框架中，框架通常会为你管理 MongoClient 的生命周期，但在独立应用中，务必使用 try-with-resources 或在应用关闭的钩子中调用 mongoClient.close()，以确保所有资源被正确释放。

Spring Boot 集成

如果你使用的是 Spring Boot，配置会变得更加简单，你只需要在 application.properties 或 application.yml 中配置即可，Spring Boot 会自动为你创建并配置好 MongoClient。

application.properties 示例:

# MongoDB 主机地址和端口
spring.data.mongodb.uri=mongodb://localhost:27017/testdb
# 连接池配置
spring.data.mongodb.client.min-connection-per-host=10
spring.data.mongodb.client.max-connection-per-host=100
spring.data.mongodb.client.connection-timeout=3000
spring.data.mongodb.client.socket-timeout=3000

Spring Boot 会自动将这些属性映射到 MongoClientSettings 中，无需你编写任何 Java 配置代码，这是最推荐的方式。