Java 實現 MongoDB 連接池管理最佳實踐

MongoDB Java 驅動內建連接池，合理配置對性能至關重要。本文涵蓋連接池核心參數、配置模板、監控指標、常見問題與最佳實踐，基於 MongoDB Java Driver 4.x (Sync API)。

核心配置參數

完整配置代碼

import com.mongodb.ConnectionString;
import com.mongodb.MongoClientSettings;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import org.bson.codecs.configuration.CodecRegistry;
import org.bson.codecs.pojo.PojoCodecProvider;
import static org.bson.codecs.configuration.CodecRegistries.*;

public class MongoPoolConfig {
    public static MongoClient createClient(String uri) {
        CodecRegistry pojoRegistry = fromRegistries(
            MongoClientSettings.getDefaultCodecRegistry(),
            fromProviders(PojoCodecProvider.builder().automatic(true).build())
        );

        MongoClientSettings settings = MongoClientSettings.builder()
            .applyConnectionString(new ConnectionString(uri))
            .codecRegistry(pojoRegistry)
            .applyToConnectionPoolSettings(builder -> builder
                .maxSize(200)
                .minSize(20)
                .maxWaitTime(5, TimeUnit.SECONDS)
                .maxConnectionLifeTime(30, TimeUnit.MINUTES)
                .maxConnectionIdleTime(5, TimeUnit.MINUTES)
                .maintenanceFrequency(1, TimeUnit.MINUTES)
                .maintenanceInitialDelay(1, TimeUnit.MINUTES)
            )
            .applyToSocketSettings(builder -> builder
                .connectTimeout(5, TimeUnit.SECONDS)
                .readTimeout(30, TimeUnit.SECONDS)
            )
            .applyToClusterSettings(builder -> builder
                .serverSelectionTimeout(10, TimeUnit.SECONDS)
                .mode(ClusterSettings.Mode.MULTIPLE) // 副本集
            )
            .retryWrites(true)
            .retryReads(true)
            .build();

        return MongoClients.create(settings);
    }
}

Spring Boot 整合配置

# application.yml
spring:
  data:
    mongodb:
      uri: mongodb://user:pass@host1:27017,host2:27017/db?replicaSet=rs0
      auto-index-creation: true
  mongodb:
    client-settings:
      connections-per-host: 200
      min-connections-per-host: 20
      max-wait-time: 5000
      connect-timeout: 5000
      socket-timeout: 30000
      server-selection-timeout: 10000

關鍵監控指標

• 連接池使用率：currentInUse / maxPoolSize，持續 > 80% 需擴容或優化查詢。
• 等待佇列長度：waitQueueSize，非零說明連接不足。
• 連接創建/關閉頻率：頻繁波動說明 minPoolSize 過小或 maxIdleTime 過短。
• 慢查詢佔用連接：結合 socketTimeout 與 Profiler 定位。

可通過 MongoClient.getCluster().getDescription() 或 Micrometer/Prometheus 導出監控。

常見問題與對策

最佳實踐清單

1. 單例 MongoClient：全應用共享一個實例，JVM 關閉時調用 close()。
2. 合理設置超時：連接/讀/寫/選主超時分離配置，避免無限等待。
3. 啟用重試：retryWrites=true、retryReads=true (4.2+)，提升可用性。
4. 使用 PojoCodec：自動映射 Java Bean，減少手動 Document 構建。
5. 監控告警：接入 Prometheus + Grafana，關鍵指標設置閾值告警。
6. 定期滾動升級驅動：修復 Bug、性能優化、新功能支援。

1. 上一篇文章： Java 圖片添加水印完整實戰：文字水印、圖片水印、旋轉、透明度與批量處理
2. 下一篇文章： Java Web 開發中 HttpServletRequest 核心方法詳解與實戰範例

Java 相關知識

解決 XFire 發布 WebService 時 Spring 注入失效問題

問題現象 使用 XFire 發布 WebService，Se

IBM Java 診斷系列（三）：Lock Analyzer 即時鎖監控與同步效能優化

鎖爭用對效能的衝擊 多執行緒共享資源需同步存取，Java 提

J2EE 表現層設計關鍵決策與最佳實踐

核心設計議題 表現層設計需權衡安全、數據完整性、可管理性、擴

Hibernate 進階（四）：基本映射（Basic Mapping）從入門到實戰

什麼是 ORM 映射？ 對象關系映射（ORM）核心目標：將對