c++ - boost websocket 和 io_context 的可重用性以重新建立连接

Question

我在 中使用 boost::beast::websocket 和 boost::asio::io_context 编写了一个小型 websocket 客户端>C++。我有一个具有以下状态的状态机:

enum class State {
    GDR_PROVISING,
    WEBSOCKET_HANDSHAKE,
    REGISTRATION,
    READY,
    CLEANUP,
};

如果代码无法建立连接或建立连接后失败(可能原因:Internet down、Service down、Server 发送关闭帧)，则状态机转向CLEANUP 状态并且应该进行清理。

我不确定我是否可以重用相同的 io_context 和 websocket::stream。目前，我的 io_context 仅在这个单线程中使用。我计划使用 websockets 和 io_context 的 pointers 并在 CLEANUP 中删除它们并在 GDR_PROVISING 中再次分配它们。

我可以使用相同的 websocket 和 io_context 实例来重新建立与服务器的连接吗？可能我需要调用一些成员函数，例如 stop 或 reset？

我的 READY 现在看起来像这样:

    case State::READY:
    {
        // TODO: Send the Message from the vector
        {
            std::lock_guard<std::mutex> msgGaurd(msgMutex_);
            for (const auto& m: sendMsgQueue_) {
                boost::system::error_code ec;
                pWebStream_->write(boost::asio::buffer(m.toString()), ec);
            }
        }
        // Call io_context run_until to process read messages async because there is no way for non-blocking read in boost for websockets!
        pIoc_->run_until(std::chrono::steady_clock::now() + /* TODO: Add some time_point */);
        break;
    }

    case State::CLEANUP:
    {
        // TODO: Verify if we should delete the stream!
        if (pWebStream_)
            delete pWebStream_;
        if (pIoc_)
            delete pIoc_;
        pWebStream_ = nullptr;
        pIoc_ = nullptr;
        state_ = State::GDR_PROVISING;
        break;
    }

Answer 1

您可以照常重用 io_context。 run 调用不会终止，除非当它尝试执行另一个事件循环迭代时没有更多工作要做。

您还可以使用 get_lowest_layer(*pWebStream_).close() 重用套接字，使用 get_lowest_layer(*pWebStream_).open() 重新打开它，然后调用 async_connect 正常。但是，我认为通过像您一样完全重置对象，您的代码会更清晰。

如果您确实想要重置套接字，我强烈建议您尝试使用 std::optional。它不进行堆分配，您不必担心内存泄漏。