Boost-Asio,多线程tcp服务器

Question

关于boost-asio多线程程序,我无法成功.

由于没有任何关于此的好例子或文档,我希望得到你的帮助:)

简单地说,我认为这段代码可以监听,但是当我想要"缓存"缓冲数据时,它不会打印任何内容或者只听一次并停止.

我的代码是:

void Worker::startThread(int clientNumber) {
     cout << "listening: "<< clients[clientNumber]->port << endl;
     boost::asio::io_service io_service;
     tcp::acceptor acc(io_service, tcp::endpoint(tcp::v4(),portNumber[clientNumber]));
     socket_ptr sock(new tcp::socket(io_service));
     acc.accept(*sock);
     try
     {
     for (;;) {
        char data[max_length];
        boost::system::error_code error;
         cout << "message?" << endl;
        size_t length = sock->read_some(boost::asio::buffer(data), error);
         cout << "message :)" << endl;
        cout << data << endl;
        if(error == boost::asio::error::eof)
            break; // Connection closed cleanly by peer.
        else if (error)
            throw boost::system::system_error(error); // Some other error.

     }
     }
     catch (std::exception& e)
     {
         std::cerr << "Exception in thread: " << e.what() << "\n";
     }
}
void Worker::start() {
     cout << "Starting thread server" << endl;
     for(int i=0; i<clients.size(); i++) {
         boost::thread t(boost::bind(&Worker::startThread, this, i));
     }

     for(;;);
}

Answer 1

如果您没有看到多线程示例,则很长时间没有查看文档

HTTP服务器3

使用单个io_service和调用io_service :: run()的线程池的HTTP服务器.

HTTP服务器2

使用io_service-per-CPU设计的HTTP服务器.

请记住,这些示例使用异步方法,这是Boost.Asio库真正发挥作用的地方.