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

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

CSDN上求助无果,只好用自创的非主流方法了。
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. }

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

时间: 2024-12-11 15:41:27

boost::asio设置同步连接超时的相关文章

boost asio库 同步socket连接示例

<pre name="code" class="cpp">/////////////////////////////////////// // Asio同步socket连接示例 // #include <iostream> #include <boost/thread.hpp> #include <boost/asio/io_service.hpp> #include <boost/asio.hpp> us

使用Boost asio实现同步的TCP/IP通信

可以先了解一下Boost asio基本概念,以下是Boost asio实现的同步TCP/IP通信: 服务器程序部分,如果想保留套接字之后继续通信,可以动态申请socket_type,保存指针,因为socket_type貌似不能拷贝: #include "stdafx.h" #include <iostream> #include <boost/asio.hpp> using namespace boost::asio; using namespace std;

boost::asio::socket tcp 连接 在程序结束时崩溃。

刚开始的时候一直不知道怎么回事,不过幸好我有在每个class 的析构时都打印一条信息. 这个时候发现我的一个tcp_connection (就是自定义的一个连接类) 在最后才被析构. 所以感觉这里可能出了问题. 由于tcp_connection 是派生自boost::enable_shared_from_this<tcp_connection> 的,猜想可能是需要提前释放某些资源,而不导致io_service 这个资源释放的时候某些数据不对.所以我就在socket 调用close() 之后将这

boost asio学习笔记 [1] - 同步通讯

本文以一段示例代码,说明使用boost asio进行同步通讯的使用方法. #include <iostream> #include <boost/asio.hpp> using namespace std; using boost::asio::ip::tcp;  int main() {     boost::asio::io_service   ioservice;             // I/O事件模型封装,如win下的iocp,unix下的poll, linux下的e

Boost.Asio入门(CSDN也有Markdown了,好开森)

Boost.Asio入门 首先,让我们先来了解一下什么是 Boost.Asio?怎么编译它?了解的过程中我们会给出一些例子.然后在发现 Boost.Asio 不仅仅是一个网络库的同时你也会接触到 Boost.Asio 中最核心的类--io_service. 什么是Boost.Asio 简单来说,Boost.Asio是一个跨平台的.主要用于网络和其他一些底层输入/输出编程的 C++ 库. 网络 API 的设计方式有很多种,但是 Boost.Asio 的的方式远远优于其它的设计方式.它在 2005

Boost.Asio c++ 网络编程翻译(20)

异步服务端 这个图表是相当复杂的:从Boost.Asio出来你可以看到4个箭头指向on_accept,on_read,on_write和on_check_ping.着也就意味着你永远不知道哪个异步调用是下一个完成的调用,但是你可以确定的是它是这4个操作中的一个. 现在,我们是异步的了:我们可以继续保持单线程.接受客户端连接是最简单的部分,如下所示: ip::tcp::acceptor acceptor(service, ip::tcp::endpoint(ip::tcp::v4(), 8001)

Boost.Asio c++ 网络编程翻译(5)

异常处理VS错误代码 Boost.Asio允许同时使用异常处理或者错误代码,所有的异步函数都有抛出错误和返回错误码两种方式的重载.当函数抛出错误时,它经常抛出boost::system::system_error的错误. using boost::asio; ip::tcp::endpoint ep; ip::tcp::socket sock(service); sock.connect(ep); // Line 1 boost::system::error_code err; sock.con

boost::asio::io_service 超时设置

class client{public:  /*client(const udp::endpoint& listen_endpoint)    : socket_(io_service_, listen_endpoint),      deadline_(io_service_)  {    deadline_.expires_at(boost::posix_time::pos_infin);    check_deadline();  } std::size_t receive(const b

boost::asio 连接管理11 如何关闭连接

在实际产品运行中,对连接管理有了更新的认识,这里分享一下. shared_ptr管理连接对象的生命周期 shared_ptr的引用计数器决定了连接对象的生命周期.这里我说的连接对象就是在我的前文:http://blog.csdn.net/csfreebird/article/details/8522620 中的Client对象: [cpp] view plaincopyprint? #include "core/connection.h" #include <vector>