boost :: asio无限循环系统：首次连接后出现9错误

I have an Server, using asio with the following code, 100% copied from the examples. The code behaves well when there are no connections. however, as soon as the first client connects, handle accept starts to output vast amounts of system:9 errors and I am unable to connect any other clients. The single client that is connected can perform async read/writes just fine. I'm at a loss at what I'm doing incorrectly. I've tried the code with and without io_service in a thread pool with the same results.

我有一个服务器，使用带有以下代码的asio，100％从示例中复制。没有连接时，代码表现良好。但是，只要第一个客户端连接，句柄接受开始输出大量系统：9个错误，我无法连接任何其他客户端。连接的单个客户端可以正常执行异步读/写。我不知道我做错了什么。我已经在线程池中使用和不使用io_service尝试了具有相同结果的代码。

Server::Server(io_service& io_service,
      const std::string address,
      const std::string port)
    : io_service_(io_service),
    //zmq_strand_(io_service),
      acceptor_(io_service) {

    ip::tcp::resolver resolver(io_service_);
    ip::tcp::resolver::query query(address, port);
    ip::tcp::endpoint endpoint = *resolver.resolve(query);
    acceptor_.open(endpoint.protocol());
    acceptor_.set_option(ip::tcp::acceptor::reuse_address(true));
    acceptor_.bind(endpoint);
    acceptor_.listen(); 
    start_accept();
  }

void Server::start_accept() {
    auto session = std::shared_ptr<Session>(new Session(io_service_,session_manager_));

    acceptor_.async_accept(session->socket()
        ,std::bind(&Server::handle_accept,this,session,std::placeholders::_1));
}

void Server::handle_accept(std::shared_ptr<Session> session, const system::error_code& error) {
  if (!error) {
    std::cout << "handle_accept" << std::endl;
    session->start();
  } else {
      std::cout << error << std::endl;
  }
  start_accept();
}

small update: Instead of using the http3 example I used the example Denis proposed. It's less convoluted and made the server behave correctly. I haven't found a rational explanation to why the previous piece of code doesn't work. This does:

小更新：我没有使用http3示例，而是使用了Denis提出的示例。它不那么复杂，使服务器行为正常。我没有找到理由解释为什么前一段代码不起作用。这样做：

Server::Server(
      io_service &service,
      const uint8_t num_threads,
      const std::string address,
      const uint16_t port)
    : 
      num_threads_(num_threads),
    //zmq_strand_(io_service),
      acceptor_(service,ip::tcp::endpoint(ip::tcp::v4(),port)) {

    //io_service::work work(io_service_);
    start_accept();
  }


void Server::start_accept() {
    auto session = std::shared_ptr<Session>(new Session(acceptor_.get_io_service(),session_manager_));

    acceptor_.async_accept(session->socket()
        ,std::bind(&Server::handle_accept,this,session,std::placeholders::_1));
}

void Server::handle_accept(std::shared_ptr<Session> session, const system::error_code& error) {
  if (!error) {
    std::cout << "handle_accept" << std::endl;
    session->start();
  }
  start_accept();
}

void Server::start() {
    std::set<std::unique_ptr<std::thread>> threads;

    for( unsigned int i = 0; i < num_threads_; ++i ) {
        threads.insert(std::unique_ptr<std::thread>(new std::thread( [&]() {
            acceptor_.get_io_service().run();
            }) 
        ));
    }
    std::cout << threads.size() << " threads started" << std::endl;
    for(auto &t:threads) {
        t->join();
    }
    std::cout << threads.size() << " threads joined" << std::endl;
}

1 个解决方案

#1

Look precisely at this tutorial and compare your code with tutorial: Boost TCP async server example

仔细查看本教程并将您的代码与教程进行比较：Boost TCP异步服务器示例