0

这是我的boost::asio服务器

class Server: public boost::enable_shared_from_this<Server>, private boost::noncopyable{
  private:
    boost::asio::ip::tcp::acceptor _acceptor;
    boost::asio::ip::tcp::socket   _socket;
  public:
    explicit Server(boost::asio::io_service& ios, boost::asio::ip::tcp::endpoint& endpoint):_acceptor(ios, endpoint), _socket(ios){

    }
    void start(){
       accept();
    }
    void accept(){
       std::cout << "accepting " << std::endl;;
      _acceptor.async_accept(_socket, boost::bind(&Server::handler, this, boost::asio::placeholders::error));
    }
    void handler(const boost::system::error_code &ec){
       const std::string message = "HTTP/1.1 200 OK\r\nContent-Length: 13\r\n\r\nHello, world!";
       if(!ec){
         boost::asio::async_write(_socket, boost::asio::buffer(message), boost::bind(&Server::write_handler, this));
       }else{
         std::cout << ec << std::endl;
       }
       accept();
    }
    void write_handler(){

    }
    boost::asio::ip::tcp::socket& socket(){
      return _socket;
    }
};


int main(){
  boost::asio::io_service ios;
  const unsigned int port = 5050;
  boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::tcp::v4(), port);

  Server server(ios, endpoint);
  server.start();

  ios.run();
  return 0;
}

它第一次以“你好世界”回应；然后它只是在accept<-->handler循环中循环并且不写欢迎消息。ec印刷

asio.misc:1
accepting 
asio.misc:1
accepting 
asio.misc:1
accepting 
asio.misc:1
accepting 
asio.misc:1
accepting 
asio.misc:1
accepting 
......

并且永不停止

4

1 回答 1

4

无限循环是_socket被使用的结果。第一个async_accept()有效，因为_socket未使用。但是，永远不会关闭，因此对with的_socket其他调用将失败。的peer参数预计套接字未在使用中，因为它将使用套接字进行新连接。这可以通过以下任一方式解决：async_accept()_socketasync_accept()

  • 为每个连接分配一个新的套接字。考虑通过boost::shared_ptr. 这允许服务器处理多个并发连接。
  • 关闭_socketin write_handler，然后调用accept(). 这将服务器一次限制为一个连接。

另外，要小心async_write(). 底层缓冲存储器的所有权由调用者保留，调用者必须保证它在调用处理程序之前保持有效。在这种情况下，message将在调用之前从堆栈中弹出write_handler()。随着message存在const，考虑使其static保证其持续时间。

在将对象传递给调用的实例时使用shared_from_this()而不是。否则，可能会删除 指向的实例，因为引用计数仅在使用时正确发生。thisbindthisshared_from_this()

最后，在打印时boost::system::error_code，使用error_code.message()方法得到更有意义的消息。在无限循环的情况下，它会打印“已经打开”。

这是一次支持一个连接的修改handler()和write_handler()代码：

void accept(){
   std::cout << "accepting " << std::endl;;
  _acceptor.async_accept(_socket, boost::bind(&Server::handler, shared_from_this(), boost::asio::placeholders::error));
}
void handler(const boost::system::error_code &ec){
   // Guarantee message will remain valid throughout the duration of async_write.
   static const std::string message = "HTTP/1.1 200 OK\r\nContent-Length: 13\r\n\r\nHello, world!";
   if(!ec){
     // write_handler will accept the next connection once it is done with the socket.
     boost::asio::async_write(_socket, boost::asio::buffer(message), boost::bind(&Server::write_handler, shared_from_this()));
   }else{
     std::cout << ec.message() << std::endl;
     // Try accepting on error.
     accept();
   }
}
void write_handler(){
   _socket.close();
   // Now that the socket is closed, new connectiosn can be accepted.
   accept();
}
于 2012-06-13T13:06:13.180 回答