当前位置：首页 > backend >正文

Redis C语言连接教程

backend 2025/7/28 6:58:19

一、源码编译与安装

获取源码

git clone https://github.com/redis/hiredis.git
cd hiredis

编译库
```
make
```
- Linux 下生成 libhiredis.so，macOS 下生成 libhiredis.dylib。
安装到系统（可选）
```
sudo make install
```
- 默认将头文件安装到 /usr/local/include/hiredis，库文件安装到 /usr/local/lib。

如果不想安装到系统目录，也可以将生成的库和头文件拷贝到项目目录，自行通过编译参数指定路径。

二、连接并测试

新建 main.c，演示最基本的连接、设置和获取操作：

#include <stdio.h>
#include <stdlib.h>
#include <hiredis/hiredis.h>int main(void) {// 建立到 Redis 的连接（默认 127.0.0.1:6379）redisContext *ctx = redisConnect("127.0.0.1", 6379);if (ctx == NULL || ctx->err) {if (ctx) {fprintf(stderr, "连接错误: %s\n", ctx->errstr);redisFree(ctx);} else {fprintf(stderr, "无法分配 redisContext\n");}exit(EXIT_FAILURE);}// 执行 SET foo barredisReply *reply = redisCommand(ctx, "SET foo bar");printf("SET 返回: %s\n", reply->str);freeReplyObject(reply);// 执行 GET fooreply = redisCommand(ctx, "GET foo");printf("GET 返回: %s\n", reply->str);freeReplyObject(reply);// 关闭连接redisFree(ctx);return 0;
}

编译并运行（若已 make install）：

cc main.c -lhiredis -o test_redis
./test_redis# 输出：
# SET 返回: OK
# GET 返回: bar

若未安装到系统路径，可加上 -I/path/to/hiredis 和 -L/path/to/hiredis。

三、发送命令

使用 redisCommand() 发送任意 Redis 命令，返回 redisReply*。

示例：

// 自增计数器
redisReply *r = redisCommand(ctx, "INCR page_views");
printf("访问量: %lld\n", r->integer);
freeReplyObject(r);// 向列表头插入用户名
r = redisCommand(ctx, "LPUSH recent_users %s", username);
freeReplyObject(r);

四、处理回复

根据 reply->type 判断结果类型并提取值，常见类型及字段：

switch (reply->type) {case REDIS_REPLY_STRING:printf("字符串: %s\n", reply->str);break;case REDIS_REPLY_INTEGER:printf("整数: %lld\n", reply->integer);break;case REDIS_REPLY_ARRAY:for (size_t i = 0; i < reply->elements; i++) {printf("元素[%zu]: %s\n", i, reply->element[i]->str);}break;case REDIS_REPLY_NIL:puts("空回复");break;case REDIS_REPLY_STATUS:printf("状态: %s\n", reply->str);break;case REDIS_REPLY_ERROR:fprintf(stderr, "错误: %s\n", reply->str);break;
}
freeReplyObject(reply);

使用完 redisReply 后，务必调用 freeReplyObject() 释放内存。

五、管道（Pipelining）与事务（Transactions）

管道示例

将多条命令打包，减少网络往返：

redisAppendCommand(ctx, "SET a 1");
redisAppendCommand(ctx, "SET b 2");
redisAppendCommand(ctx, "MGET a b");redisReply *r;
for (int i = 0; i < 3; i++) {redisGetReply(ctx, (void**)&r);// 处理 r ...freeReplyObject(r);
}

事务示例

使用 MULTI/EXEC：

redisReply *r = redisCommand(ctx, "MULTI");
freeReplyObject(r);redisAppendCommand(ctx, "INCR counter");
redisAppendCommand(ctx, "INCR counter");r = redisCommand(ctx, "EXEC");
if (r->type == REDIS_REPLY_ARRAY) {printf("执行了 %zu 条命令\n", r->elements);
}
freeReplyObject(r);

六、与事件驱动框架集成

hiredis 提供多种事件循环适配器，可实现非阻塞 I/O：

libevent：#include <hiredis/adapters/libevent.h>
libuv：#include <hiredis/adapters/uv.h>
ae（Redis 内置）：#include <hiredis/adapters/ae.h>

以 libevent 为例：

#include <event.h>
#include <hiredis/hiredis.h>
#include <hiredis/adapters/libevent.h>int main(void) {struct event_base *base = event_base_new();redisContext *ctx = redisConnect("127.0.0.1", 6379);redisLibeventAttach(ctx, base);// 异步发送 PING，回调中处理结果redisAsyncCommand(ctx, [](redisAsyncContext*, void*, void*) {printf("PONG\n");}, NULL, "PING");event_base_dispatch(base);return 0;
}