如何中断 TCP/IP 服务器中的 accept()？

Question

我正在开发一个视觉应用程序，它有两种模式： 1) 参数设置 2) 自动 问题出在 2) 中，当我的应用程序通过 TCP/IP 等待信号时。程序在调用accept()-methode 时冻结。我想在 GUI 上提供更改模式的可能性。所以如果模式正在改变，它是由另一个信号（message_queue）提供的。所以我想中断接受状态。 是否有简单的可能性来中断接受？

std::cout << "TCPIP " << std::endl;

client = accept(slisten, (struct sockaddr*)&clientinfo, &clientinfolen);

if (client != SOCKET_ERROR)
    cout << "client accepted: " << inet_ntoa(clientinfo.sin_addr) << ":"
         << ntohs(clientinfo.sin_port) << endl;

//receive the message from client
//recv returns the number of bytes received!!
//buf contains the data received
int rec = recv(client, buf, sizeof(buf), 0);
cout << "Message: " << rec << " bytes and the message   " << buf << endl;

我读到了select()，但我不知道如何使用它。谁能给我一个提示，例如如何在我的代码中实现select()？

谢谢。

最好的问候，

T

Answer 1

解决方案是仅在有传入连接请求时才调用accept()。您可以通过轮询侦听套接字来做到这一点，您还可以在其中添加其他文件描述符、使用超时等。

您没有提及您的平台。 Linux上看epoll()，UNIX看poll()/select()，Windows我不知道。

Answer 2

一般的方法是使用本地 TCP 连接，UI 线程可以通过该连接中断 select 调用。一般架构将使用：

• 在slisten 和本地 TCP 连接上等待 select 的专用线程
• UI 线程和等待线程之间的 TCP 连接（Unix 或类 Unix 系统上的 Unix 域套接字，或 Windows 上的 127.0.0.1）
• 根据需要在两个线程之间进行各种同步/消息

只需声明select 应该读取slisten 和本地套接字。它会在一个准备好后立即返回，您将能够知道哪个准备好了。

Answer 3

由于您没有指定您的平台，并且网络，尤其是异步，是特定于平台的，我想您需要一个跨平台的解决方案。 Boost.Asio 非常适合这里：http://www.boost.org/doc/libs/1_39_0/doc/html/boost_asio/reference/basic_socket_acceptor/async_accept/overload1.html

链接示例：

void accept_handler(const boost::system::error_code& error)
{
  if (!error)
  {
    // Accept succeeded.
  }
}

...

boost::asio::ip::tcp::acceptor acceptor(io_service);
...
boost::asio::ip::tcp::socket socket(io_service);
acceptor.async_accept(socket, accept_handler);

如果Boost 是个问题，Asio 可以是仅标头库并在没有 Boost 的情况下使用：http://think-async.com/Asio/AsioAndBoostAsio。

Answer 4

一种方法是在超时的循环中运行select。

将slisten 置于非阻塞模式（这不是绝对必要的，但有时accept 会阻塞，即使select 另有说明）然后：

fd_set read_fds;
FD_ZERO(&read_fds);
FD_SET(slisten, &read_fds);

struct timeval timeout;
timeout.tv_sec = 1;  // 1s timeout
timeout.tv_usec = 0;

int select_status;
while (true) {
    select_status = select(slisten+1, &read_fds, NULL, NULL, &timeout);
    if (select_status == -1) {
        // ERROR: do something
    } else if (select_status > 0) {
        break;  // we have data, we can accept now
    }
    // otherwise (i.e. select_status==0) timeout, continue
}

client = accept(slisten, ...);

这将允许您每秒捕获一次信号。更多信息在这里：

http://man7.org/linux/man-pages/man2/select.2.html

和Windows版本（差不多）：

https://msdn.microsoft.com/pl-pl/library/windows/desktop/ms740141(v=vs.85).aspx