在 linux 中关闭 udp 套接字后，recv 不返回

Question

我正在尝试使用 udp 协议编写客户端服务器应用程序，但我遇到了连接结束问题。
我打开两个套接字（一个是“服务器”，另一个是“客户端”），当服务器从客户端异步接收时，客户端向他发送一条简单的消息，打印到控制台。
经过一段时间的睡眠（以确保服务器将再次调用 recv）客户端和服务器套接字关闭。 在这一点上，我预计 recv 将返回 -1 并且异步将结束。
但实际发生的是，recv 永远卡住了*。
如果就在关闭套接字之前我发送了一个空包（在代码中将 sendToMakeExit 变量设置为 true），recv 将返回该空包，并且仅在下一次调用后才返回 -1，尽管套接字在第一次调用中已关闭。

    const bool sendToMakeExit = false;
    const int port = 2000;
    const auto addr = "127.0.0.1";
    int serverSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    sockaddr_in target;
    target.sin_family = AF_INET;
    target.sin_port = htons(port);
    inet_pton(AF_INET, addr, &target.sin_addr);
    bind(serverSocket, (sockaddr *) &target, sizeof(target));
    auto readAsync = std::async(std::launch::async, [&serverSocket] {
        const int MAX_READ = 4096;
        char readBuf[MAX_READ];
        ssize_t actualRead;
        do {
            actualRead = recv(serverSocket, readBuf, MAX_READ, 0);
            if (actualRead > 0) {
                cout << readBuf << endl;
            }
        } while (actualRead != -1);
    });
    int clientSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    connect(clientSocket, (sockaddr *) &target, sizeof(target));
    this_thread::sleep_for(chrono::seconds(1));
    send(clientSocket, "test", 5, 0);
    this_thread::sleep_for(chrono::seconds(1));
    close(clientSocket);
    if (sendToMakeExit) {
        sendto(serverSocket, nullptr, 0, 0, (sockaddr *) &target, sizeof(target));
    }
    close(serverSocket);

*如果我在调试中运行此代码并在 recv 意外卡住时创建新断点，recv 返回 -1。
当我关闭套接字时，如何让 recv 返回 -1？

Answer 1

关闭一个套接字并不能保证另一个线程中仍在使用该套接字的任何函数调用立即返回。如果您有等待数据进入的调用，例如recv()、select()、poll()，则必须将一些数据发送到套接字以使这些调用返回。您在代码中执行此操作，但在收到长度为零的 UDP 数据包时实际上并没有退出：将 while 循环的结尾更改为：

} while (actualRead > 0);

但是，我建议使用一个标志变量来指示线程是否应该继续运行，如下所示：

volatile bool running = true;

auto readAsync = std::async(std::launch::async, [&serverSocket, &running] {
    ...
    while (running) {
        ...recv()...
    }
});

...
running = false;
sendto(serverSocket, ...);
readAsync.wait();
close(serverSocket);

注意我在关闭socket之前加了一行等待readAsync完成，为了防止意外发生：有一个小窗口，socket失效了，但是readAsync可能还是调用@ 987654330@就可以了。如果你有更多的线程，也可能会发生你关闭这个线程中的套接字，另一个线程打开一个新的套接字并获得与你刚刚关闭的相同的文件描述符编号，然后readAsync线程会使用错误插座。