c#检测ClientWebSocket何时断开(关闭)

var client = new ClientWebSocket();
client.ConnectAsync(new Uri("ws://example.com/socket"), CancellationToken.None).Wait();

client.Closed += (sender, e) =>
{
    Console.WriteLine("WebSocket closed.");
};

// 发送和接收消息的逻辑...

if (client.State == WebSocketState.Closed)
{
    Console.WriteLine("WebSocket is closed.");
}

try
{
    var buffer = new byte[1024 * 4];
    var result = await client.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
}
catch (WebSocketException ex)
{
    Console.WriteLine($"WebSocket error: {ex.Message}");
}

public class ChatClient
{
    private ClientWebSocket _client;

    public async Task ConnectAsync(string uri)
    {
        _client = new ClientWebSocket();
        await _client.ConnectAsync(new Uri(uri), CancellationToken.None);
        _client.Closed += OnClientClosed;

        // 开始接收消息
        await ReceiveMessagesAsync();
    }

    private void OnClientClosed(object sender, WebSocketClosedEventArgs e)
    {
        Console.WriteLine("Client disconnected.");
        // 通知服务器或其他客户端
    }

    private async Task ReceiveMessagesAsync()
    {
        var buffer = new byte[1024 * 4];
        while (_client.State == WebSocketState.Open)
        {
            try
            {
                var result = await _client.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
                if (result.MessageType == WebSocketMessageType.Close)
                {
                    await _client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closing", CancellationToken.None);
                }
                else
                {
                    // 处理接收到的消息
                }
            }
            catch (WebSocketException ex)
            {
                Console.WriteLine($"Error: {ex.Message}");
                break;
            }
        }
    }
}