如何在gRPC服务器端（C#）检测SwiftUI客户端连接状态

gRPC基于HTTP/2，单纯靠请求超时无法可靠检测客户端静默断开的情况，以下是几种落地的方案，按可靠性排序：

1. 双向流心跳机制（推荐） #

这是最可靠的方案，通过维持长连接双向流，服务器可以实时感知客户端的连接状态，还能主动发送心跳检测。

步骤1：定义心跳RPC服务（.proto） #

service HeartbeatService {
  rpc KeepAlive(stream HeartbeatRequest) returns (stream HeartbeatResponse);
}

message HeartbeatRequest {
  string client_id = 1; // 客户端唯一标识（如设备ID/用户ID）
}

message HeartbeatResponse {
  int32 code = 1;
  string message = 2;
}

步骤2：C#服务器端实现 #

public override async Task KeepAlive(IAsyncStreamReader<HeartbeatRequest> requestStream, IServerStreamWriter<HeartbeatResponse> responseStream, ServerCallContext context)
{
    string clientId = string.Empty;
    try
    {
        // 获取客户端标识
        if (await requestStream.MoveNext(context.CancellationToken))
        {
            clientId = requestStream.Current.ClientId;
        }

        // 服务器主动发送心跳（每5秒一次）
        var heartbeatSender = Task.Run(async () =>
        {
            while (!context.CancellationToken.IsCancellationRequested)
            {
                await responseStream.WriteAsync(new HeartbeatResponse { Code = 0, Message = "Alive" });
                await Task.Delay(5000, context.CancellationToken);
            }
        }, context.CancellationToken);

        // 监听客户端心跳上报
        while (await requestStream.MoveNext(context.CancellationToken))
        {
            // 收到心跳可更新客户端在线状态（如写入缓存）
        }
    }
    catch (OperationCanceledException)
    {
        // 客户端断开时触发此异常
        Console.WriteLine($"客户端 {clientId} 已离线");
        // 执行你的业务操作：标记状态、清理资源等
        HandleClientOffline(clientId);
    }
}

private void HandleClientOffline(string clientId)
{
    // 替换为你的业务逻辑，比如更新数据库、通知其他服务
}

步骤3：SwiftUI客户端配合 #

客户端启动时建立双向流连接，定期发送心跳请求；如果连接断开，自动尝试重连。服务器端会在连接中断时捕获到取消异常，触发离线处理逻辑。

2. 利用ServerCallContext的取消令牌 #

针对单个RPC调用，注册CancellationToken回调，当客户端在调用过程中断开时，令牌会触发取消事件。

public override async Task<Method1Response> MyServer_grpcMethod1(Method1Request request, ServerCallContext context)
{
    // 注册断开回调
    context.CancellationToken.Register(() =>
    {
        var clientPeer = context.Peer; // 可通过Peer识别客户端，或结合请求里的客户端ID
        Console.WriteLine($"客户端 {clientPeer} 在调用Method1时断开");
        HandleClientOffline(clientPeer);
    });

    // 原有业务逻辑
    return await ProcessMethod1(request);
}

局限：仅能检测客户端在活跃RPC调用时的断开，无法覆盖客户端静默离线（无请求发送）的场景。

3. 配置HTTP/2空闲检测 #

通过gRPC服务器的HTTP/2配置，设置空闲超时，让服务器主动关闭长时间无活动的连接，结合取消令牌感知断开：

var server = new Server
{
    Services = { MyServer.BindService(new MyServerImpl()) },
    Ports = { new ServerPort("localhost", 50051, ServerCredentials.Insecure) },
    HttpHandler = new Http2Options
    {
        IdleTimeout = TimeSpan.FromSeconds(30), // 30秒无活动则关闭连接
        EnablePing = true, // 启用HTTP/2 PING帧检测
        PingTimeout = TimeSpan.FromSeconds(10)
    }
};
server.Start();

注意：这个配置只是主动清理空闲连接，要精准识别客户端，仍需结合客户端标识和取消令牌的回调。

关键注意点 #

• 不要依赖单纯的RPC请求超时：超时仅针对单个请求的响应时限，无法检测客户端连接状态。
• 必须给客户端分配唯一标识（如client_id）：服务器才能精准区分是客户端A/B/C中的哪一个离线。
• 双向流心跳是唯一能覆盖所有离线场景的方案，适合需要实时监控的业务需求。

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