溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

Boost asio 同步連接超時設(shè)置失敗

發(fā)布時間:2020-07-28 20:00:46 來源:網(wǎng)絡(luò) 閱讀:1800 作者:fengyuzaitu 欄目:編程語言

場景

        boost庫中的asio模塊,在阻塞模式下,調(diào)用connect進(jìn)行服務(wù)器的連接,如果服務(wù)器沒有打開,默認(rèn)情況下需要20秒的超時連接,才會返回。目前嘗試設(shè)置套接字的連接超時時間,都不奏效。估計只能修改boost源碼中的超時時間

//設(shè)置成非阻塞,然后調(diào)用select等待超時,無效
int TestBoostAsioConnectTimeout()
{
 boost::asio::io_service ios;
 boost::asio::ip::tcp::socket sock(ios);
 boost::system::error_code ec;

 sock.open(boost::asio::ip::tcp::v4());
 // 設(shè)為非阻塞 
 sock.io_control(boost::asio::ip::tcp::socket::non_blocking_io(true));
 sock.connect(
  boost::asio::ip::tcp::endpoint(
   boost::asio::ip::address::from_string("192.168.1.1"), 80)
  , ec);
 fd_set fdWrite;
 FD_ZERO(&fdWrite);
 FD_SET(sock.native(), &fdWrite);
 timeval tv = { 5 };    // 5秒超時 
 if (select(0, NULL, &fdWrite, NULL, &tv) <= 0
  || !FD_ISSET(sock.native(), &fdWrite))
 {
  std::cout << "連接超時" << std::endl;
  sock.close();
  return 0;
 }
 // 設(shè)回阻塞 
 sock.io_control(boost::asio::ip::tcp::socket::non_blocking_io(false));
 std::cout << "連接成功" << std::endl;
 sock.close();

 return 0;
}

//獲取原始的套接字,進(jìn)行屬性的設(shè)置

int TestBoostAsioConnectOverTime()
{
 boost::asio::io_service ios;
 boost::asio::ip::tcp::socket sock(ios);
 boost::system::error_code ec;

 sock.open(boost::asio::ip::tcp::v4());
 // 設(shè)為非阻塞 
 sock.io_control(boost::asio::ip::tcp::socket::non_blocking_io(true));
 int timeout = 3000;
 int nRet = setsockopt(sock.native(), SOL_SOCKET, SO_CONNECT_TIME, (const char*)&timeout, sizeof(timeout));
 nRet = setsockopt(sock.native(), SOL_SOCKET, SO_RCVTIMEO, (const char*)&timeout, sizeof(timeout));
 sock.connect(
  boost::asio::ip::tcp::endpoint(
   boost::asio::ip::address::from_string("192.168.1.1"), 80)
  , ec);
 fd_set fdWrite;
 FD_ZERO(&fdWrite);
 FD_SET(sock.native(), &fdWrite);
 timeval tv;
 tv.tv_sec = 1;   // 5秒超時
 tv.tv_usec = 0;
 if (select(0, NULL, &fdWrite, NULL, &tv) <= 0
  || !FD_ISSET(sock.native(), &fdWrite))
 {
  std::cout << "超時/出錯啦" << std::endl;
  sock.close();
  return 0;
 }
 // 設(shè)回阻塞 
 sock.io_control(boost::asio::ip::tcp::socket::non_blocking_io(false));
 std::cout << "連接成功" << std::endl;
 sock.close();

 return 0;
}


設(shè)置超時的代碼:
windows:
 int nTvlen=1000;  //1s
 int retOpt=setsockopt(m_Socket,SOL_SOCKET, SO_RCVTIMEO, (const char*)&nTvlen,sizeof(nTvlen));
linux:
 struct timeval nTvlen={1,0}; //1S
 int retOpt=setsockopt(m_Socket,SOL_SOCKET, SO_RCVTIMEO, (const char*)&nTvlen,sizeof(nTvlen));




向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI