Win11下C#与WSL2 Python间ZeroMQ延迟异常升高问题排查

我尝试在Win11系统的C#客户端与WSL2中的Python服务器之间传输图像。使用ZeroMQ发送字节数组时，当字节数组大小超过约8KB阈值，延迟会从0.3ms骤升至50ms，该高延迟状态会持续到大小达到约74KB后，才回落至0.3ms左右。

我曾查阅过Nagle算法相关资料，但ZeroMQ默认已禁用该算法。

【更新】在Win11本地运行Python服务器时，使用完全相同的代码文件未出现此问题。

请问有人能指出问题所在吗？

C# 客户端 #

using System.Diagnostics;
using NetMQ;
using NetMQ.Sockets;

namespace ChatGptUdp;

internal class Program
{
    private static void Main(string[] args)
    {
        var socket = new RequestSocket();
        socket.Connect("tcp://localhost:5555");
        var data = new byte[100000];
        for (var i = 0; i < data.Length; i++) data[i] = (byte) i;

        for (var i = 1; i < 100; i++)
        {
            var targetLength = 1000 * i;
            var chunk = data.Take(targetLength).ToArray();
            var elapsed = new List<TimeSpan>();
            for (var j = 0; j < 100; j++)
            {
                var sw = Stopwatch.StartNew();
                socket.SendFrame(chunk);
                var response = socket.ReceiveFrameString();
                sw.Stop();
                elapsed.Add(sw.Elapsed);
            }
            // 跳过前50次测试以忽略启动延迟
            Console.Out.WriteLine($"{targetLength}: {elapsed.Skip(50).Average(s => s.TotalMilliseconds)}");
        }
    }
}

Python 服务器 #

import zmq
import numpy as np
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind('tcp://*:5555')
print("Server connected")
while True:
    msg = socket.recv()
    data = {
        'str': 'Hello there!'
    }
    socket.send_json(data)

延迟测试结果 #

这个延迟突变的核心原因是WSL2虚拟网络层的TCP分段与传输机制特性：

1. WSL2网络的MTU限制
   WSL2默认虚拟网卡MTU为1500字节（标准以太网值），当消息大小超过单段TCP有效载荷（约1460字节，扣除IP/TCP头）时，会触发多次TCP分段传输。ZeroMQ在处理8KB-74KB的中等大小消息时，会采用"分段发送+等待确认"的模式，叠加WSL2虚拟网络的额外转发开销，直接导致延迟跃升至50ms左右。

当消息超过74KB时，ZeroMQ会切换到批量传输模式，利用TCP滑动窗口一次性发送更多分段，此时WSL2的网络开销被摊薄，延迟回归正常水平。而本地运行服务器无此问题，是因为原生Windows TCP栈的效率远高于WSL2的虚拟网络栈。

2. 可行的解决方法

• 调整ZeroMQ缓冲区大小：在客户端和服务器端增大套接字的发送/接收缓冲区，适配WSL2的网络特性：
  Python服务器端示例：

  socket.setsockopt(zmq.SNDBUF, 131072)
  socket.setsockopt(zmq.RCVBUF, 131072)
  

  C#客户端示例：

  socket.Options.SendBuffer = 131072;
  socket.Options.ReceiveBuffer = 131072;
  

• 修改WSL2的MTU值：将WSL2虚拟网卡MTU调整为更大值（如8192），减少TCP分段次数。在WSL2终端执行：

  sudo ip link set dev eth0 mtu 8192
  

  注：该设置重启WSL后失效，可添加到~/.bashrc或~/.zshrc中持久化。
• 切换ZeroMQ套接字类型：尝试使用ZMQ_STREAM替代REQ/REP，更灵活地控制传输逻辑，减少确认等待带来的延迟。

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