Python gRPC客户端偶发Connection reset by peer错误（UNAVAILABLE状态）求助

可能的原因 #

• 服务器端闲置连接超时：NestJS gRPC服务器或前端代理（如Nginx）配置了过短的闲置连接超时，当客户端连接长时间无活动时被主动断开。
• 客户端keepalive参数不完整：当前仅配置了grpc.keepalive_time_ms和grpc.keepalive_permit_without_calls，缺少关键参数导致keepalive机制无法正常维持连接。
• 网络中间件干预：防火墙、负载均衡器等中间设备主动断开了长时间闲置的连接。
• 服务器资源过载：服务器CPU、内存耗尽时，会主动终止部分连接以释放资源。

客户端（Python）修复方案 #

1. 完善keepalive参数配置
   补充更多keepalive相关参数，确保与服务器端参数匹配：

   def connect_to_user_manager_server() -> AuthorizationControllerStub:
       channel = grpc.insecure_channel(envs.USER_MANAGER_GRPC_URL, options=(
           ('grpc.keepalive_time_ms', 120000),
           ('grpc.keepalive_permit_without_calls', True),
           ('grpc.keepalive_timeout_ms', 30000),  # 等待keepalive响应超时
           ('grpc.http2.max_pings_without_data', 0),  # 允许无数据时发送ping
           ('grpc.http2.min_time_between_pings_ms', 30000),  # 两次ping最小间隔
           ('grpc.http2.min_ping_interval_without_data_ms', 30000),  # 无数据时ping间隔
       ))
       stub = AuthorizationControllerStub(channel)
       return stub
   

2. 复用Channel和Stub
   避免每次请求重新创建连接，复用已有的Channel和Stub：

   # 全局维护一个客户端实例
   _client = None
   
   def get_user_manager_client() -> AuthorizationControllerStub:
       global _client
       if _client is None or _client._channel.get_state() != grpc.ChannelState.READY:
           _client = connect_to_user_manager_server()
       return _client
   
   # 使用方式
   user_response = get_user_manager_client().CheckAuthorization(
       authorizationData(authorization=token, requiredRoles=roles)
   )
   

3. 启用gRPC debug日志
   添加日志排查具体连接问题：

   import logging
   logging.basicConfig(level=logging.DEBUG)
   logging.getLogger('grpc').setLevel(logging.DEBUG)
   

服务器端（NestJS）修复方案 #

1. 配置gRPC keepalive参数
   在NestJS的gRPC配置中添加对应keepalive设置，与客户端参数对齐：

   import { Module } from '@nestjs/common';
   import { ClientsModule, Transport } from '@nestjs/microservices';
   
   @Module({
     imports: [
       ClientsModule.register([
         {
           name: 'USER_MANAGER_SERVICE',
           transport: Transport.GRPC,
           options: {
             url: '0.0.0.0:50051',
             keepalive: {
               keepaliveTimeMs: 120000,
               keepaliveTimeoutMs: 30000,
               keepalivePermitWithoutCalls: true,
               http2MaxPingsWithoutData: 0,
             },
           },
         },
       ]),
     ],
   })
   export class AppModule {}
   

2. 检查代理超时配置
   如果服务器前端有Nginx、负载均衡器等代理，调整其闲置超时时间，确保大于等于客户端keepalive间隔。例如Nginx配置：

   http {
     upstream grpc_backend {
       server localhost:50051;
     }
   
     server {
       listen 443 ssl http2;
   
       location / {
         grpc_pass grpc://grpc_backend;
         grpc_socket_keepalive on;
         proxy_connect_timeout 300s;
         proxy_send_timeout 300s;
         proxy_read_timeout 300s;
       }
     }
   }
   

3. 监控服务器资源
   检查服务器CPU、内存使用率，确保资源充足，避免因过载导致连接被终止。

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