1.簡單介紹

hiredis是一個輕量級的訪問redis資料庫的c客戶端。

它是輕量級的不僅僅是因為它僅僅提供對協議的最小支援，而且它使用了一個高級別的極度類似於printf的api使它的級別遠高於其最小程式碼庫和缺乏繫結的redis命令。簡而言之，就是更靈活。

除了支援傳送命令和接受命令，它還有一個與io層分離的回覆解析器。它是一個簡單靈活的流解析器，可以用於更高級別的語言繫結以實現有效的回覆解析。

 hiredis僅僅支援二進位制安全的redsi協議，因此你可以使用它在redis的版本的大於1.2.0.

 hiredis提供多套api，包括同步的api,非同步api，回覆解析的api.

2.同步api

要使用同步api，僅僅需要學會使用幾個函式。

redisContext *redisConnect(const char *ip, int port);      voidredisFree(redisContext *c);

void *redisCommand(redisContext *c, const char *format, ...);
void freeReplyObject(void *reply);

1）redisConnect返回一個redisContext的結構體， 這個結構用於儲存連線狀態。這個結構體包含一個integer型別的err資料成員，這個成員非0，當連線處於一個錯誤狀態的時候，另一個string的資料成員指出具體的錯誤原因。在呼叫redisConnect之後應該檢查err以測試是否連線成功。

2）向redis傳送命令有好幾種方式。

第一種方式：

redisCommand，提供了一種類似於printf的形式去傳送命令。第一個引數是redisConnect的返回值。

最簡單的形式：

reply = redisConnect(context, "set foo bar");

使用%s插入字串的形式：

reply = redisConnect(context, "SET foo %s", value);

傳送二進位制字串的形式，但同時需要指出字串的長度:

reply = redisCommand(context, "SET foo %b",  (szie_t)valuelen);

傳送多個分離的字串的形式：

reply = redisCommand(context, "set key:%s %s", myid, value);

類似於命令列的形式：

void *redisCommandArgv(redisContext *c, int argc, const char **argv, const size_t *argvlen);

第四個引數是每個引數字串的長度

回覆：

當命令成功執行時，redisCommand的返回值會保留一個回覆。發生錯誤時，返回值為NULL，上下文中的err欄位將被設定（請參閱錯誤部分）。一旦錯誤返回，上下文不能被重用，你應該建立一個新的連線。
標準回覆redisCommand的型別是redisReply。 redisReply中的型別欄位應該用於測試收到的回覆型別：
REDIS_REPLY_STATUS：
該命令回覆了狀態回覆。狀態字串可以使用reply-> str來訪問。該字串的長度可以使用reply-> len來訪問。
REDIS_REPLY_ERROR：
該命令回覆了一個錯誤。錯誤字串可以與REDIS_REPLY_STATUS相同訪問。
REDIS_REPLY_INTEGER：
該命令用一個整數來回答。整數值可以使用long long型別的reply-> integer欄位來訪問。
REDIS_REPLY_NIL：
該命令回答了一個零物件。沒有要訪問的資料。
REDIS_REPLY_STRING：
批量（字串）回覆。答覆的值可以使用reply-> str來訪問。該字串的長度可以使用reply-> len來訪問。
REDIS_REPLY_ARRAY：

多批量回復。多批量答覆中的元素數量儲存在reply->元素中。多批量回復中的每個元素也是一個redisReply物件，可以通過reply-> element [.. index ..]進行訪問。 Redis可能會迴應巢狀陣列，但這完全受支援。

應使用freeReplyObject（）函式釋放回復。 請注意，這個函式將負責釋放包含在陣列和巢狀陣列中的子回覆物件，所以使用者不需要釋放子回覆（它實際上是有害的並且會損壞記憶體）。

3）將命令序列化

當redisCommand系列中的任何函式被呼叫時，Hiredis首先根據Redis協議格式化該命令。然後將格式化的命令放入redisContext的輸出緩衝區中。這個輸出緩衝區是動態的，所以它可以容納任意數量的命令。將命令放入輸出緩衝區後，呼叫redisGetReply。這個函式有以下兩個執行路徑：
        輸入緩衝區非空：
            嘗試解析來自輸入緩衝區的單個回覆並將其返回
            如果沒有答覆可以解析，相當於輸入緩衝區為空的情況
        輸入緩衝區為空：
            將整個輸出緩衝區寫入套接字
            從套接字讀取，直到可以解析單個回覆

對於序列化命令，唯一需要做的事情是填充輸出緩衝區。由於這個原因，除了不返回一個回覆之外，可以使用兩個與redisCommand系列相同的命令，然後我們用redisGetReply獲取命令的返回結果。

    void redisAppendCommand(redisContext *c, const char *format, ...);

    void redisAppendCommandArgv(redisContext *c, int argc, const char **argv, const size_t *argvlen);

官方文件如上描述，但其實原始碼中這兩個命令的返回值是int。

使用方法如下：

redisReply *reply;
redisAppendCommand(context,"SET foo bar");
redisAppendCommand(context,"GET foo");
redisGetReply(context,&reply); // reply for SET
freeReplyObject(reply);
redisGetReply(context,&reply); // reply for GET

freeReplyObject(reply);

4）error

當函式呼叫不成功時，根據函式返回NULL或REDIS_ERR。 context中的err欄位將為非零值，並設定為以下常量之一：
REDIS_ERR_IO：建立連線時發生I / O錯誤，嘗試寫入套接字或從套接字讀取。 如果您在應用程式中包含errno.h，則可以使用全域性errno變數來找出錯誤。
REDIS_ERR_EOF：伺服器關閉導致空讀的連線。
REDIS_ERR_PROTOCOL：解析協議時發生錯誤。
REDIS_ERR_OTHER：任何其他錯誤。 目前，只有在指定的主機名連線時才能使用它。
在任何情況下，context中的errstr欄位都將設定為儲存錯誤的字串表示形式

4.程式碼

編譯的時候切記加上動態連結庫。可以使用pkg-config --cflags --libs hiredis顯示如何加。

/*************************************************************************
 > File Name: main.cpp
 > Author: aben
 > Mail: [email protected] 
> Created Time: Sat 19 May 2018 08:52:02 PM PDT
 ************************************************************************/


#include <stdio.h>
#include <stdlib.h>
#include <hiredis/hiredis.h>


using namespace std;


void prase(redisReply *reply)
{
int seq = 0;
if (NULL == reply) {
printf("redisReply id NULL\n");
return;
}
switch (reply->type) 
{
case REDIS_REPLY_STATUS:
printf("REDIS_REPLY_STATUS:%s\n", reply->str);
break;
case REDIS_REPLY_ERROR:
printf("REDIS_REPLY_ERROR:%s\n", reply->str);
break;
case REDIS_REPLY_INTEGER:
printf("REDIS_REPLY_INTEGER:%lld\n", reply->integer);
break;
case REDIS_REPLY_NIL:
printf("REDIS_REPLY_NIL:NULL\n");
break;
case REDIS_REPLY_STRING:
printf("REDIS_REPLY_STRING:%s\n", reply->str);
break;
case REDIS_REPLY_ARRAY:
printf("REDIS_REPLY_ARRAY\n");
while(seq < reply->elements) {
printf("REDIS_REPLY_STRING:%s   ", reply->element[seq]->str);
if (seq++ % 3 == 0) {
printf("\n");
}
}
printf("\n");
break;
default:
break;
}
freeReplyObject(reply);
}


int main()
{
redisContext *c = redisConnect("127.0.0.1", 6379);
if (c == NULL || c->err) {
if (c) {
printf("Error:%s\n", c->errstr);
} else {
printf("conn't allocate redis context\n");
}
exit(-1);
}
printf("redis connect return %d:%s\n", c->err, c->errstr);


 redisReply *reply = (redisReply*)redisCommand(c, "set company noahwm");
prase(reply);
 reply = (redisReply*)redisCommand(c, "set phone 17621079235");
prase(reply);
 reply = (redisReply*)redisCommand(c, "keys *");
prase(reply);




return 0;
}

5.程式碼 2

修改main函式

int main()
{

redisContext *c = redisConnect("127.0.0.1", 6379);

if (c == NULL || c->err) {
    if (c) {
        printf("Error:%s\n", c->errstr);
    } else {
        printf("conn't allocate redis context\n");
    }
    exit(-1);
}
printf("redis connect success\n");


redisReply *reply = (redisReply*)redisCommand(c, "set company noahwm");
prase(reply);
reply = (redisReply*)redisCommand(c, "set phone 17621079235");
prase(reply);


redisAppendCommand(c, "set family henan");
redisGetReply(c, (void**)&reply); // reply for SET                     
prase(reply);
reply = (redisReply*)redisCommand(c, "keys *");
prase(reply);

return 0;

}

如果使用完append類的command函式之後我們不使用redisGetReply得到回覆，那麼下一個命令的回覆就是上一條命令的回覆