gRPC连接延迟疑问：先启客户端后启服务端为何延迟？如何解决？

我在一个简单gRPC示例里加入了循环逻辑，先启动客户端，等待约1分钟后再启动服务端。此时客户端仍会持续约30秒抛出rpcExceptions，之后才会打印服务端的回复，且客户端在无服务端运行的时间越久，延迟就越长。

客户端代码 #

internal class Program {
  static void Main(string[] args) {
    Channel channel = new Channel("localhost", 50000, ChannelCredentials.Insecure);
    var client = new GRPCConsoleClient.Greeter.GreeterClient(channel);

    while (true) {
      try {
        var reply = client.SayHello(new GRPCConsoleClient.HelloRequest {
          Name = "asdsad"
        });
        Console.WriteLine(reply);
      } catch (Exception ex) {

      }

      Task t = Task.Delay(1000);
      t.Wait();
    }
  }
}

服务端代码 #

static void Main(string[] args) {
  Server server = new Server {
    Services = {
        BindService(new GreeterService())
      },
      Ports = {
        new ServerPort("localhost", 50000, ServerCredentials.Insecure)
      }
  };

  server.Start();

  Console.WriteLine("Greeter server listening on port " + 50000);
  Console.WriteLine("Press any key to stop the server...");
  Console.ReadKey();

  server.ShutdownAsync().Wait();
}

延迟产生的原因 #

• gRPC的Channel默认采用指数退避重试机制：当客户端多次尝试连接服务端失败后，每次重试的等待间隔会按指数级增长，直到达到最大退避时长。你先启动客户端的1分钟内，它一直在尝试连接失败，积累了多次失败记录，导致服务端启动后，客户端仍会按照之前积累的退避间隔等待，从而产生延迟；无服务端运行时间越久，退避间隔被拉得越长，延迟也就越明显。
• 代码中捕获异常后未做任何处理，没有重置Channel的连接退避状态，导致Channel一直沿用之前失败的连接计时策略。

解决方法 #

1. 自定义Channel的重试策略 #

创建Channel时，通过ChannelOptions配置自定义的重试参数，限制退避的最大间隔、重试次数等，避免指数退避过度累积：

var channelOptions = new ChannelOptions
{
    ServiceConfig = new ServiceConfig
    {
        RetryPolicy = new RetryPolicy
        {
            MaxAttempts = 3,
            InitialBackoff = TimeSpan.FromMilliseconds(100),
            MaxBackoff = TimeSpan.FromMilliseconds(500),
            BackoffMultiplier = 1.5,
            RetryableStatusCodes = { StatusCode.Unavailable }
        }
    }
};
Channel channel = new Channel("localhost", 50000, ChannelCredentials.Insecure, channelOptions);

2. 捕获异常时重置退避计时器 #

在捕获到连接类异常（比如StatusCode.Unavailable）时，调用channel.ResetConnectBackoff()重置退避计时，让下次尝试连接使用初始间隔：

catch (RpcException ex)
{
    if (ex.Status.StatusCode == StatusCode.Unavailable)
    {
        channel.ResetConnectBackoff();
    }
}

3. 改用异步调用优化连接处理 #

将同步调用改为异步方式，提升线程效率的同时，也能更合理地处理连接状态：

static async Task Main(string[] args)
{
    Channel channel = new Channel("localhost", 50000, ChannelCredentials.Insecure);
    var client = new GRPCConsoleClient.Greeter.GreeterClient(channel);

    while (true)
    {
        try
        {
            var reply = await client.SayHelloAsync(new GRPCConsoleClient.HelloRequest { Name = "asdsad" });
            Console.WriteLine(reply);
        }
        catch (RpcException ex)
        {
            if (ex.Status.StatusCode == StatusCode.Unavailable)
            {
                channel.ResetConnectBackoff();
            }
        }

        await Task.Delay(1000);
    }
}

4. 设置合理的连接超时 #

在ChannelOptions中配置ConnectTimeout，避免客户端长时间等待无效连接：

var channelOptions = new ChannelOptions
{
    ConnectTimeout = TimeSpan.FromSeconds(2)
};

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