C++如何通过SSE（Server-Sent Events）推送实时事件-C++-PHP中文网

C++需借助HTTP库实现SSE，因原生不支持；cpp-httplib是推荐方案，通过set_content_provider维持长连接并流式写入data:事件，须注意CORS、线程安全及HTTP头细节。

c++如何通过sse（server-sent events）推送实时事件

C++ 本身不原生支持 SSE，必须借助 HTTP 服务器库手动构造符合 SSE 规范的响应流。 直接用 std::cout 或裸 socket 发送 text/event-stream 响应极易出错——缺少 chunked 编码、缓冲干扰、连接保活失效等问题会立刻导致浏览器断连或事件丢失。

为什么不能直接用 Boost.Beast 或 libcurl 实现 SSE 推送

Boost.Beast 可以构建 HTTP 响应，但它的 http::response 默认使用固定 Content-Length，而 SSE 要求流式响应（无终止、持续写入）。若强行禁用 Content-Length 并开启 Transfer-Encoding: chunked，还需手动处理：

每个事件必须以 data: 开头，结尾用双换行 \n\n
每条消息前需写入 chunk size 十六进制 + \r\n，再写内容，最后加 \r\n
浏览器要求首次响应必须在 3 秒内到达，否则触发 error 事件
连接空闲时需定期发送注释行（: keep-alive\n\n）防超时

推荐方案：用 cpp-httplib 启动轻量 SSE 端点

cpp-httplib 支持流式响应且 API 直观。关键不是“推送”，而是维持一个长连接并持续调用 res.set_content_provider：

svr.Get("/events", [&](const auto& req, auto& res) {
    res.set_header("Content-Type", "text/event-stream");
    res.set_header("Cache-Control", "no-cache");
    res.set_header("Connection", "keep-alive");
<pre class="brush:php;toolbar:false;">res.set_content_provider(
    /* length */ 0,
    [&](size_t offset, size_t len, httplib::DataSink& sink) -> bool {
        if (offset == 0) {
            // 首次响应必须立即发，哪怕只是空 data
            sink.write("data: connected\n\n");
            return true;
        }

        // 实际业务：从队列/条件变量取事件
        std::string event = get_next_sse_event(); // 自定义逻辑
        if (!event.empty()) {
            sink.write("data: ");
            sink.write(event);
            sink.write("\n\n");
        }
        return true; // 返回 true 继续等待下一次调用
    },
    [](bool success) { /* 连接关闭回调 */ }
);

});

C++14

C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。

下载

注意：set_content_provider 的回调会在每次底层 socket 可写时被调用，不是主动推送——你要用线程+条件变量把事件“喂”进去，而非轮询。

常见崩溃与阻塞点

实际部署时最常卡在三处：

未设置 res.set_header("Access-Control-Allow-Origin", "*")，前端报 CORS 错误，但浏览器控制台只显示 Failed to fetch，不提示具体原因
在 content_provider 回调里执行耗时操作（如磁盘读、数据库查询），导致整个 HTTP worker 线程卡死，后续所有请求挂起
多线程往同一个 DataSink 写数据——DataSink::write 不是线程安全的，必须加锁或改用无锁队列中转

SSE 的本质是单向流，C++ 侧没有“推送 SDK”这种东西。你得自己管好连接生命周期、线程安全、HTTP 头细节和浏览器兼容性（比如 Safari 对重连间隔更敏感）。漏掉任意一环，前端就收不到 message 事件。