.NET 6中如何为ClientWebSocket启用permessage-deflate压缩

我正在使用.NET 6的ClientWebSocket建立WebSocket连接，从以下握手信息可知服务端支持permessage-deflate扩展：

GET / HTTP/1.1
Sec-WebSocket-Version: 13
Sec-WebSocket-Key: 4Qecg52c4NaUM7RDCcW9/g==
Connection: Upgrade
Upgrade: websocket
Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits
Host: domainname:64901

HTTP/1.1 101 WebSocket Protocol Handshake
Upgrade: WebSocket
Connection: Upgrade
Sec-WebSocket-Accept: +lpWMhWJ1SpnmxcxRtx/Bk+k5q8=
Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits=15

问题与解答 #

1. 需启用ClientWebSocket的哪些选项来开启permessage-deflate？ #

• 必须配置ClientWebSocketOptions.DangerousDeflateOptions属性，给它赋值一个实例化的WebSocketDeflateOptions对象，这是开启permessage-deflate扩展的核心配置项。

2. 若需配置WebSocketDeflateOptions对象，应设置哪些参数？ #

• 结合服务端返回的握手响应，重点配置以下参数：
  • ClientMaxWindowBits：设为15，和服务端响应的client_max_window_bits=15保持一致，指定客户端压缩使用的滑动窗口大小；
  • 可选配置：
    • ServerMaxWindowBits：若服务端有指定窗口大小可对应设置，未指定则用默认值；
    • DisableClientContextTakeover/DisableServerContextTakeover：默认启用上下文接管，若不需要可设为true关闭。

3. 仅添加请求头"Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits"是否就能实现压缩？ #

• 不行。手动添加请求头只是在握手时发送了扩展协商信息，但ClientWebSocket不会自动启用压缩逻辑，必须通过配置DangerousDeflateOptions让框架处理后续的压缩/解压缩操作，否则即使服务端同意，客户端也不会实际对数据进行压缩处理。

4. 压缩/解压缩是否需要手动在收发内容前后处理，还是由ClientWebSocket内部处理？ #

• 完全由ClientWebSocket内部自动处理。只要正确配置了Deflate选项，发送消息时框架会自动压缩，接收时自动解压缩，你直接调用SendAsync和ReceiveAsync收发数据即可，不用手动干预压缩逻辑。

5. .NET 6中启用permessage-deflate的示例代码 #

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

class WebSocketClientWithDeflate
{
    static async Task Main(string[] args)
    {
        using var client = new ClientWebSocket();
        var options = client.Options;

        // 配置permessage-deflate扩展
        options.DangerousDeflateOptions = new WebSocketDeflateOptions
        {
            ClientMaxWindowBits = 15, // 匹配服务端响应的窗口大小
            // 可选：根据需求调整以下参数
            // DisableClientContextTakeover = false,
            // DisableServerContextTakeover = false,
            // ServerMaxWindowBits = 15
        };

        var serverUri = new Uri("ws://domainname:64901");
        try
        {
            await client.ConnectAsync(serverUri, CancellationToken.None);
            Console.WriteLine("WebSocket连接建立成功，已启用permessage-deflate压缩");

            // 发送测试消息（自动压缩）
            var sendContent = "这是一条测试压缩消息";
            var sendBuffer = Encoding.UTF8.GetBytes(sendContent);
            await client.SendAsync(
                new ArraySegment<byte>(sendBuffer),
                WebSocketMessageType.Text,
                endOfMessage: true,
                CancellationToken.None);
            Console.WriteLine("消息已发送");

            // 接收消息（自动解压缩）
            var receiveBuffer = new byte[1024];
            var receiveResult = await client.ReceiveAsync(
                new ArraySegment<byte>(receiveBuffer),
                CancellationToken.None);
            var receivedContent = Encoding.UTF8.GetString(receiveBuffer, 0, receiveResult.Count);
            Console.WriteLine($"收到消息：{receivedContent}");
        }
        catch (Exception ex)
        {
            Console.WriteLine($"出错：{ex.Message}");
        }
        finally
        {
            if (client.State == WebSocketState.Open)
            {
                await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "正常关闭", CancellationToken.None);
            }
        }
    }
}

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