C++怎么使用hiredis库实现异步Redis通信-C++-PHP中文网

hiredis异步API核心是redisAsyncContext，需绑定libev/libevent等事件循环才能工作；若未注册回调或未将socket fd加入事件监听，命令将无响应。

c++怎么使用hiredis库实现异步redis通信

hiredis 异步 API 的核心是 `redisAsyncContext` 和事件循环绑定

hiredis 本身不提供事件循环，只提供异步上下文和回调接口。你必须把 redisAsyncContext 接入已有的事件驱动框架（如 libev、libuv、libevent），否则 redisAsyncCommand 发出去的命令永远不会被处理——这不是 bug，是设计使然。

常见错误现象：redisAsyncCommand 返回 REDIS_OK，但回调函数从不触发，也没有错误日志。原因几乎总是：没调用 redisAsyncSetConnectCallback/redisAsyncSetDisconnectCallback，或没把 socket fd 加入事件循环监听可读/可写事件。

必须在 redisAsyncConnect 后立即设置连接/断连回调，否则连接失败时无法感知
每个 redisAsyncContext 对应一个 socket fd，需用 redisAsyncGetFileDescriptor 获取，再注册到你的事件循环中
libev 示例中需监听 EV_READ | EV_WRITE；libuv 中需用 uv_poll_t 并在 UV_READABLE/UV_WRITABLE 时调用 redisAsyncHandleRead/redisAsyncHandleWrite

`redisAsyncCommand` 的参数顺序和内存管理容易出错

异步命令的签名是 int redisAsyncCommand(redisAsyncContext *ac, redisCallbackFn *fn, void *privdata, const char *format, ...)，注意第三位是用户私有数据指针，不是格式化参数起始位——这个位置放错会导致回调里 privdata 变成野指针或 NULL。

使用场景：你想在回调中更新某个对象的状态，就把该对象指针传给 privdata，而不是试图在回调里捕获局部变量地址（栈变量在命令发出后可能已销毁）。

格式化字符串支持 %s、%b（带长度的二进制）、%d 等，但不支持 %f 或宽字符
所有传入的字符串参数（如 %s 对应的值）在回调执行前必须保持有效；若用临时 std::string::c_str()，要确保 string 对象生命周期覆盖整个异步流程
回调函数签名必须为 void callback(struct redisAsyncContext *, void *, void *)，第二个 void * 是 reply（可能为 NULL），第三个是 privdata

连接断开、重连和命令积压需要手动处理

hiredis 异步模式下，网络中断不会自动重连，也不会重发未响应的命令。断连回调触发后，redisAsyncContext 进入不可用状态，必须显式销毁并重建上下文，再重新注册事件监听。

Sentinal Redis

监控Redis服务器健康状况、内存、性能及BullMQ队列。检查队列深度、失败任务，分析慢查询并诊断问题。

下载

性能影响：若在断连后立刻重建连接，但没清空旧 context 的 pending commands 队列，可能导致内存泄漏（hiredis 内部会保留未完成命令的结构体）。

务必在 disconnect 回调里调用 redisAsyncFree，不要只 close fd
重连逻辑建议加退避（如指数退避），避免雪崩式重连请求打满 Redis
如果业务要求命令不丢，需在发送前本地缓存 command + privdata，并在 reconnect 成功后重放；hiredis 不提供内置重试队列

C++ 封装时别直接继承 `redisAsyncContext`，用 PIMPL 更安全

redisAsyncContext 是 C 风格 opaque struct，内部布局不公开，且 hiredis 头文件未声明其析构行为。C++ 类直接继承它或将其作为 public 成员，会导致析构顺序失控、double-free 风险（比如你 delete this 时 hiredis 还持有内部 buffer 指针）。

容易被忽略的地方：hiredis 1.0+ 默认启用 HAVE_SSL 时，异步 context 会额外分配 OpenSSL 相关资源，若未走 redisAsyncFree 而是靠 RAII 自动析构，SSL 结构体可能泄漏。

推荐用 std::unique_ptr 管理 redisAsyncContext*，并在自定义 deleter 中调用 redisAsyncFree
回调函数必须是静态成员或全局函数，不能是普通成员函数（因为 C ABI 不匹配 this 指针）；可通过 privdata 传 this 指针，在回调内 static_cast 回去
多线程下每个线程应独占一个 redisAsyncContext；hiredis 异步 API 不是线程安全的

实际跑通的关键就三步：建 context → 绑事件循环 → 发命令。中间任何一环漏掉，程序看起来“没报错”，但 Redis 就像没听见一样。最常卡住的位置是事件循环集成——确认你的 ev_io 或 uv_poll 是否真的在触发，以及是否对同一 fd 同时监听了读写。