2

我有一个服务器类，它将启动两个线程，一个是接受所有传入的连接并将这些套接字放入一个向量中。另一种是扫描这个套接字向量，找出哪个被读为读/写，然后做一些事情。

所以问题是在第二个线程（成员函数）中，我如何实际扫描这些套接字？

人们建议使用 unix socket 的 select() 但我决定在任何地方都使用 boost，所以我正在寻找 boost 中的解决方案。

我已经阅读了 boost.org 和这个站点的一些文档。人们说 io_service 是 select 的抽象。我不明白。我只是绑定函数/对象然后使用 io_service::post() 将它们放入队列并使用 io_service::run() 执行吗？

更新，在我的理解中，每次你使用包含 io_service 对象的构造函数实例化一个新的套接字对象时，这个套接字对象都会与 io_service 对象相关联，因为我只有一个 io_service 对象，所以当我调用 io_service 时会执行这些套接字对象。跑（）

但是，问题是，我如何将handle_function分配给那些套接字，我看到人们像这样使用acceptor.async_accept(socket, boost::bind(handler, &socket))，但我想使用accept而不是async_accept()，但是 accept() 函数不能用于将处理函数绑定到此套接字

我该怎么办？ 

class Server
{
  io_service IOService;

  std::vector<boost::....::socket> SocketVector;

  listen()

  {
    //blockingly accept all incoming connection and bind socket with handler function;
  }

  process HandleRequest()
  {
    //io_service.run()
  } 
}

int main()
{
    Server myServer;
    boost::thread thread1(&Server::listen, &myServer);
    boost::thread thread2(&Server::HandleRequest, &myServer);
}
4

1 回答 1

0

您的设计听起来过于复杂，可能无法与 Boost Asio 很好地集成。是的，您可以为每个套接字使用一个线程，但是当有多个并发连接时，它很快就会分崩离析。

我建议重新考虑您的设计并将其基于异步操作。研究asio 文档中包含的示例。标签中也有大量信息。

于 2013-04-13T16:08:22.223 回答