MongoDB连接检出耗时2秒的根因及修复方案咨询

从你给出的日志（ConnectionCheckOutStarted与ConnectionCheckedOut间隔2秒）来看，延迟主要出现在获取MongoDB连接的阶段，而非数据库操作本身。结合AWS EKS + Mongo Atlas的环境，常见根因有以下几类：

1. DNS解析延迟 #

Mongo Atlas的域名需要解析到其集群节点IP，若EKS集群的默认CoreDNS解析速度慢，或解析结果未缓存，每次新建连接都会触发耗时的DNS查询，直接导致连接checkout延迟。

2. 连接池配置不合理 #

• 连接池MaxPoolSize设置过小，并发请求超过可用连接数时，需要等待新建连接，而新建连接的DNS+TLS握手流程耗时较长。
• MaxIdleTime设置过短，连接频繁被销毁重建，每次重建都要重复握手流程，累积延迟。

3. TLS握手耗时过长 #

Mongo Atlas强制要求TLS连接，若存在以下情况会导致握手延迟：

• Go应用未启用TLS1.3等现代协议，握手协商过程慢。
• 每次连接都需要下载验证CA证书，未预加载证书导致额外网络请求。
• EKS与Atlas之间的网络路径存在防火墙/代理做深度包检测，干扰TLS协商。

4. AWS网络配置问题 #

• EKS与Mongo Atlas未配置VPC peering，流量走公网跨区域传输，延迟高。
• 安全组/网络ACL规则限制，导致连接建立过程中出现丢包或超时重试。

一、优化DNS解析 #

1. 缓存Atlas域名解析结果：
   在EKS的CoreDNS中添加自定义Hosts记录，将Atlas域名映射到其节点IP（可通过nslookup获取），避免重复解析。或者在Mongo客户端中自定义Dialer，使用带缓存的DNS解析：

   dialer := &net.Dialer{
       Timeout:   5 * time.Second,
       KeepAlive: 30 * time.Second,
       Resolver: &net.Resolver{
           PreferGo: true,
           // 使用AWS内部DNS或高性能公共DNS
           Dial: func(ctx context.Context, network, address string) (net.Conn, error) {
               return (&net.Dialer{Timeout: 2 * time.Second}).DialContext(ctx, "udp", "169.254.169.253:53")
           },
       },
   }
   clientOpts.SetDialContext(dialer.DialContext)
   

2. 验证DNS解析速度：
   在EKS节点上执行dig mongodb-atlas-uri，查看Query time是否超过100ms，若超过则说明DNS是瓶颈。

二、调整连接池参数 #

修改Mongo客户端的连接池配置，避免频繁新建连接：

clientOpts := options.Client().ApplyURI(mongoURI)
// 根据并发量设置合适的连接池大小，建议20-50（依业务负载调整）
clientOpts.SetMaxPoolSize(30)
// 延长空闲连接存活时间，避免频繁销毁重建
clientOpts.SetMaxIdleTime(30 * time.Minute)
// 设置连接超时，避免无限等待
clientOpts.SetConnectTimeout(5 * time.Second)
clientOpts.SetSocketTimeout(10 * time.Second)

排查连接池状态：
在代码中定期打印连接池统计信息，确认是否存在等待连接的情况：

stats := client.PoolStats()
fmt.Printf("WaitQueueSize: %d, TotalConnections: %d, IdleConnections: %d\n", 
    stats.WaitQueueSize, stats.TotalConnections, stats.IdleConnections)

如果WaitQueueSize持续大于0，说明MaxPoolSize设置过小，需要增大。

三、优化TLS配置 #

1. 强制使用TLS1.3：
   Go 1.21支持TLS1.3，启用后可大幅减少握手时间：

   tlsConfig := &tls.Config{
       MinVersion: tls.VersionTLS13,
       // 预加载Atlas的CA证书，避免每次连接都下载
       // 可从Mongo官方获取证书内容打包到应用中
   }
   caCert, err := os.ReadFile("mongodb-ca.crt")
   if err == nil {
       certPool := x509.NewCertPool()
       certPool.AppendCertsFromPEM(caCert)
       tlsConfig.RootCAs = certPool
   }
   clientOpts.SetTLSConfig(tlsConfig)
   

2. 验证TLS握手时间：
   使用tcpdump在EKS节点上捕获TLS握手包，查看握手过程耗时是否超过1秒。

四、优化AWS网络配置 #

1. 配置VPC Peering：
   在Mongo Atlas控制台中创建与EKS VPC的对等连接，确保流量走私有网络而非公网，可直接降低网络延迟。
2. 检查安全组规则：
   • EKS节点安全组允许出站到Atlas集群的27017端口。
   • Atlas集群的IP白名单包含EKS节点的CIDR段。
3. 同区域部署：
   确保EKS集群与Mongo Atlas集群在同一AWS区域，避免跨区域网络延迟。

内容的提问来源于stack exchange，提问作者Sab