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

在C#中，检测ClientWebSocket何时断开（关闭）可以通过几种方式实现。以下是一些基础概念和相关方法：

基础概念

WebSocket: 是一种在单个TCP连接上进行全双工通信的协议。
ClientWebSocket: 是.NET框架中用于实现WebSocket客户端的类。

类型与应用场景

聊天应用: 实时消息传递。
在线游戏: 实时数据同步。
股票交易: 实时数据更新。

检测断开的方法

方法一：使用`CloseAsync`和`CloseOutputAsync`

当客户端或服务器关闭连接时，通常会发送一个关闭帧。可以通过监听CloseAsync或CloseOutputAsync方法来处理关闭事件。

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

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

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

方法二：检查`WebSocketState`

可以通过定期检查WebSocket.State属性来判断连接状态。

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

方法三：处理异常

在读写操作中捕获异常，如WebSocketException，这通常意味着连接已断开。

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;
            }
        }
    }
}