Socket.BeginReceive 合并 TCP 数据包

Question

是否有一个设置可以用来防止将多个 TCP 数据包合并到 Socket.BeginReceive 回调内的单个缓冲区中？

你的下意识反应是我无法阻止 TCP 拆分/合并数据，但 这不是我要的；我可以清楚地看到在 Wireshark 中接收到的各个数据包，我唯一关心的是延迟，即在数据段到达时立即处理它。这并不意味着我不知道如何处理拆分/合并段，而是意味着我想避免延迟。

我的代码如下所示：

void WaitForData(ISocketInfo soc)
{
    if (socket != null && socket.Connected)
        socket.BeginReceive(buffer, 0, buffer.Length, 
            SocketFlags.None, OnPacketReceived, socket);
}

void OnPacketReceived(IAsyncResult asyn)
{
    try
    {
        var socket = (ISocketInfo)asyn.AsyncState;

        numberOfBytesReceived = socket.EndReceive(asyn);
        if (numberOfBytesReceived > 0)
        {
            _queue.Enqueue(buffer, 0, numberOfBytesReceived);
            OnNewDataReceived();
        }

        WaitForData(socketInfo);
    }
    catch (SocketException ex)
    {
        Log.Warn("Socket error while receiving packet", ex);
        Close();
    }
}

当我在 WireShark 中检查这些数据包时，我可以看到每 50 毫秒接收一次单独的 TCP 数据包，每个（比如说）100 字节。但有时在我的应用程序中会有 100 毫秒的延迟，而 OnPacketReceived 方法获得 200 字节。

既然 WireShark 确认这不是操作系统/网络问题，那么这里的问题可能是什么？ OnPacketReceived 只是在后台线程上触发，因此它不会阻塞该方法，并且程序实际上并不会消耗太多 CPU。

（更新）

看来我的问题表达得不够清楚。我的问题不是如果数据被分割成段，如何解析数据。我的协议定义明确（即START_COOKIE、LENGTH、DATA、CRC），我一收到数据就将数据排入字节FIFO（上面sn-p中的_queue.Enqueue调用），所以我可以轻松解析它是异步的。

问题是，如果我看到没有数据包。在 Wireshark 中 +50ms 时为 1（100 字节），数据包编号2（100 字节）在 Wireshark 中 +100 毫秒，我的应用程序没有阻塞 OnPacketReceived 方法并且不消耗 CPU，.NET 怎么会每隔一段时间在 +100 毫秒时调用 OnPacketReceived 并合并两个数据包合二为一？

Answer 1

TCP 根据定义是一个连续的数据流（它的主要特征是让它看起来好像根本没有数据包，不像 UDP）。因此，由您的软件来定义消息格式。你可以：

• 用长度标记每条消息的开头（http 会这样做）。
• 在邮件末尾添加分隔标记 (/n)。要让接收者知道何时开始和停止阅读单条消息，请标记消息的开头和结尾（使用无法键入的特殊符号）。

总而言之，您必须注意将流拆分为消息。或者在 TCP 之上使用 HTTP、WebSockets 或其他消息格式实现。

Answer 2

您可能会收到更少或更多，但不能保证您会收到发送的确切内容。

来自 MSDN：

无法保证您发送的数据会立即出现在网络上。为了提高网络效率，底层系统可能会延迟传输，直到收集到大量传出数据。 BeginSend 方法的成功完成意味着底层系统有空间来缓冲您的数据以进行网络发送。

Here 是一篇很好的文章，可以解释这一点以及如何解决问题。