本文只總結(jié)常規(guī)會用到的hiRedis使用方法袜炕，一般順序?yàn)橄扔?redisConnect 連接數(shù)據(jù)庫，然后用 redisCommand 執(zhí)行命令犁罩，執(zhí)行完后用 freeReplyObject 來釋放redisReply對象，最后用 redisFree 來釋放整個連接。
hiredis直接去git上克隆氏身，地址：https://github.com/redis/hiredis，然后make && make install
連接
函數(shù)原型
redisContext *redisConnect(const char *ip, int port);
void redisFree(redisContext *c);
使用示例
//連接redis惑畴，若出錯redisContext.err會設(shè)置為1蛋欣，redisContext.errstr會包含描述錯誤信息
redisContext *redis_handle = redisConnect("192.163.122.1", 8889);
if (redis_handle == NULL || redis_handle->err) {
if (redis_handle) {
printf("Error:%s\n", redis_handle->errstr);
} else {
printf("can't allocate redis context\n");
}
return -1;
}
//do your work
redisFree(redis_handle);
執(zhí)行Redis命令
函數(shù)原型
typedef struct redisReply {
int type; /* REDIS_REPLY_* */
long long integer; /* The integer when type is REDIS_REPLY_INTEGER */
int len; /* Length of string */
char *str; /* Used for both REDIS_REPLY_ERROR and REDIS_REPLY_STRING */
size_t elements; /* number of elements, for REDIS_REPLY_ARRAY */
struct redisReply **element; /* elements vector for REDIS_REPLY_ARRAY */
} redisReply;
void *redisCommand(redisContext *c, const char *format, ...);
void freeReplyObject(void *reply);
redisReply結(jié)構(gòu)的type定義如下
- REDIS_REPLY_STATUS：
表示返回了一個狀態(tài)。狀態(tài)字符串可以使用reply->str來訪問如贷。該字符串的長度可以使用reply->len來訪問陷虎。例如set成功，會返回狀態(tài)杠袱，str為"OK" - REDIS_REPLY_ERROR：
表示執(zhí)行錯誤尚猿。錯誤字符串可以使用reply->str來訪問 - REDIS_REPLY_INTEGER：
表示返回一個整數(shù)。整數(shù)值可以使用long long類型的reply-> integer字段來訪問 - REDIS_REPLY_NIL：
表示返回空數(shù)據(jù) - REDIS_REPLY_STRING：
表示返回一個字符串楣富≡涞啵可以使用reply-> str來訪問。該字符串的長度可以使用reply->len來訪問纹蝴。 - REDIS_REPLY_ARRAY：
表示返回一個數(shù)組庄萎。例如mget，元素?cái)?shù)量存儲在reply->elements元素中塘安。每個元素也是一個redisReply對象糠涛，可以通過reply-> element [index]進(jìn)行訪問。
使用示例
//set
string set_ = "set China Beijing";
redisReply *reply = (redisReply *)redisCommand(redis_handle, set_.c_str());
if (reply!=NULL && reply->type==REDIS_REPLY_STATUS) {
printf("%s\n", reply->str);
}
freeReplyObject(reply);
//mset
string mset_ = "set China Beijing Japan Tokyo";
redisReply *reply = (redisReply *)redisCommand(redis_handle, mset_.c_str());
if (reply!=NULL && reply->type==REDIS_REPLY_STATUS) {
printf("%s\n", reply->str);
}
freeReplyObject(reply);
//get
string get_ = "get China";
redisReply *reply = (redisReply *)redisCommand(redis_handle, get_.c_str());
if (reply!=NULL && reply->type==REDIS_REPLY_STRING) {
printf("%s\n", reply->str);
}
freeReplyObject(reply); //使用reply以后必須要進(jìn)行釋放
//mget
string mget_ = "mget China Japan";
redisReply *reply = (redisReply *)redisCommand(redis_handle, mget_.c_str());
if (reply!=NULL && reply->type==REDIS_REPLY_ARRAY) {
for (int i=0; i<reply->elements; ++i) {
printf("%s\n", reply->element[i]->str);
}
}
freeReplyObject(reply);
當(dāng)命令執(zhí)行發(fā)生錯誤時(shí)兼犯，reply為NULL忍捡，redis_handle中的err字段將被設(shè)置。一旦錯誤返回切黔，redis_handle不能被重用砸脊，你應(yīng)該建立一個新的連接。
redisReply *reply = (redisReply *)redisCommand(redis_handle, mget_str.c_str());
if (reply == NULL) {
printf("Error:%s\n", redis_handle->errstr);
redisReconnect(redis_handle);
}
進(jìn)階
由于hiRedis是非線程安全的纬霞，即一個redis_handle不能同時(shí)被多個線程使用脓规，因此通過連接池解決并發(fā)訪問redis的問題
#include <string>
#include <mutex>
#include "hiredis.h"
class redis_pool {
public:
redis_pool() {
}
~redis_pool() {
for (int i=0; i<conn_num; ++i) {
if (conn_pool[i] != NULL) {
redisFree(conn_pool[i]);
conn_pool[i] = NULL;
}
}
delete [] conn_pool;
if (conn_flag != NULL) {
delete [] conn_flag;
conn_flag = NULL;
}
}
int init(std::string ip_, int port_, int conn_num_) {
ip = ip_;
port = port_;
conn_num = conn_num_;
conn_pool = new redisContext * [conn_num];
if (conn_pool == NULL) {
return 1;
}
conn_flag = new int[conn_num];
if (conn_flag == NULL) {
return 2;
}
for (int i=0; i<conn_num; ++i) {
conn_pool[i] = redisConnect(ip.c_str(), port);
if (conn_pool[i]==NULL || conn_pool[i]->err) {
return 3;
}
conn_flag[i] = 0;
}
empty_num = conn_num;
current_conn = 0;
return 0;
}
redisContext *get_conn(int &id) {
if (empty_num == 0) {
return NULL;
}
mtx.lock();
while (conn_flag[current_conn] != 0) {current_conn = (current_conn+1) % conn_num;}
conn_flag[current_conn] = 1;
--empty_num;
id = current_conn;
current_conn = (current_conn+1) % conn_num;
mtx.unlock();
return conn_pool[id];
}
void put_conn(int id) {
if (id<conn_num && id>=0) {
mtx.lock();
conn_flag[id] = 0;
++empty_num;
mtx.unlock();
}
return;
}
private:
std::string ip;
int port;
int conn_num;
redisContext **conn_pool;
int *conn_flag;
int empty_num;
int current_conn;
std::mutex mtx;
};
備注
- redis對于空閑連接，會在一定時(shí)間內(nèi)關(guān)閉险领，當(dāng)hiRedis的連接被關(guān)閉時(shí)侨舆，通過redisCommand返回的reply為NULL秒紧，需要調(diào)用redisReconnect重連
- 調(diào)用redisEnableKeepAlive并未達(dá)到保持連接的效果
- 當(dāng)key不存在時(shí)，redisCommand并不會返回失敗挨下，只是str成員會為NULL
