Socket.EndReceive接收多TCP消息合并及UI冻结问题求助

TCP是面向流的传输协议，底层会根据网络状况合并或拆分数据包，哪怕你设置了NoDelay=true也无法完全避免粘包——这是协议特性，不是代码问题。你的场景中设备每10ms发8字节消息，出现768字节合并数据（96条消息）是完全正常的，必须在应用层处理拆包，同时解决UI冻结问题。

具体解决方案 #

1. 维护全局接收缓冲区

新增一个全局缓冲区暂存未处理的剩余数据，配合锁保证线程安全：

private readonly byte[] mBuffer = new byte[4096]; // 单次接收缓冲区
private readonly List<byte> mReceiveBuffer = new List<byte>(); // 全局暂存缓冲区
private readonly object mBufferLock = new object(); // 缓冲区锁

2. 修改异步接收逻辑

接收新数据后先追加到全局缓冲区，再启动单独线程处理拆包，避免阻塞UI：

void rcvTCP(IAsyncResult ar)
{
    var socket = (Socket)ar.AsyncState;
    try
    {
        var bytesRead = socket.EndReceive(ar);

        if (bytesRead > 0)
        {
            lock (mBufferLock)
            {
                // 将新接收的数据追加到全局缓冲区
                mReceiveBuffer.AddRange(mBuffer.Take(bytesRead));
            }

            // 用单独线程处理拆包，避免占用接收回调线程（可能是UI线程）
            Task.Run(ProcessReceivedData);
        }

        // 立即开启下一次异步接收，不要中断接收流程
        socket.BeginReceive(mBuffer, 0, mBuffer.Length, SocketFlags.None, rcvTCP, socket);
    }
    catch (Exception ex)
    {
        Debug.WriteLine(ex.Message);
    }
}

3. 实现固定长度拆包逻辑

循环检查全局缓冲区，每次拆分出完整的8字节消息，直到剩余数据不足一条：

private void ProcessReceivedData()
{
    lock (mBufferLock)
    {
        const int singleMessageSize = 8; // 每条消息固定8字节
        // 处理所有完整的消息
        while (mReceiveBuffer.Count >= singleMessageSize)
        {
            // 提取一条完整消息
            var singleMessage = mReceiveBuffer.Take(singleMessageSize).ToArray();
            // 移除已处理的字节
            mReceiveBuffer.RemoveRange(0, singleMessageSize);
            // 触发数据接收事件，注意：如果涉及UI操作，需要切换到UI线程
            dataReceived(this, mMaster.SlaveAddress, singleMessage);
        }
    }
}

关键注意事项 #

• 粘包本质：TCP不保证消息边界，无论用Socket还是TcpClient，都必须在应用层处理拆包（固定长度、分隔符、消息头+长度等方式）
• UI线程保护：异步接收的回调线程可能属于UI线程池，直接在回调中处理大量数据会导致UI冻结，用Task.Run把拆包逻辑放到后台线程
• 线程安全：全局缓冲区是共享资源，必须用lock避免多线程读写冲突
• UI跨线程访问：如果dataReceived事件中需要更新UI，必须用Control.Invoke（WinForms）或Dispatcher.Invoke（WPF）切换到UI线程执行

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