.NET 8.0中多线程UdpClient无法同时收发数据问题

你的问题核心是两个UDP转发任务无法并行运行，第一个任务在第二个任务启动后停止接收数据，最可能的原因是本地UDP端口绑定冲突，或者未配置端口重用选项。以下是具体排查和解决步骤：

1. 优先确认本地端口唯一性 #

确保requestData.localPort和responseData.localPort是两个完全不同的端口（例如8080和8081）。Windows默认不允许两个UdpClient绑定同一个端口，若端口重复，第二个UdpClient初始化会抢占端口，导致第一个任务的ReceiveAsync无法再获取数据，甚至直接抛出异常。

2. 配置端口重用（若需共享同一端口） #

如果业务场景要求两个任务共享同一本地端口（如UDP多播接收），需要给UdpClient设置ReuseAddress选项，允许多个套接字绑定同一端口：

修改RecvAndSend方法中recv的初始化代码：

// 替换原有的 using var recv = new UdpClient(data.localPort);
var recvSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
// 开启地址重用
recvSocket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
using var recv = new UdpClient(recvSocket);
// 显式绑定到指定本地端口
recv.Client.Bind(new IPEndPoint(IPAddress.Any, data.localPort));

3. 添加详细日志排查问题 #

在代码中添加更细粒度的日志，确认任务是否真的停止接收，或是无数据输入：

public async Task RecvAndSend(DataObj data, bool isRequest)
{
    var taskName = isRequest ? "Request" : "Response";
    try
    {
        using var recv = new UdpClient(data.localPort);
        using var send = new UdpClient();
        var remoteEndpoint = new IPEndPoint(data.remoteAddress, data.remotePort);

        Console.WriteLine($"[{taskName}] Started, listening on port {data.localPort}");
        while (true)
        {
            try
            {
                Console.WriteLine($"[{taskName}] Waiting for data...");
                var result = await recv.ReceiveAsync();
                byte[] res = result.Buffer;
                Console.WriteLine($"[{taskName}] Received {res.Length} bytes");
                
                await send.SendAsync(res, res.Length, remoteEndpoint);
                Console.Write(isRequest ? "-" : "~");
            }
            catch (SocketException ex)
            {
                Console.WriteLine($"[{taskName}] Socket Error: {ex.Message}, Code: {ex.ErrorCode}");
            }
            catch (Exception ex)
            {
                Console.WriteLine($"[{taskName}] Error: {ex.Message}\n{ex.StackTrace}");
            }
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"[{taskName}] Fatal Error: {ex.Message}");
    }
    finally
    {
        Console.WriteLine($"[{taskName}] Task terminated");
    }
}

4. 验证任务生命周期 #

通过finally块的日志，可以明确任务是正常运行还是意外终止。如果第一个任务的Task terminated日志提前出现，说明任务因未捕获的异常终止，需要根据错误信息进一步排查。

修改后的启动代码无需调整，保持原有的并行启动逻辑即可：

Task t1 = RecvAndSend(requestData, true);
Task t2 = RecvAndSend(responseData, false);

await Task.WhenAll(t1, t2);

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