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壓縮，但你可以根據需要選擇其他壓縮算法。