AJAX在C#中处理WebSocket消息压缩与解压缩

在C#中，处理WebSocket消息的压缩和解压缩通常涉及到使用System.IO.Compression命名空间中的类。以下是一个简单的示例，展示了如何使用Gzip压缩和解压缩WebSocket消息：

1. 首先，确保已经安装了System.IO.Compression命名空间所需的程序集。在.NET Core或.NET 5及更高版本中，它已经包含在内。对于.NET Framework，请确保已经安装了System.IO.Compression程序集。

2. 创建一个用于压缩和解压缩字节数组的辅助方法：

using System;
using System.IO;
using System.IO.Compression;

public static class CompressionHelper
{
    public static byte[] Compress(byte[] data)
    {
        using (var memoryStream = new MemoryStream())
        {
            using (var gzipStream = new GZipStream(memoryStream, CompressionMode.Compress, true))
            {
                gzipStream.Write(data, 0, data.Length);
            }

            return memoryStream.ToArray();
        }
    }

    public static byte[] Decompress(byte[] data)
    {
        using (var compressedStream = new MemoryStream(data))
        {
            using (var decompressedStream = new MemoryStream())
            {
                using (var gzipStream = new GZipStream(compressedStream, CompressionMode.Decompress))
                {
                    gzipStream.CopyTo(decompressedStream);
                }

                return decompressedStream.ToArray();
            }
        }
    }
}

3. 在处理WebSocket消息时，使用这些辅助方法进行压缩和解压缩：

using System;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;

public class WebSocketHandler
{
    private readonly WebSocket _webSocket;

    public WebSocketHandler(WebSocket webSocket)
    {
        _webSocket = webSocket;
    }

    public async Task SendCompressedMessageAsync(string message, CancellationToken cancellationToken)
    {
        var data = Encoding.UTF8.GetBytes(message);
        var compressedData = CompressionHelper.Compress(data);
        await _webSocket.SendAsync(new ArraySegment<byte>(compressedData), WebSocketMessageType.Binary, true, cancellationToken);
    }

    public async Task<string> ReceiveDecompressedMessageAsync(CancellationToken cancellationToken)
    {
        var buffer = new byte[1024 * 4];
        var receivedData = new List<byte>();
        WebSocketReceiveResult result;

        do
        {
            result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), cancellationToken);
            receivedData.AddRange(buffer.Take(result.Count));
        }
        while (!result.EndOfMessage);

        var decompressedData = CompressionHelper.Decompress(receivedData.ToArray());
        return Encoding.UTF8.GetString(decompressedData);
    }
}

这个示例中的WebSocketHandler类提供了发送压缩消息和接收解压缩消息的方法。请注意，这里使用了Gzip压缩，但你可以根据需要选择其他压缩算法。