多线程共用同一UdpClient实例仅收发数据是否线程安全？

问题描述 #

我正尝试实现一个线程安全的UDP套接字，为此创建两个while(true)循环分别处理发送和接收操作，按需持续收发信息。我快速编写了一段示例代码，基于Send和Receive方法互不影响UdpClient对象的假设，但对此并不确定。由于线程安全难以测试，特提前询问该实现思路是否存在问题。

示例代码 #

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Collections;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Collections.Concurrent;

namespace ConsoleApp1
{
    class ThreadSafeSocket
    {
        private UdpClient udpclient;
        private ConcurrentQueue<SendInfo> sendData;
        private SendInfo data;
        private object recieveLock;
        private int port;
        public ThreadSafeSocket(int port)
        {
            this.udpclient = new UdpClient(port);
            this.sendData = new ConcurrentQueue<SendInfo>();
            this.port = port;
            Thread receiveThread = new Thread(RecieveLoop);
            Thread sendThread = new Thread(SendLoop);
            receiveThread.Start();
            sendThread.Start();
        }

        public void Send(SendInfo data)
        {
            sendData.Enqueue(data);
        }
        public SendInfo Receive()
        {
            lock(recieveLock)
            {
                byte[] receivedata = new byte[data.Data.Length];
                Array.Copy(receivedata, data.Data, data.Data.Length);
                IPEndPoint point = new IPEndPoint(data.Point.Address, data.Point.Port);
                return new SendInfo(receivedata, point);
            }
        }
        private void SendLoop()
        {
            while (true)
            {
                if (sendData.TryDequeue(out SendInfo result))
                {
                    udpclient.Send(result.Data, result.Data.Length,this.data.Point);
                }
                else
                {
                    Thread.Sleep(1);
                }
            }
        }
        private void RecieveLoop()
        {
            while(true)
            {
                IPEndPoint point = new IPEndPoint(IPAddress.Any, this.port);
                byte[] data = this.udpclient.Receive(ref point);
                lock(recieveLock)
                {
                    this.data = new SendInfo(data, point);
                }
            }
        }
    }
}

注：SendInfo包含一个名为Data的字节数组和一个名为Point的IPEndpoint

存在的问题 #

1. UdpClient本身的线程安全隐患 #

.NET官方文档明确说明，UdpClient的Send和Receive方法不支持多线程并发调用。你的代码中发送线程和接收线程直接操作同一个UdpClient实例，会触发未定义行为，比如数据传输混乱、套接字状态异常甚至程序崩溃。

2. 未初始化同步对象 #

recieveLock字段在构造函数中未被实例化（没有recieveLock = new object();），调用Receive()方法时会直接抛出NullReferenceException。

3. 接收数据逻辑错误 #

• 用单个data变量存储接收数据，会导致后续接收的数据覆盖之前的结果，调用Receive()只能获取最近一次接收的内容，历史数据会丢失。
• 如果在还未收到任何数据时调用Receive()，data字段为null，会触发空引用异常。
• Array.Copy参数顺序颠倒，原代码是Array.Copy(receivedata, data.Data, data.Data.Length)，实际应该是Array.Copy(data.Data, receivedata, data.Data.Length)，否则返回的receivedata会是空数组。

4. 发送数据逻辑错误 #

SendLoop中错误地使用this.data.Point作为目标端点，而非result.Point，导致所有发送数据都会被发送到最近一次接收数据的端点，完全违背业务逻辑。

5. 空轮询浪费资源 #

SendLoop中当发送队列为空时，用Thread.Sleep(1)进行空轮询，会持续占用CPU资源，效率极低。

修正思路 #

• 保护UdpClient的并发访问：对UdpClient的Send和Receive调用加锁，确保同一时间只有一个线程操作套接字；或者为发送和接收分别创建独立的UdpClient实例（UDP本身支持多绑定）。
• 用并发队列存储接收数据：将单个data变量替换为ConcurrentQueue<SendInfo>存储所有接收的数据，Receive()方法从队列中取数据，避免数据丢失。
• 修复数据拷贝逻辑：修正Array.Copy的参数顺序，确保数据正确复制。
• 替换空轮询：使用BlockingCollection<T>替代ConcurrentQueue<T>，它支持阻塞式取数据，无需手动Sleep，提升性能。
• 初始化同步对象：在构造函数中实例化recieveLock，避免空引用异常。

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