如何判断tcp::acceptor已就绪？HTTP服务器就绪后立即发请求方案

方法一：确认Acceptor的监听状态 #

tcp::acceptor构造并绑定端点后就处于监听状态，你可以通过is_open()先确认它已成功启动监听，再继续后续操作：

boost::asio::io_context io_context;
tcp::acceptor acceptor(io_context, tcp::endpoint(tcp::v4(), 8080));
// 生产环境可替换为实际错误处理逻辑
assert(acceptor.is_open());

// 注册异步接受连接的回调
acceptor.async_accept([](boost::system::error_code ec, tcp::socket socket) {
    if (!ec) {
        // 处理新连接的业务逻辑
    }
});

auto server_thread = std::jthread([&io_context] { io_context.run(); });

// 此时服务器已处于监听状态，可发送请求
sendHTTPRequests();

不过这种方式仅能确认acceptor的监听状态，无法保证async_accept已被io_context的事件循环处理。

方法二：用Promise/Future做同步屏障 #

要确保io_context事件循环已启动并开始处理任务，用std::promise和std::future做同步是最可靠的方案：

boost::asio::io_context io_context;
tcp::acceptor acceptor(io_context, tcp::endpoint(tcp::v4(), 8080));

std::promise<void> server_ready;
auto ready_future = server_ready.get_future();

// 将就绪信号任务提交到io_context，确保事件循环启动后才触发
boost::asio::post(io_context, [&server_ready]() {
    server_ready.set_value();
});

acceptor.async_accept([](boost::system::error_code ec, tcp::socket socket) {
    if (!ec) {
        // 处理新连接逻辑
    }
});

auto server_thread = std::jthread([&io_context] {
    io_context.run();
});

// 等待就绪信号，返回时说明事件循环已正常运行
ready_future.get();

sendHTTPRequests();

当ready_future.get()返回时，io_context已启动并处理了我们提交的就绪任务，此时async_accept也已注册到事件循环，服务器完全就绪。

方法三：重试连接直到成功（容错方案） #

如果不需要严格同步，仅需确保服务器能处理请求，可以在发送请求前尝试连接服务器，直到成功：

void wait_for_server(boost::asio::io_context& io_context, const tcp::endpoint& endpoint) {
    tcp::socket socket(io_context);
    boost::system::error_code ec;
    do {
        socket.connect(endpoint, ec);
        if (!ec) break;
        // 连接失败后短暂休眠再重试
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
        socket.close();
    } while (true);
}

// 使用示例
boost::asio::io_context io_context;
tcp::endpoint server_endpoint(tcp::v4(), 8080);
tcp::acceptor acceptor(io_context, server_endpoint);

acceptor.async_accept([](boost::system::error_code ec, tcp::socket socket) {
    if (!ec) {
        // 处理新连接逻辑
    }
});

auto server_thread = std::jthread([&io_context] { io_context.run(); });

// 等待服务器可连接后再发送请求
wait_for_server(io_context, server_endpoint);

sendHTTPRequests();

这种方法适合对启动延迟不敏感的场景，即使服务器启动有微小延迟，也能自动重试直到成功。

内容的提问来源于stack exchange，提问作者DuduArbel