C++ WebSocket服务器不创建线程实现空闲循环系统方案咨询

1 替代阻塞accept的非阻塞接口 #

你使用的Boost.Asio库原生提供async_accept异步接受连接接口，完全不需要阻塞等待连接进入，仅当有新连接就绪时才会触发预先注册的回调函数，不会卡住主逻辑。

如果硬要在自定义循环里用非阻塞模式调用accept，可以先设置acceptor为非阻塞模式：

acceptor.non_blocking(true);

之后调用accept时如果没有待处理的连接会立即返回错误（取决于所用的重载版本），不会阻塞线程。但这种方案需要自行处理循环间隙的CPU占用控制，容易出现空转耗资源或者响应延迟的问题，不推荐。

2 单线程无多线程代码的实现方案 #

完全不需要自己手写无限循环，Boost.Asio自带成熟的事件驱动循环io_context::run()，单线程调用这个接口即可处理所有IO事件，全程不需要任何多线程相关代码，也不会有线程同步问题。
基于Boost.Beast（官方WebSocket实现）的单线程服务最小示例逻辑如下：

#include <boost/asio.hpp>
#include <boost/beast.hpp>
#include <iostream>
#include <functional>

namespace asio = boost::asio;
namespace beast = boost::beast;
namespace http = beast::http;
namespace websocket = beast::websocket;
using tcp = asio::ip::tcp;

int main() {
    // 1表示单线程运行，不需要多线程调度
    asio::io_context ioc{1};
    tcp::acceptor acceptor{ioc, tcp::endpoint{tcp::v4(), 8080}};

    // 定义接受连接的回调函数
    std::function<void()> do_accept = [&]() {
        acceptor.async_accept([&](boost::system::error_code ec, tcp::socket socket) {
            if (!ec) {
                // 新连接建立，创建WebSocket会话
                auto ws = std::make_shared<websocket::stream<tcp::socket>>(std::move(socket));
                ws->set_option(websocket::stream_base::timeout::suggested(beast::role_type::server));
                // 异步执行WebSocket握手
                ws->async_accept([ws](boost::system::error_code ec) {
                    if (!ec) {
                        // 握手成功后注册异步读、写逻辑，所有操作都挂在ioc上
                        // 示例：异步等待客户端消息
                        auto buf = std::make_shared<beast::flat_buffer>();
                        ws->async_read(*buf, [ws, buf](boost::system::error_code ec, std::size_t) {
                            if (!ec) {
                                // 收到消息后原路返回（echo逻辑）
                                ws->async_write(buf->data(), [ws, buf](boost::system::error_code, std::size_t) {});
                            }
                        });
                    }
                });
            }
            // 继续接受下一个连接
            do_accept();
        });
    };

    // 发起第一个接受连接的异步请求
    do_accept();

    // 单线程运行事件循环，全程没有多线程代码
    ioc.run();
    return 0;
}

上述实现全程在单线程内运行，没有任何多线程相关代码，ioc.run()会自动处理所有IO事件，没有事件时会挂起等待，不会空转占用CPU，完全满足你的需求。

3 更合理的实现思路 #

推荐直接使用Boost.Asio原生的异步事件驱动模型，不要自行手写无限循环：

• 所有IO操作都使用async_前缀的异步接口，事件就绪后自动触发回调，逻辑串行执行，完全没有线程竞争问题
• io_context::run()已经做了高度优化，空闲时不占用CPU，响应延迟极低
• 后续如果需要扩展性能，只需要加少量代码启动多个线程调用ioc.run()即可，不需要重构核心逻辑

内容的提问来源于stack exchange，提问作者Arslan Gök Türk