c++ - 非阻塞 TCP 缓冲区问题

Question

我觉得我遇到了麻烦。我有两个相互连接的 TCP 应用程序，它们使用 winsock I/O 完成端口发送/接收数据(非阻塞套接字)。

一切正常，直到出现数据传输突发。发件人开始发送不正确/格式错误的数据。

我在堆栈上分配了要发送的缓冲区，如果我理解正确，那是错误的做法，因为这些缓冲区在我发送它们时应该保持不变，直到我收到来自 IOCP 的“写入完成”通知。

以此为例:

void some_function()
{
    char cBuff[1024];

    // filling cBuff with some data

    WSASend(...); // sending cBuff, non-blocking mode

    // filling cBuff with other data

    WSASend(...); // again, sending cBuff

    // ..... and so forth!
}

如果我理解正确，这些 WSASend() 调用中的每一个都应该有自己唯一的缓冲区，并且只有在发送完成时才能重用该缓冲区。
正确吗？

现在，我可以实现什么策略来维护大量此类缓冲区，我应该如何处理它们，如何避免性能损失等？
而且，如果我要使用缓冲区，这意味着我应该将要从源缓冲区发送的数据复制到临时缓冲区，因此，我会将每个套接字上的 SO_SNDBUF 设置为零，这样系统就不会重新复制我的内容已经复制了。你和我在一起吗？如果我不清楚，请告诉我。

Answer 1

认真看boost::asio .异步 IO 是它的专长(顾名思义。)这是一个非常成熟的库，现在在 Boost 中。自 1.35。许多人在生产中使用它来建立非常密集的网络。有很多examples在文档中。

有一件事是肯定的 - 它需要与 buffers 一起工作非常认真。

编辑:

处理突发输入的基本思想是排队。

• 例如，创建三个预分配缓冲区的链表 - 一个用于空闲 缓冲区，一个用于待处理(已接收)数据，一个用于待发送数据。
• 每次你需要发送一些东西时 - 从空闲列表中取出一个缓冲区(如果空闲列表为空，则分配一个新缓冲区)，填充数据，将其放入待定-发送列表。
• 每次您需要接收一些东西时 - 从上面的空闲列表中取出一个缓冲区，将其交给 IO 接收例程。
• 定期从待发送队列中取出缓冲区，将它们交给发送程序。
• 发送完成(内联或异步)- 将它们放回空闲列表。
• 接收完成后 - 将缓冲区放入待处理列表。
• 让您的“业务”例程从待处理列表中删除缓冲区。

突发将填满该输入队列，直到您能够处理它们。您可能希望限制队列大小以避免耗尽所有内存。