boost::asio设置同步连接超时

时间:2023-03-08 18:15:35

boost::asio设置同步连接超时

****上求助无果,只好用自创的非主流方法了。
asio自带的例子里是用deadline_timer的async_wait方法来实现超时的,这种方法需要单独写一个回调函数,不利于把连接和超时封装到单个函数里。传统的Winsock编程可以先把socket设为非阻塞,然后connect,再用select来判断超时,asio也可以这样做,唯一“非主流”的是asio里没有一个类似select的函数,所以得调用原始的Winsock API,也就牺牲了跨平台:

  1. #include <iostream>
  2. #include <boost/asio.hpp>
  3. int main()
  4. {
  5. boost::asio::io_service ios;
  6. boost::asio::ip::tcp::socket s(ios);
  7. boost::system::error_code ec;
  8. s.open(boost::asio::ip::tcp::v4());
  9. // 设为非阻塞
  10. s.io_control(boost::asio::ip::tcp::socket::non_blocking_io(true));
  11. // connect时必须指定error_code参数,否则会有异常抛出
  12. s.connect(
  13. boost::asio::ip::tcp::endpoint(
  14. boost::asio::ip::address::from_string("192.168.1.1"), 80)
  15. , ec);
  16. fd_set fdWrite;
  17. FD_ZERO(&fdWrite);
  18. FD_SET(s.native(), &fdWrite);
  19. timeval tv = {5};    // 5秒超时
  20. if (select(0, NULL, &fdWrite, NULL, &tv) <= 0
  21. || !FD_ISSET(s.native(), &fdWrite))
  22. {
  23. std::cout << "超时/出错啦" << std::endl;
  24. s.close();
  25. return 0;
  26. }
  27. // 设回阻塞
  28. s.io_control(boost::asio::ip::tcp::socket::non_blocking_io(false));
  29. std::cout << "连接成功" << std::endl;
  30. s.close();
  31. return 0;
  32. }