C# 异步套接字 : How much data does the Socket store when the call to BeginReceive is delayed?

Question

我正在使用 C# 的异步套接字并使用 BeginReceive 将数据从套接字读取到一个 8192 字节的 byte[]-Buffer 中。但是，当新数据包在再次调用 BeginReceive 之前进入时会发生什么？我当前的设置在停止之前处理大约 3 条传入消息。我假设 Socket 必须先将传入数据存储在某处，然后才能由 BeginReceive 处理。

我是否可以控制 Socket 在停止之前缓冲的数据量？

我是否必须依靠足够快的速度处理传入的消息才不会“错过”任何消息？

当下面示例中的 ProcessMessageBuffer 方法花费很长时间(出于某种原因)以至于传入数据开始堆积在 Socket 中时，会发生什么情况？

public void ReadCallback(IAsyncResult ar)
    {
        // We have a new TCP Packet!
        int bytesReceived = 0;

        try
        {
            // The amount of bytes we have just received
            bytesReceived = Socket.EndReceive(ar);
        }
        catch (SocketException ex)
        {
            // The client closed the connection
            OnSocketException(new SocketExceptionEventArgs(ex));
        }

        if (bytesReceived > 0)
        {
            // We have received some data. Write it to the MessageBuffer
            MessageBuffer.Write(ReceiveBuffer, 0, bytesReceived);

            // Process the Messages that may be stored in the MessageBuffer
            // What happens, if this takes too long?
            ProcessMessageBuffer(MessageBuffer.ToArray());

            // Get ready to receive more data
            Socket.BeginReceive(ReceiveBuffer, 0, ReceiveBuffer.Length, SocketFlags.None, new AsyncCallback(ReadCallback), null);
        }
    }

Answer 1

网络 I/O 在每一步都被缓冲。因此很难知道您担心的是哪个“缓冲区”。

来自 Socket.ReceiveBufferSize :

…The default is 8192.

A larger buffer size potentially reduces the number of empty acknowledgements (TCP packets with no data portion), but might also delay the recognition of connection difficulties. Consider increasing the buffer size if you are transferring large files, or you are using a high bandwidth, high latency connection (such as a satellite broadband provider.)

从你的问题:

Do I have any control over how much data the Socket buffers before it stops?

你至少有几个可用的策略:

• 修改ReceiveBufferSize 属性值。这将更改套接字对象中缓冲区的大小。
• 在调用 BeginReceive() 时使用更大的缓冲区。这将为 Socket 对象提供更多空间，以便它可以在无法再清空自己的缓冲区之前写入。请注意，您传递给 Socket 的缓冲区将被固定，直到接收操作完成，这可能会对内存堆管理产生影响。
• 发出多个 BeginReceive() 调用。这与提供更大的缓冲区具有类似的效果，但可以让您更精细地控制缓冲区。随之而来的是，由于 Windows 调度线程的方式，您最终可能会以不同于您最初调用 BeginReceive() 的顺序执行接收操作完成的回调。根据 BeginReceive() 调用的顺序和您传递的每个缓冲区，数据 将以正确的顺序排列，但这些缓冲区可能在您的代码中显示为已填充乱序(它们不是真的，但是处理较晚填充的缓冲区的线程可能会在处理较早填充的缓冲区的线程之前运行)。

参见 socket buffer size: pros and cons of bigger vs smaller了解更多详情。

Do I have to rely on processing the incoming messages fast enough in order not to "miss" any?

没有。 TCP 是可靠的。如果您处理数据的速度不够快，将会发生的只是远程端点将不得不等待发送更多数据。

也就是说，您应该非常努力地使您的套接字 I/O 代码尽可能快地运行。如果您有一些处理速度慢到足以延迟接收操作，您应该将该处理卸载到一个完全独立的线程，自己缓冲接收到的数据(例如使用 MemoryStream、FileStream，某种队列等)。

如果你那样做，那么除了简单的、默认的套接字处理之外，你可能不需要做任何任何。您将能够立即有一个未完成的 BeginReceive()，您不必调整套接字的缓冲区，并且您将能够分配“正常大小”的 byte[] 对象(或保留一个对象以供重用)。