c++ - 加速非阻塞 Unix 套接字 (C++)

Question

我已经实现了一个简单的套接字包装类。它包括一个非阻塞功能：

void Socket::set_non_blocking(const bool b) {
    mNonBlocking = b; // class member for reference elsewhere
    int opts = fcntl(m_sock, F_GETFL);
    if(opts < 0) return;
    if(b)
        opts |= O_NONBLOCK;
    else
        opts &= ~O_NONBLOCK;

    fcntl(m_sock, F_SETFL, opts);
}

该类还包含一个简单的接收函数：

int Socket::recv(std::string& s) const {
    char buffer[MAXRECV + 1];
    s = "";
    memset(buffer,0,MAXRECV+1);
    int status = ::recv(m_sock, buffer, MAXRECV,0);

    if(status == -1) {
    if(!mNonBlocking)
        std::cout << "Socket, error receiving data\n";

        return 0;
    } else if (status == 0) {
        return 0;
    } else {
        s = buffer;
        return status;
    }
}

实际上，调用 Socket::recv() 时似乎有大约 15 毫秒的延迟。这种延迟是可以避免的吗？我见过一些使用 select() 的非阻塞示例，但不明白这可能有什么帮助。

score 1 · Accepted Answer

这取决于您如何使用套接字。如果您有多个套接字并且循环遍历所有套接字，以检查可能导致延迟的数据。

使用非阻塞recv，您取决于那里的数据。如果您的应用程序需要使用多个套接字，您将不得不不断地轮流汇集每个套接字，以确定其中是否有可用的数据。

这对系统资源不利，因为这意味着即使无事可做，您的应用程序也会不断运行。

您可以通过选择来避免这种情况。您基本上设置了套接字，将它们添加到组并在组中选择。当任何选定的套接字上发生任何事情时，选择返回指定发生了什么以及在哪个套接字上。

有关如何使用 select 的一些代码，请查看beej 的网络编程指南

score 0 · Accepted Answer

你的有多大MAXRECV？可能只是您在堆栈增长时遇到了页面错误。其他人已经提到完全没有必要将接收缓冲区清零。当您创建一个std::string接收到的字符数据时，您还会进行内存分配和复制命中。

score 0 · Accepted Answer

select 会让你指定一个超时时间，并且可以测试套接字是否准备好被读取。所以你可以使用小于 15ms 的东西。顺便说一句，您需要小心您拥有的代码，如果线路上的数据可以包含嵌入的 NUL s，则不会包含所有读取的数据。你应该使用类似的东西s.assign(buffer, status);。

score 0 · Accepted Answer

除了 stefanB，我看到您每次都将缓冲区归零。何必？recv 返回实际读取的字节数。只需将 ( buffer[status+1]=NULL ) 之后的一个字节清零

c++ - 加速非阻塞 Unix 套接字 (C++)

4 回答 4

Related

Reference