Как я могу повторно подключить boost:: socket после отключения?

Ответ 1

Вам нужно создать новый boost::asio::ip::tcp::socket при каждом повторном подключении. Самый простой способ сделать это, вероятно, просто выделить сокет в куче, используя boost::shared_ptr (вы, возможно, также можете уйти с scoped_ptr, если ваш сокет полностью инкапсулирован в класс). Например:.

bool MyClient::myconnect()
{
    bool isConnected = false;

    // Attempt connection
    // socket is of type boost::shared_ptr<boost::asio::ip::tcp::socket>
    socket.reset(new boost::asio::ip::tcp::socket(...));
    socket->connect(server_endpoint, errorcode);
    // ...
}

Затем, когда вызывается mydisconnect, вы можете освободить сокет:

void MyClient::mydisconnect(void)
{
    // ...
    // deallocate socket.  will close any open descriptors
    socket.reset();
}

Ошибка, которую вы видите, вероятно, является результатом того, что ОС очистит дескриптор файла после того, как вы вызвали close. Когда вы вызываете close, а затем пытаетесь выполнить connect в том же сокете, вероятно, вы пытаетесь подключить неверный дескриптор файла. На этом этапе вы увидите сообщение об ошибке, начинающееся с "Connection failed:..." на основе вашей логики, но затем вы вызываете mydisconnect, который, вероятно, затем пытается вызвать shutdown в недопустимом дескрипторе файла. Порочный цикл!

Ответ 2

Для ясности здесь используется заключительный подход, который я использовал (но это основано на ответе bjlaub, поэтому, пожалуйста, дайте ему какие-либо варианты):

Я объявил элемент socket как scoped_ptr:

boost::scoped_ptr<boost::asio::ip::tcp::socket> socket;

Затем я изменил свой метод connect следующим образом:

bool MyClient::myconnect()
{
    bool isConnected = false;

    // Create new socket (old one is destroyed automatically)
    socket.reset(new boost::asio::ip::tcp::socket(io_service));

    // Attempt connection
    socket->connect(server_endpoint, errorcode);

    if (errorcode)
    {
        cerr << "Connection failed: " << errorcode.message() << endl;
        socket->close();
    }
    else
    {
        isConnected = true;

        // Connected so setup async read for an incoming message.
        startReadMessage();

        // And start the io_service_thread
        io_service_thread = new boost::thread(
            boost::bind(&MyClient::runIOService, this, boost::ref(io_service)));
    }
    return (isConnected)
}

Ответ 3

Я сделал что-то подобное, используя Boost.Asio в прошлом. Я использую асинхронные методы, поэтому повторное подключение обычно позволяет моему существующему объекту ip:: tcp:: socket выйти из области видимости, а затем создать новый для вызовов async_connect. Если async_connect терпит неудачу, я использую таймер, чтобы немного поспать, а затем повторить попытку.

Ответ 4

Я пробовал использовать метод close() и метод shutdown, и для меня это просто сложно. Close() может выдать ошибку, которую вам нужно поймать, и является грубым способом делать то, что вы хотите:) и shutdown(), кажется, лучше, но на многопоточном программном обеспечении, я считаю, что это может быть суетливо. Так что лучший способ, как сказал Сэм, позволить ему выйти из сферы действия. Если сокет является членом класса, вы можете: 1) перепроектировать так, чтобы класс использовал объект "соединение", чтобы обернуть сокет и позволить ему выйти из области видимости или 2) обернуть его в интеллектуальный указатель и reset умный указатель. Если вы используете boost, в том числе shared_ptr, это дешево и работает как шарм. Никогда не было проблемы с очисткой сокета, делающей это с помощью shared_ptr. Только мой опыт.