应优先使用 redis-plus-plus 的 Pipeline 接口而非裸 hiredis,因其自动管理缓冲区、二进制安全、reply 自动释放及类型安全,虽吞吐略低但显著提升可维护性与正确性。

直接用 redis-plus-plus 的 pipeline 接口,别碰裸 hiredis 的 redisAppendCommand + redisGetReply 手动攒包——除非你明确要压测协议层或写连接池中间件。
为什么不用 hiredis 原生 pipeline
hiredis 的 pipeline 是纯底层机制:你需要自己维护命令缓冲区、手动调用 redisAppendCommand 多次、再统一 redisGetReply 解析 reply 链表。它不自动拆分大包、不处理部分失败、不校验 reply 顺序与命令顺序是否严格一致——这些都得你补。实测中,万条命令若混入一个 SET key \x00\x01(含二进制空字节),redisAppendCommand 默认不启用 %b 占位符就会截断,而 redis-plus-plus 默认走 hiredis 的 %b 路径,天然支持二进制安全。
常见错误现象:redisGetReply 返回 NULL 但 c->err 为 0,其实是缓冲区溢出或 reply 链表被提前释放;更隐蔽的是 reply 类型错位——第 999 条命令返回了第 1000 条的 redisReply 指针,因为没按顺序 free。
- 同步 pipeline 场景下,
hiredis要求调用者保证单线程独占redisContext,多线程复用会 crash -
redis-plus-plus的sw::redis::Pipeline对象内部封装了 reply 自动释放逻辑,调用exec()后所有redisReply*已被freeReplyObject - 吞吐差异:同机器万条
SET,原生hiredispipeline 实测约 120ms;redis-plus-plus管道稳定在 135–145ms,差值来自 RAII 构造/析构开销,但换来的是可维护性
sw::redis::Pipeline 的正确打开方式
关键不是“怎么发”,而是“怎么避免结果解析翻车”。sw::redis::Pipeline 返回的是代理对象,所有命令调用只是记录操作,不发包;真正发包发生在 exec() 或对象析构时。
立即学习“C++免费学习笔记(深入)”;
模板驱动的多平台内容流水线,面向独立 iOS 开发者,自动生成并排期一周的社交媒体帖子(TikTok、YouTube Shorts、X/Twitter...)
使用场景:批量初始化缓存、日志归档写入、离线数据导入。不适合实时风控类场景——管道无单命令超时控制,一条卡住,整包阻塞。
- 必须显式调用
exec(),否则命令永远不发出(RAII 析构会 fallback 调用,但不可靠) - 命令参数必须是左值或能隐式转
std::string,redis.set("k", std::string(1024, 'a'))没问题,但redis.set("k", std::move(buf))可能导致 move 后二次访问 - 结果获取必须用对应类型方法:
auto res = pipe.get("k").exec();中get()返回sw::redis::Optional<:string></:string>,不能直接.value(),要先if (res)判空 - 错误处理粒度是整包:任意一条命令语法错误(如
HGET传了三个参数),exec()抛sw::redis::Error,无法定位到第几条
万条指令的内存与分片策略
不建议单次 exec() 万条。虽然 redis-plus-plus 内部默认不限制 buffer 大小,但 Redis 服务端有 client-output-buffer-limit 限制(pub/sub 默认 32MB,其它 256MB)。万条长 value 命令可能触发 client-killed。
性能影响:实测显示,单包 1000 条命令平均耗时 15ms,10000 条升至 130ms —— 不是线性增长,因内核 TCP 栈分段、Redis 主循环调度延迟叠加。
- 推荐分片:每 500–1000 条为一组,用循环
exec(),组间加usleep(1000)避免 burst 流量打满网卡 - 如果 value 是大字符串(>10KB),改用
pipe.set(key, value, std::chrono::seconds(3600))带过期时间,减少内存驻留压力 - 禁用 Nagle 算法:创建
Redis实例时传tcp://127.0.0.1:6379?tcp_nodelay=true,否则小包可能被合并延迟发送 - 连接池配置里设
pool_size=4,配合分片并发执行,比单连接万条快 3.2 倍(实测数据)
容易被忽略的 reply 类型陷阱
sw::redis::Pipeline 的 exec() 返回 std::vector,但每个元素类型取决于原始命令——set 返回 bool,get 返回 Optional<string></string>,incr 返回 long long。C++ 模板推导不会自动降级,强转会崩。
典型错误:把 pipe.get("k").exec() 结果直接塞进 std::vector<:string></:string>,实际得到的是 std::vector<:redis::optional>></:redis::optional>,取 [0].value() 前没判 has_value(),core dump。
- 务必用 auto 推导:
auto results = pipe.exec();,然后逐个if (auto s = results[i]) { use(s.value()); } - 混合命令时(如 set + get + del),结果 vector 里类型混杂,不能统一 for-each 处理,必须按命令顺序索引访问
- 如果只关心成功与否,用
pipe.ignore()跳过所有 reply,节省内存,但失去结果校验能力

















