c++ - 无法重新连接 boost asio 套接字客户端

Question

我正在使用 boost::asio::io_service 来管理一些异步 TCP 通信。asio 版本是boost::asio 1.46. 当服务器出现故障时，我想让客户端重新连接到服务器。

代码如下：

tot_client::tot_client(boost::asio::io_service& io_service,
                   tcp::resolver::iterator endpoint_iterator)
: io_service_(io_service),
socket_(io_service)
{
    boost::shared_ptr<tcp::socket> ptr_temp(new tcp::socket(io_service));
    socket_ptr =ptr_temp;
    socket_ptr->async_connect(tcp::endpoint(boost::asio::ip::address_v4::loopback(),2012),
                              boost::bind(&tot_client::handle_connect, this,
                                          boost::asio::placeholders::error));


   } 

如果服务器关闭，我的客户端会检查套接字是否打开。如果套接字未打开，它会尝试重新连接到服务器：

if(socket_ptr.use_count()&&socket_ptr->is_open())

{
   //...
} else 
{
    reconnect ();
}

重新连接代码在这里：

void tot_client::reconnect()
{
    try
    {
        std::cout<<" socket_ptr.reset(new tcp::socket(io_service_) ); "<<endl;
        socket_ptr.reset(new tcp::socket(io_service_) );
        //socket_ptr->connect(tcp::endpoint(boost::asio::ip::address_v4::loopback(),2012));
        socket_ptr->async_connect(tcp::endpoint(boost::asio::ip::address_v4::loopback(),2012),
                              boost::bind(&tot_client::handle_connect, this,
                                          boost::asio::placeholders::error));
    }
    catch (std::exception& e )
    {
        std::cerr<<e.what()<<endl;
    }

}

插座async_connect不工作！如果我直接使用connect方法，服务器可以接收套接字，但是io_service客户端中的无论如何都不起作用。

有人可以告诉我重新连接到服务器的正确方法吗？非常感谢！

Answer 1

您确定 io_service 仍在运行吗？

如果 io_service 在工作结束后停止工作，您需要调用

io_service.reset();
io_service.run();