ASP.NET Core能否自动关闭闲置WebSocket？无需ReceiveAsync检测客户端断开

1. ASP.NET Core 能否自动关闭闲置WebSocket连接？ #

可以通过配置WebSocketOptions.KeepAliveInterval配合异常处理实现类似“自动关闭”的效果：

• KeepAliveInterval会定期向客户端发送Ping帧，如果客户端已断开（比如关闭标签页），服务器在发送Ping帧或后续数据时会检测到连接异常。
• 注意：TCP连接的断开是被动检测机制，服务器只有在尝试读写操作时才会感知到客户端断开，无法完全脱离IO操作实现纯“自动”关闭。

2. 无需ReceiveAsync检测客户端断开的方式 #

不调用ReceiveAsync的情况下，可通过以下两种方式检测客户端断开并关闭连接：

• 捕获SendAsync的异常：当客户端断开后，服务器调用SendAsync会抛出IOException或WebSocketException，捕获这些异常即可触发连接关闭逻辑。
• 利用KeepAlive机制：配置的KeepAliveInterval会自动发送Ping帧，若客户端无响应，后续的Ping操作会抛出异常，同样可以捕获并处理。

修正后的示例代码 #

你的代码遗漏了接受WebSocket连接的关键步骤（AcceptWebSocketAsync），以下是修正并加入异常处理的完整版本：

app.UseWebSockets(new WebSocketOptions()
{
    KeepAliveInterval = TimeSpan.FromSeconds(10), // 定期发送Ping帧检测连接
    AllowedOrigins = { "*" }
});

app.MapControllers();

[ApiController]
[Route("[controller]")]
public class HomeController : ControllerBase
{
    private readonly IReadOnlyList<WebSocketState> _invalidWebSocketStateList = new[]
        { WebSocketState.CloseReceived, WebSocketState.Closed, WebSocketState.Aborted };

    public async Task<IActionResult> Index()
    {
        if (!HttpContext.WebSockets.IsWebSocketRequest)
        {
            return Ok("end");
        }

        // 接受WebSocket连接，using自动管理资源
        using var webSocket = await HttpContext.WebSockets.AcceptWebSocketAsync();

        try
        {
            while (true)
            {
                await Task.Delay(1000);

                var sendData = new List<DataInfo>();
                // 填充业务数据逻辑
                var valBytes = Encoding.UTF8.GetBytes(JsonSerializer.Serialize(sendData));
                var mem = new ReadOnlyMemory<byte>(valBytes);
                
                // 发送数据时捕获客户端断开异常
                await webSocket.SendAsync(mem, WebSocketMessageType.Text, true, CancellationToken.None);

                // 辅助检查本地缓存状态（仅作为补充，不能单独依赖）
                if (_invalidWebSocketStateList.Contains(webSocket.State))
                {
                    break;
                }
            }
        }
        catch (IOException)
        {
            // 客户端断开时通常会抛出此异常
        }
        catch (WebSocketException)
        {
            // WebSocket连接异常（如主动关闭）
        }
        finally
        {
            // 确保连接被正确关闭
            if (webSocket.State != WebSocketState.Closed)
            {
                await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "连接已关闭", CancellationToken.None);
            }
        }

        return Ok("websocket closed");
    }

    // 定义数据结构
    public class DataInfo { /* 你的业务字段 */ }
}

关键说明 #

• 必须接受连接：一定要调用AcceptWebSocketAsync获取WebSocket实例，否则无法进行任何WebSocket操作。
• 不能单独依赖WebSocket.State：State是本地维护的缓存状态，只有执行IO操作（Send/Receive）后才会更新，单独依赖它无法准确判断客户端是否断开。
• KeepAlive的作用：即使没有主动调用SendAsync，KeepAliveInterval设置的Ping帧也会定期触发IO操作，一旦客户端断开，Ping操作会抛出异常，从而触发连接关闭逻辑。

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