K8s环境下.Net 6微服务MongoDB连接重置问题求助

针对你遇到的K8s集群内.NET 6微服务连接MongoDB 6.0时出现的Connection reset by peer错误，结合环境给出以下可行方案：

一、排查K8s网络层面的连接中断问题 #

• 验证Pod到MongoDB的基础连通性：在Pod内执行telnet <mongodb-ip> 27017或nc -zv <mongodb-ip> 27017，确认网络无阻断；
• 检查K8s网络配置：确认MongoDB对应的Service Endpoint状态正常，网络策略未限制Pod与MongoDB的双向通信；
• 修改TCP KeepAlive参数：集群内负载均衡器、Node节点iptables可能回收闲置连接，通过initContainer调整内核参数：

  initContainers:
  - name: set-tcp-keepalive
    image: busybox:1.36
    command: ["sysctl", "-w", "net.ipv4.tcp_keepalive_time=60", "net.ipv4.tcp_keepalive_intvl=10", "net.ipv4.tcp_keepalive_probes=3"]
    securityContext:
      privileged: true
  

二、优化MongoDB Driver 2.19的连接配置 #

除调整连接池大小外，针对闲置连接、心跳检测等参数优化：

var clientSettings = MongoClientSettings.FromConnectionString("mongodb://your-mongodb-service:27017");
// 限制连接闲置时间，避免被回收
clientSettings.MaxConnectionIdleTime = TimeSpan.FromSeconds(30);
// 缩短心跳间隔，快速检测失效连接
clientSettings.HeartbeatInterval = TimeSpan.FromSeconds(10);
clientSettings.HeartbeatTimeout = TimeSpan.FromSeconds(15);
// 调整Socket超时，避免客户端提前断开
clientSettings.SocketTimeout = TimeSpan.FromMinutes(5);
clientSettings.ConnectTimeout = TimeSpan.FromSeconds(10);
// 多线程场景保持MongoClient全局单例（本身线程安全）
var mongoClient = new MongoClient(clientSettings);

三、检查MongoDB服务器端配置与状态 #

• 查看当前连接数：执行db.serverStatus().connections，确认current未接近max上限；
• 排查回包阻断：确认MongoDB服务器能正常解析Pod的IP，防火墙/安全组未截断回包链路；
• 检查MongoDB网络参数：确认net.maxIncomingConnections未被过低限制。

四、添加客户端异常容错与重试逻辑 #

Pod重启多因未捕获的Socket异常导致进程崩溃，添加重试机制：
使用Polly库实现重试策略：

var retryPolicy = Policy
    .Handle<SocketException>()
    .Or<IOException>()
    .WaitAndRetry(3, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)));

// 读取数据时应用重试
var data = retryPolicy.Execute(() => 
{
    var collection = mongoClient.GetDatabase("db").GetCollection<YourModel>("collection");
    return collection.Find(Builders<YourModel>.Filter.Empty).ToList();
});

五、调整K8s Pod的重启策略与资源配置 #

• 修改restartPolicy：避免单次异常触发重启，可调整为OnFailure并配合存活探针；
• 补充Pod资源：确保CPU/内存充足，避免因资源不足导致连接维护异常。

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