使 boost::asio::ip::tcp::acceptor 非阻塞

Question

我一直在尝试使用 tcp::acceptor 创建一个非阻塞 TCP 服务器。我在使用 BSD 套接字和 C(++) 之前已经完成了此操作，但无法使用 boost 设置非阻塞 I/O。

C(++)：

#ifdef WIN32
  int mode = 1;
  ioctlsocket(Socket, FIONBIO, (u_long FAR *) &mode);
#else
  fcntl(Socket, F_SETFL, fcntl(Socket, F_GETFL) | O_NONBLOCK);
#endif

我需要 TODO 下的等效内容：

// reuse address

m_Socket.set_option( boost::asio::socket_base::reuse_address( true ) );

// TODO: set non blocking

// listen

m_Socket.listen( );

非常感谢！

Answer 1

使用async_accept。

Answer 2

由于我实际上正在重构旧的 C++ 代码，accept() 函数（如果可以设置为非阻塞）将非常适合。我试图避免异步函数，因为整个概念对我来说并不熟悉：

tcp::socket *CTCPServer :: AsyncAccept( )
{
  tcp::socket *Socket = new tcp::socket( *m_Service );
  m_Socket.async_accept( *Socket, endpoint, boost::bind( &CTCPServer::HandleAccept, this ) );

  return Socket;
}

这样的事情可能吗（它通过accept()成功了）？基本上我有一个 CTCPServer 类来监听，如果建立了连接，我会创建一个 CTCPSocket( io_service *, socket * )，它会因“错误文件描述符”而失败（这不是 io_service 中的问题）。

我的测试主要：

tcp::socket *Socket;
CTCPServer Server( &io_service, 6667 );

while( true )
{
  if( ( Socket = Server.AsyncAccept( ) ) )
  {
    CTCPSocket TCPSocket( &io_service, Socket ); // fails
    TCPSocket.PutBytes( "stack overflow" );
    TCPSocket.DoSend( );
   }
}

告诉我您是否需要更多（如果我可以称之为）源代码。