尧图网站建设 
后端网络【免费下载链接】cpp-httplibA C header-only HTTP/HTTPS server and client library项目地址https://gitcode.com/GitHub_Trending/cp/cpp-httplib点击查看免费下载本篇文章以 cpp-httplib 官方文档 README-stream.md 为核心系统讲解该库新增的Streaming API基于迭代器的stream::Get()/stream::Result高层接口以及直接操作 socket 的open_stream()/StreamHandle底层接口。读完本文你将掌握如何用极低内存代价逐块消费 HTTP 响应体落地 LLM 流式输出、SSEServer-Sent Events、大文件下载与反向代理等真实场景并理解这些 API 在 httplib.h 中的底层实现原理。一、什么是 cpp-httplib 流式 API传统上Client::Get()会等待整个响应体完整接收并缓冲到内存中这对小响应和 Keep-Alive 连接复用很友好但遇到超大文件或无限流式输出如大模型逐字生成时内存与首字节延迟都不可接受。cpp-httplib 为此提供了流式扩展数据直接从网络 socket 读取一次只保留当前一个数据块在内存中配合迭代器风格的循环逐块处理实现真正的 socket 级流式true socket-level streaming。流式 API 特别适用于以下几类场景LLM / AI 流式响应如 ChatGPT、Claude、Ollama 等以 JSON Lines 逐行输出的接口Server-Sent EventsSSE实时推送大文件下载及下载进度跟踪反向代理实现把上游响应体原样转发给下游。使用前请先记住三条重要约束无 Keep-Alive每次stream::Get()都会使用一条专用连接响应体读完后连接即关闭需要连接复用时请改用Client::Get()。只能迭代一次next()方法只能从头到尾遍历响应体一遍。Result 非线程安全stream::Get()可以在多个线程同时被调用但返回的stream::Result只能由单个线程使用。二、Quick Start第一个流式客户端在项目目录中引入头文件后即可用与Client::Get()几乎相同的写法发起流式请求#include httplib.h int main() { httplib::Client cli(http://localhost:8080); // Get streaming response auto result httplib::stream::Get(cli, /stream); if (result) { // Process response body in chunks while (result.next()) { std::cout.write(result.data(), result.size()); } } return 0; }核心循环是while (result.next())next()每次从 socket 读入一块数据并返回true读到流结束返回falseresult.data()指向当前块起始位置result.size()给出当前块字节数。整个过程中内存中只保留一个块配合std::cout.write()即可把响应原样输出。需要说明的是stream::Get只是open_stream(GET, ...)的便捷封装源码见 httplib.h默认块大小chunk_size 8192字节。除了 GETstream命名空间还提供Post/Put/Patch/Delete/Head/Options等对应方法均支持传Headers、Params与请求体见 httplib.h。三、API 分层从高层到低层四层接口cpp-httplib 针对不同使用诉求提供了四层 API从上到下抽象层级递减、控制粒度递增┌─────────────────────────────────────────────┐ │ SSEClient │ ← SSE-specific, parsed events │ - on_message(), on_event() │ │ - Auto-reconnect, Last-Event-ID │ ├─────────────────────────────────────────────┤ │ stream::Get() / stream::Result │ ← Iterator-based streaming │ - while (result.next()) { ... } │ ├─────────────────────────────────────────────┤ │ open_stream() / StreamHandle │ ← General-purpose streaming │ - handle.read(buf, len) │ ├─────────────────────────────────────────────┤ │ Client::Get() │ ← Traditional, full buffering └─────────────────────────────────────────────┘选择建议如下使用场景推荐 API需要自动重连的 SSESSEClient见 README-sse.mdLLM 流式输出JSON Linesstream::Get()大文件下载stream::Get()或open_stream()反向代理open_stream()小响应 Keep-AliveClient::Get()其中SSEClient命名空间sse实现于 httplib.h 起的SSEMessage/SSEClient会把流按 SSE 规范解析成带event/data/id字段的消息对象并内置自动重连与Last-Event-ID续传逻辑是 SSE 场景下的最高层选择。四、低层 API 参考StreamHandle 与 open_streamStreamHandle是流式 API 的底层句柄接管 socket 连接的所有权数据直接从网络读取。声明位于 httplib.h。// Open a stream (takes ownership of socket) httplib::Client cli(http://localhost:8080); auto handle cli.open_stream(GET, /path); // Check validity if (handle.is_valid()) { // Access response headers immediately int status handle.response-status; auto content_type handle.response-get_header_value(Content-Type); // Read body incrementally char buf[4096]; ssize_t n; while ((n handle.read(buf, sizeof(buf))) 0) { process(buf, n); } }注意使用open_stream()时连接专用于流式传输不支持 Keep-Alive需要连接复用的场景请改用client.Get()。StreamHandle 成员一览成员类型说明responsestd::unique_ptrResponse含响应头的 HTTP 响应对象errorError请求失败时的错误码is_valid()bool响应有效时返回 trueread(buf, len)ssize_t直接从 socket 读取最多len字节get_read_error()Error获取最近一次读错误has_read_error()bool检查是否发生读错误open_stream 的底层实现细节从 httplib.h 的ClientImpl::open_stream()实现可以看到它做了完整的事前准备目标编码与缓冲发送路径保持一致空Params时直接用path否则调用append_query_params()追加查询参数再经detail::encode_request_target()编码保证无论走哪个 API同样的path产生同样的请求行连接准备在socket_mutex_保护下检查现有 socket 是否存活is_socket_aliveSSL 下还会检查对端是否关闭失效则断开重建并通过setup_proxy_connection()处理代理所有权转移transfer_socket_ownership_to_handle()httplib.h把 socket 描述符及 SSL 会话从Client移交给StreamHandle客户端自身的socket_置为INVALID_SOCKET从此连接生命周期完全由句柄掌控请求写出先在内存BufferStream中组装请求行与请求头write_request_linecheck_and_write_headers校验通过后再一次性写入网络随后写入请求体若有避免被拒绝的头污染线上数据响应解析读取响应行与响应头并做与普通路径相同的 framing 检查HEAD、204、304 可合法携带无体 framing 头Content-Length冲突视为Error::Read传输语义识别根据响应头设置BodyReader的content_length/chunked标志is_chunked_transfer_encoding()判定分块传输并对Content-Encoding创建对应的解压器见下节。StreamHandle::read()在存在解压器时走read_with_decompression()路径httplib.h否则直接调用detail::read_body_content()按 Content-Length / chunked 语义读取当分块流读完后还会解析 trailerparse_trailers_if_needed()httplib.h。测试 test/test.cc 中的StreamHandleTest验证了is_valid()对response与error的组合判定逻辑。五、高层 API 参考stream::Get() 与 stream::Resultstream::Result是对StreamHandle的迭代器式封装声明于 httplib.h实现于 httplib.h使用起来更符合直觉#include httplib.h httplib::Client cli(http://localhost:8080); cli.set_follow_location(true); // ... // Simple GET auto result httplib::stream::Get(cli, /path); // GET with custom headers httplib::Headers headers {{Authorization, Bearer token}}; auto result httplib::stream::Get(cli, /path, headers); // Process the response if (result) { while (result.next()) { process(result.data(), result.size()); } } // Or read entire body at once auto result2 httplib::stream::Get(cli, /path); if (result2) { std::string body result2.read_all(); }stream::Result 成员一览成员类型说明operator bool()bool响应有效时返回 trueis_valid()bool与operator bool()等价status()intHTTP 状态码headers()const Headers响应头get_header_value(key, def)std::string获取响应头值可带默认值has_header(key)bool检查响应头是否存在next()bool读取下一块数据读完返回 falsedata()const char*当前块数据指针size()size_t当前块大小read_all()std::string把剩余响应体全部读入字符串error()Error获取连接/请求错误read_error()Error获取最近一次读错误has_read_error()bool检查是否发生读错误实现细节上next()httplib.h在句柄无效或已结束时直接返回false否则确保内部缓冲区不小于chunk_size_后调用handle_.read()n 0则更新current_size_并返回true读到 0 或负值时置finished_ true并返回false。read_all()不过是反复next()并把每块append到字符串——这解释了只能迭代一次的约束一旦读完finished_即被置位。此外stream::Result是**仅移动move-only**类型拷贝构造与拷贝赋值被删除移动构造/赋值可用httplib.h因此把它放入 lambda 捕获列表或返回时需使用std::move。六、实战示例示例 1SSEServer-Sent Events客户端用stream::Get()逐块读取并实时输出事件流每读一块立即flush#include httplib.h #include iostream int main() { httplib::Client cli(http://localhost:1234); auto result httplib::stream::Get(cli, /events); if (!result) { return 1; } while (result.next()) { std::cout.write(result.data(), result.size()); std::cout.flush(); } return 0; }需要自动重连、事件解析与Last-Event-ID续传的完整 SSE 客户端可参考仓库示例 example/ssecli-stream.cc它在主循环中不断调用httplib::stream::Get(cli, path, headers)连接失败或读错误后按retry_ms间隔重连并通过parse_sse_line()按 SSE 规范把缓冲内容切分成event/data/id/retry字段遇到空行即完成一个事件对 204/404/401/403 等永久性错误则直接退出不再重连。它还会校验Content-Type是否为text/event-stream并在流结束后用result.read_error()区分正常结束与连接中断。示例 2LLM 流式响应以本地 Ollama 服务的/api/generate为例逐块接收模型生成内容并在读取结束后检查错误#include httplib.h #include iostream int main() { httplib::Client cli(http://localhost:11434); // Ollama auto result httplib::stream::Get(cli, /api/generate); if (result result.status() 200) { while (result.next()) { std::cout.write(result.data(), result.size()); std::cout.flush(); } } // Check for connection errors if (result.read_error() ! httplib::Error::Success) { std::cerr Connection lost\n; } return 0; }result.status()在响应头到达后即可获得无需等待整个响应体配合read_error()可区分流正常结束与中途断开两种收尾形态。示例 3大文件下载与进度显示边读边写磁盘并用累计字节数输出进度#include httplib.h #include fstream #include iostream int main() { httplib::Client cli(http://example.com); auto result httplib::stream::Get(cli, /large-file.zip); if (!result || result.status() ! 200) { std::cerr Download failed\n; return 1; } std::ofstream file(download.zip, std::ios::binary); size_t total 0; while (result.next()) { file.write(result.data(), result.size()); total result.size(); std::cout \rDownloaded: (total / 1024) KB std::flush; } std::cout \nComplete!\n; return 0; }由于每个块处理完即被覆盖即使文件达数 GB内存占用也稳定在一个块默认 8 KB附近。仓库测试 test/test.cc 中的PostLarge用例即用stream::Post读取 100 KB 响应并断言累计字节数精确等于100 * 1024验证了块拼接的完整性。示例 4反向代理流式转发服务端 handler 中打开到上游的流把状态码、响应头与响应体原样转发给下游客户端#include httplib.h httplib::Server svr; svr.Get(/proxy/(.*), [](const httplib::Request req, httplib::Response res) { httplib::Client upstream(http://backend:8080); auto handle upstream.open_stream(/ req.matches[1].str()); if (!handle.is_valid()) { res.status 502; return; } res.status handle.response-status; res.set_chunked_content_provider( handle.response-get_header_value(Content-Type), handle std::move(handle) mutable { char buf[8192]; auto n handle.read(buf, sizeof(buf)); if (n 0) { sink.write(buf, static_castsize_t(n)); return true; } sink.done(); return true; } ); }); svr.listen(0.0.0.0, 3000);关键在于handle std::move(handle)把StreamHandle移动进set_chunked_content_provider的 lambda使 socket 生命周期覆盖整个响应发送过程每次回调从上游读一块、经sink.write()写到下游直到read()返回非正值时调用sink.done()收尾。这正是反向代理场景读到什么转发什么的典型实现。七、与既有 API 的对比特性Client::Get()open_stream()stream::Get()响应头可用时机完整接收后立即可用立即可用响应体读取方式一次性整体缓冲直接从 socket 读取迭代器式读取内存占用整个响应体在内存极小可控极小可控Keep-Alive 支持✅ 支持❌ 不支持❌ 不支持压缩处理自动处理自动处理自动处理最适合场景小响应、连接复用底层流式控制便捷流式读取八、流式 API 的特性清单真正的 socket 级流式数据直接从网络 socket 读取不经整包缓冲低内存占用任意时刻内存中只有当前一个数据块压缩支持gzip、brotli、zstd 自动解压分块传输完整支持 chunked transfer encoding含 trailer 解析SSL/TLS 支持HTTPS 连接同样可用。关于压缩与解压从源码看open_stream()读取响应头中的Content-Encoding后调用detail::create_decompressor()创建解压器httplib.h若是已知编码但当前构建未启用对应后端如未开启 brotli返回Error::UnsupportedContentEncoding未知编码则原样透传。解压路径read_with_decompression()内部使用 8192 字节的压缩缓冲kDecompressionBufferSize分块喂给解压器并受payload_max_length即客户端的set_payload_max_length约束防止解压炸弹。分块传输侧detail::ChunkedDecoderhttplib.h按 RFC 9112 解析 chunk-size、chunk-ext 与 trailer并对畸形分块返回读取错误。测试 test/test.cc 覆盖了 open_stream 对 gzip 解压、未知编码、默认请求头Host / User-Agent / Accept-Encoding、POST 的 Content-Type 行为、大响应与分块响应读取等场景test/test.cc 则验证了 brotli 压缩内容经open_stream自动解压后内容一致。StreamApiTestfixturetest/test.cc为所有stream::*测试统一起了一个本地 HTTP 服务覆盖 Get/Post/Put/Patch 的基本读写、查询参数、自定义头与 404 状态码等断言是理解 API 行为最直观的参照。九、Keep-Alive 行为与选型提醒流式 APIstream::Get()/open_stream()在流的整个生命周期内接管 socket 所有权这意味着流式连接不支持 Keep-AliveStreamHandle析构时 socket 随即关闭StreamHandle的connection_与socket_stream_均由其独占持有见 httplib.h需要连接复用的场景请使用标准client.Get()API。// Use for streaming (no Keep-Alive) auto result httplib::stream::Get(cli, /large-stream); while (result.next()) { /* ... */ } // Use for Keep-Alive connections auto res cli.Get(/api/data); // Connection can be reused选型时把握一条主线小响应、高频短请求选Client::Get()享受连接复用大响应、实时流、逐块处理选stream::Get()需要直接控制 socket 读取粒度、做代理转发选open_stream()纯 SSE 且有重连诉求直接选SSEClient。十、相关资源流式 API 是 cpp-httplib 近期新增能力需求源头对应上游 issue #2269原始功能请求本仓库中的落地实现集中在 httplib.h 的stream命名空间与ClientImpl::open_stream。SSE 高层客户端文档见 README-sse.md实现位于 httplib.h。带自动重连的流式 SSE 客户端示例example/ssecli-stream.cc。流式 API 的完整测试test/test.ccopen_stream()测试与 test/test.ccstream::*测试。编译运行本仓库示例时直接#include httplib.h即可header-only无需链接额外库example/目录下提供Makefile与各示例源码可参照构建。赞分享后端网络【免费下载链接】cpp-httplibA C header-only HTTP/HTTPS server and client library项目地址https://gitcode.com/GitHub_Trending/cp/cpp-httplib点击查看免费下载相关推荐实时数据推送新范式cpp-httplib实现Server-Sent Events(SSE)全指南实时数据推送新范式cpp httplib实现Server Sent Events SSE 全指南 你是否还在为Web应用的实时数据更新烦恼传统轮询效率低下后端网络cpp-httplib HTTP重定向处理301、302与最佳实践cpp httplib HTTP重定向处理301、302与最佳实践 你是否在C HTTP服务开发中遇到过重定向逻辑混乱、客户端兼容性问题或性能瓶颈作为c后端网络3行代码搞定cpp-httplib响应头获取实战指南3行代码搞定cpp httplib响应头获取实战指南 你是否还在为C HTTP客户端获取响应头信息而烦恼本文将用最简洁的方式带你掌握cpp httpl后端网络上一篇Liquidsoap与FFmpeg集成指南解锁高级媒体处理与HLS流媒体能力下一篇CrowdSec 威胁情报共享协议比较TAXII vs STIX vs MISP创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 cpp-httplib 流式 API 实战：用 stream::Get 与 open_stream 实现逐块读取、SSE 与反向代理
后端网络【免费下载链接】cpp-httplibA C header-only HTTP/HTTPS server and client library项目地址https://gitcode.com/GitHub_Trending/cp/cpp-httplib点击查看免费下载本篇文章以 cpp-httplib 官方文档 README-stream.md 为核心系统讲解该库新增的Streaming API基于迭代器的stream::Get()/stream::Result高层接口以及直接操作 socket 的open_stream()/StreamHandle底层接口。读完本文你将掌握如何用极低内存代价逐块消费 HTTP 响应体落地 LLM 流式输出、SSEServer-Sent Events、大文件下载与反向代理等真实场景并理解这些 API 在 httplib.h 中的底层实现原理。一、什么是 cpp-httplib 流式 API传统上Client::Get()会等待整个响应体完整接收并缓冲到内存中这对小响应和 Keep-Alive 连接复用很友好但遇到超大文件或无限流式输出如大模型逐字生成时内存与首字节延迟都不可接受。cpp-httplib 为此提供了流式扩展数据直接从网络 socket 读取一次只保留当前一个数据块在内存中配合迭代器风格的循环逐块处理实现真正的 socket 级流式true socket-level streaming。流式 API 特别适用于以下几类场景LLM / AI 流式响应如 ChatGPT、Claude、Ollama 等以 JSON Lines 逐行输出的接口Server-Sent EventsSSE实时推送大文件下载及下载进度跟踪反向代理实现把上游响应体原样转发给下游。使用前请先记住三条重要约束无 Keep-Alive每次stream::Get()都会使用一条专用连接响应体读完后连接即关闭需要连接复用时请改用Client::Get()。只能迭代一次next()方法只能从头到尾遍历响应体一遍。Result 非线程安全stream::Get()可以在多个线程同时被调用但返回的stream::Result只能由单个线程使用。二、Quick Start第一个流式客户端在项目目录中引入头文件后即可用与Client::Get()几乎相同的写法发起流式请求#include httplib.h int main() { httplib::Client cli(http://localhost:8080); // Get streaming response auto result httplib::stream::Get(cli, /stream); if (result) { // Process response body in chunks while (result.next()) { std::cout.write(result.data(), result.size()); } } return 0; }核心循环是while (result.next())next()每次从 socket 读入一块数据并返回true读到流结束返回falseresult.data()指向当前块起始位置result.size()给出当前块字节数。整个过程中内存中只保留一个块配合std::cout.write()即可把响应原样输出。需要说明的是stream::Get只是open_stream(GET, ...)的便捷封装源码见 httplib.h默认块大小chunk_size 8192字节。除了 GETstream命名空间还提供Post/Put/Patch/Delete/Head/Options等对应方法均支持传Headers、Params与请求体见 httplib.h。三、API 分层从高层到低层四层接口cpp-httplib 针对不同使用诉求提供了四层 API从上到下抽象层级递减、控制粒度递增┌─────────────────────────────────────────────┐ │ SSEClient │ ← SSE-specific, parsed events │ - on_message(), on_event() │ │ - Auto-reconnect, Last-Event-ID │ ├─────────────────────────────────────────────┤ │ stream::Get() / stream::Result │ ← Iterator-based streaming │ - while (result.next()) { ... } │ ├─────────────────────────────────────────────┤ │ open_stream() / StreamHandle │ ← General-purpose streaming │ - handle.read(buf, len) │ ├─────────────────────────────────────────────┤ │ Client::Get() │ ← Traditional, full buffering └─────────────────────────────────────────────┘选择建议如下使用场景推荐 API需要自动重连的 SSESSEClient见 README-sse.mdLLM 流式输出JSON Linesstream::Get()大文件下载stream::Get()或open_stream()反向代理open_stream()小响应 Keep-AliveClient::Get()其中SSEClient命名空间sse实现于 httplib.h 起的SSEMessage/SSEClient会把流按 SSE 规范解析成带event/data/id字段的消息对象并内置自动重连与Last-Event-ID续传逻辑是 SSE 场景下的最高层选择。四、低层 API 参考StreamHandle 与 open_streamStreamHandle是流式 API 的底层句柄接管 socket 连接的所有权数据直接从网络读取。声明位于 httplib.h。// Open a stream (takes ownership of socket) httplib::Client cli(http://localhost:8080); auto handle cli.open_stream(GET, /path); // Check validity if (handle.is_valid()) { // Access response headers immediately int status handle.response-status; auto content_type handle.response-get_header_value(Content-Type); // Read body incrementally char buf[4096]; ssize_t n; while ((n handle.read(buf, sizeof(buf))) 0) { process(buf, n); } }注意使用open_stream()时连接专用于流式传输不支持 Keep-Alive需要连接复用的场景请改用client.Get()。StreamHandle 成员一览成员类型说明responsestd::unique_ptrResponse含响应头的 HTTP 响应对象errorError请求失败时的错误码is_valid()bool响应有效时返回 trueread(buf, len)ssize_t直接从 socket 读取最多len字节get_read_error()Error获取最近一次读错误has_read_error()bool检查是否发生读错误open_stream 的底层实现细节从 httplib.h 的ClientImpl::open_stream()实现可以看到它做了完整的事前准备目标编码与缓冲发送路径保持一致空Params时直接用path否则调用append_query_params()追加查询参数再经detail::encode_request_target()编码保证无论走哪个 API同样的path产生同样的请求行连接准备在socket_mutex_保护下检查现有 socket 是否存活is_socket_aliveSSL 下还会检查对端是否关闭失效则断开重建并通过setup_proxy_connection()处理代理所有权转移transfer_socket_ownership_to_handle()httplib.h把 socket 描述符及 SSL 会话从Client移交给StreamHandle客户端自身的socket_置为INVALID_SOCKET从此连接生命周期完全由句柄掌控请求写出先在内存BufferStream中组装请求行与请求头write_request_linecheck_and_write_headers校验通过后再一次性写入网络随后写入请求体若有避免被拒绝的头污染线上数据响应解析读取响应行与响应头并做与普通路径相同的 framing 检查HEAD、204、304 可合法携带无体 framing 头Content-Length冲突视为Error::Read传输语义识别根据响应头设置BodyReader的content_length/chunked标志is_chunked_transfer_encoding()判定分块传输并对Content-Encoding创建对应的解压器见下节。StreamHandle::read()在存在解压器时走read_with_decompression()路径httplib.h否则直接调用detail::read_body_content()按 Content-Length / chunked 语义读取当分块流读完后还会解析 trailerparse_trailers_if_needed()httplib.h。测试 test/test.cc 中的StreamHandleTest验证了is_valid()对response与error的组合判定逻辑。五、高层 API 参考stream::Get() 与 stream::Resultstream::Result是对StreamHandle的迭代器式封装声明于 httplib.h实现于 httplib.h使用起来更符合直觉#include httplib.h httplib::Client cli(http://localhost:8080); cli.set_follow_location(true); // ... // Simple GET auto result httplib::stream::Get(cli, /path); // GET with custom headers httplib::Headers headers {{Authorization, Bearer token}}; auto result httplib::stream::Get(cli, /path, headers); // Process the response if (result) { while (result.next()) { process(result.data(), result.size()); } } // Or read entire body at once auto result2 httplib::stream::Get(cli, /path); if (result2) { std::string body result2.read_all(); }stream::Result 成员一览成员类型说明operator bool()bool响应有效时返回 trueis_valid()bool与operator bool()等价status()intHTTP 状态码headers()const Headers响应头get_header_value(key, def)std::string获取响应头值可带默认值has_header(key)bool检查响应头是否存在next()bool读取下一块数据读完返回 falsedata()const char*当前块数据指针size()size_t当前块大小read_all()std::string把剩余响应体全部读入字符串error()Error获取连接/请求错误read_error()Error获取最近一次读错误has_read_error()bool检查是否发生读错误实现细节上next()httplib.h在句柄无效或已结束时直接返回false否则确保内部缓冲区不小于chunk_size_后调用handle_.read()n 0则更新current_size_并返回true读到 0 或负值时置finished_ true并返回false。read_all()不过是反复next()并把每块append到字符串——这解释了只能迭代一次的约束一旦读完finished_即被置位。此外stream::Result是**仅移动move-only**类型拷贝构造与拷贝赋值被删除移动构造/赋值可用httplib.h因此把它放入 lambda 捕获列表或返回时需使用std::move。六、实战示例示例 1SSEServer-Sent Events客户端用stream::Get()逐块读取并实时输出事件流每读一块立即flush#include httplib.h #include iostream int main() { httplib::Client cli(http://localhost:1234); auto result httplib::stream::Get(cli, /events); if (!result) { return 1; } while (result.next()) { std::cout.write(result.data(), result.size()); std::cout.flush(); } return 0; }需要自动重连、事件解析与Last-Event-ID续传的完整 SSE 客户端可参考仓库示例 example/ssecli-stream.cc它在主循环中不断调用httplib::stream::Get(cli, path, headers)连接失败或读错误后按retry_ms间隔重连并通过parse_sse_line()按 SSE 规范把缓冲内容切分成event/data/id/retry字段遇到空行即完成一个事件对 204/404/401/403 等永久性错误则直接退出不再重连。它还会校验Content-Type是否为text/event-stream并在流结束后用result.read_error()区分正常结束与连接中断。示例 2LLM 流式响应以本地 Ollama 服务的/api/generate为例逐块接收模型生成内容并在读取结束后检查错误#include httplib.h #include iostream int main() { httplib::Client cli(http://localhost:11434); // Ollama auto result httplib::stream::Get(cli, /api/generate); if (result result.status() 200) { while (result.next()) { std::cout.write(result.data(), result.size()); std::cout.flush(); } } // Check for connection errors if (result.read_error() ! httplib::Error::Success) { std::cerr Connection lost\n; } return 0; }result.status()在响应头到达后即可获得无需等待整个响应体配合read_error()可区分流正常结束与中途断开两种收尾形态。示例 3大文件下载与进度显示边读边写磁盘并用累计字节数输出进度#include httplib.h #include fstream #include iostream int main() { httplib::Client cli(http://example.com); auto result httplib::stream::Get(cli, /large-file.zip); if (!result || result.status() ! 200) { std::cerr Download failed\n; return 1; } std::ofstream file(download.zip, std::ios::binary); size_t total 0; while (result.next()) { file.write(result.data(), result.size()); total result.size(); std::cout \rDownloaded: (total / 1024) KB std::flush; } std::cout \nComplete!\n; return 0; }由于每个块处理完即被覆盖即使文件达数 GB内存占用也稳定在一个块默认 8 KB附近。仓库测试 test/test.cc 中的PostLarge用例即用stream::Post读取 100 KB 响应并断言累计字节数精确等于100 * 1024验证了块拼接的完整性。示例 4反向代理流式转发服务端 handler 中打开到上游的流把状态码、响应头与响应体原样转发给下游客户端#include httplib.h httplib::Server svr; svr.Get(/proxy/(.*), [](const httplib::Request req, httplib::Response res) { httplib::Client upstream(http://backend:8080); auto handle upstream.open_stream(/ req.matches[1].str()); if (!handle.is_valid()) { res.status 502; return; } res.status handle.response-status; res.set_chunked_content_provider( handle.response-get_header_value(Content-Type), handle std::move(handle) mutable { char buf[8192]; auto n handle.read(buf, sizeof(buf)); if (n 0) { sink.write(buf, static_castsize_t(n)); return true; } sink.done(); return true; } ); }); svr.listen(0.0.0.0, 3000);关键在于handle std::move(handle)把StreamHandle移动进set_chunked_content_provider的 lambda使 socket 生命周期覆盖整个响应发送过程每次回调从上游读一块、经sink.write()写到下游直到read()返回非正值时调用sink.done()收尾。这正是反向代理场景读到什么转发什么的典型实现。七、与既有 API 的对比特性Client::Get()open_stream()stream::Get()响应头可用时机完整接收后立即可用立即可用响应体读取方式一次性整体缓冲直接从 socket 读取迭代器式读取内存占用整个响应体在内存极小可控极小可控Keep-Alive 支持✅ 支持❌ 不支持❌ 不支持压缩处理自动处理自动处理自动处理最适合场景小响应、连接复用底层流式控制便捷流式读取八、流式 API 的特性清单真正的 socket 级流式数据直接从网络 socket 读取不经整包缓冲低内存占用任意时刻内存中只有当前一个数据块压缩支持gzip、brotli、zstd 自动解压分块传输完整支持 chunked transfer encoding含 trailer 解析SSL/TLS 支持HTTPS 连接同样可用。关于压缩与解压从源码看open_stream()读取响应头中的Content-Encoding后调用detail::create_decompressor()创建解压器httplib.h若是已知编码但当前构建未启用对应后端如未开启 brotli返回Error::UnsupportedContentEncoding未知编码则原样透传。解压路径read_with_decompression()内部使用 8192 字节的压缩缓冲kDecompressionBufferSize分块喂给解压器并受payload_max_length即客户端的set_payload_max_length约束防止解压炸弹。分块传输侧detail::ChunkedDecoderhttplib.h按 RFC 9112 解析 chunk-size、chunk-ext 与 trailer并对畸形分块返回读取错误。测试 test/test.cc 覆盖了 open_stream 对 gzip 解压、未知编码、默认请求头Host / User-Agent / Accept-Encoding、POST 的 Content-Type 行为、大响应与分块响应读取等场景test/test.cc 则验证了 brotli 压缩内容经open_stream自动解压后内容一致。StreamApiTestfixturetest/test.cc为所有stream::*测试统一起了一个本地 HTTP 服务覆盖 Get/Post/Put/Patch 的基本读写、查询参数、自定义头与 404 状态码等断言是理解 API 行为最直观的参照。九、Keep-Alive 行为与选型提醒流式 APIstream::Get()/open_stream()在流的整个生命周期内接管 socket 所有权这意味着流式连接不支持 Keep-AliveStreamHandle析构时 socket 随即关闭StreamHandle的connection_与socket_stream_均由其独占持有见 httplib.h需要连接复用的场景请使用标准client.Get()API。// Use for streaming (no Keep-Alive) auto result httplib::stream::Get(cli, /large-stream); while (result.next()) { /* ... */ } // Use for Keep-Alive connections auto res cli.Get(/api/data); // Connection can be reused选型时把握一条主线小响应、高频短请求选Client::Get()享受连接复用大响应、实时流、逐块处理选stream::Get()需要直接控制 socket 读取粒度、做代理转发选open_stream()纯 SSE 且有重连诉求直接选SSEClient。十、相关资源流式 API 是 cpp-httplib 近期新增能力需求源头对应上游 issue #2269原始功能请求本仓库中的落地实现集中在 httplib.h 的stream命名空间与ClientImpl::open_stream。SSE 高层客户端文档见 README-sse.md实现位于 httplib.h。带自动重连的流式 SSE 客户端示例example/ssecli-stream.cc。流式 API 的完整测试test/test.ccopen_stream()测试与 test/test.ccstream::*测试。编译运行本仓库示例时直接#include httplib.h即可header-only无需链接额外库example/目录下提供Makefile与各示例源码可参照构建。赞分享后端网络【免费下载链接】cpp-httplibA C header-only HTTP/HTTPS server and client library项目地址https://gitcode.com/GitHub_Trending/cp/cpp-httplib点击查看免费下载相关推荐实时数据推送新范式cpp-httplib实现Server-Sent Events(SSE)全指南实时数据推送新范式cpp httplib实现Server Sent Events SSE 全指南 你是否还在为Web应用的实时数据更新烦恼传统轮询效率低下后端网络cpp-httplib HTTP重定向处理301、302与最佳实践cpp httplib HTTP重定向处理301、302与最佳实践 你是否在C HTTP服务开发中遇到过重定向逻辑混乱、客户端兼容性问题或性能瓶颈作为c后端网络3行代码搞定cpp-httplib响应头获取实战指南3行代码搞定cpp httplib响应头获取实战指南 你是否还在为C HTTP客户端获取响应头信息而烦恼本文将用最简洁的方式带你掌握cpp httpl后端网络上一篇Liquidsoap与FFmpeg集成指南解锁高级媒体处理与HLS流媒体能力下一篇CrowdSec 威胁情报共享协议比较TAXII vs STIX vs MISP创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考