需求

C++中使用hiredis客戶端接口訪問redis； 
需要使用mset一次設置多個二進制數據

以下給出三種封裝實現方案；

簡單拼接方案

在redis-cli中，mset的語法是這樣的：

OK

按照這樣的語法拼接后，直接使用hiredis字符串接口redisCommand傳遞：
 

1. void msetNotBinary(redisContext *c, const vector<string> &vtKey, const vector<string> & vtVal ) 
2. { 
3.   if(vtKey.size() != vtVal.size()) 
4.   { 
5.     throw runtime_error( "Redis error" ); 
6.   } 
7.  
8.   string strCmd = "MSET"; 
9.   for(int i = 0; i < vtKey.size(); i++) 
10.   { 
11.     strCmd += " "+vtKey[i]+" "+vtVal[i]; 
12.   } 
13.   cout << "strCmd:" << strCmd << endl; 
14.  
15.   void * r = redisCommand(c, strCmd.c_str() ); 
16.   if ( !r ) 
17.     throw runtime_error( "Redis error" ); 
18.   freeReplyObject( r ); 
19. } 
20.  
21. void do_test( redisContext *c ) 
22. {   
23.   vector<string> vtKey; 
24.   vector<string> vtVal; 
25.  
26.   vtKey.push_back("A"); 
27.   vtVal.push_back("AAAA"); 
28.   vtKey.push_back("B"); 
29.   vtVal.push_back("BBBB"); 
30.   vtKey.push_back("C"); 
31.   vtVal.push_back("CCCC"); 
32.   //add a binary data 
33.   vtKey.push_back("D"); 
34.   vtVal.push_back(""); 
35.   char a[] = "ABCDE"; 
36.   a[2] = 0; 
37.   vtVal[3].assign(a,5); 
38.  
39.   try 
40.   { 
41.     msetNotBinary(c, vtKey, vtVal ); 
42.     //mset1( c, vtKey, vtVal ); 
43.     //mset2( c, vtKey, vtVal ); 
44.   } 
45.   catch ( runtime_error & ) 
46.   { 
47.     cout << "Error" << endl; 
48.   } 
49. } 
50.  
51. int main(int argc, char *argv[]) 
52. { 
53.   redisContext *c; 
54.  
55.   c = redisConnect("127.0.0.1",6379); 
56.   if (c->err) 
57.    { 
58.     cout << "Connection error: " << c->errstr << endl; 
59.     return -1; 
60.   } 
61.  
62.   do_test(c); 
63.  
64.   redisFree(c); 
65.  
66.   return 0; 
67. } 

這種方式可以處理mset多個字符串數據，但對于數據內容為二進制數據的無能為力；

redisCommandArgv接口傳遞 方案

對于多個參數傳遞，hiredis提供了以下接口，這個接口中最后一個參數是所有的傳入數據的內容長度， 
就是說這個接口是二進制安全的：

void *redisCommandArgv(redisContext *c, int argc, const char **argv, const size_t *argvlen);
主要工作就是構造一個動態的二維數組char ** argv,其中涉及到char **到const char **的轉換，有一定的風險， 
關于這一點前一篇文章已經談到；
 

1. void mset1( redisContext *c, const vector<string> &vtKey, const vector<string> & vtVal ) 
2. { 
3.   if(vtKey.size() != vtVal.size()) 
4.   { 
5.     throw runtime_error( "Redis error" ); 
6.   } 
7.  
8.   char ** argv = new char*[vtKey.size() + vtVal.size() + 1 ]; 
9.   size_t * argvlen = new size_t[vtKey.size() + vtVal.size() + 1 ]; 
10.  
11.   int j = 0; 
12.   argv[j] = new char[5]; 
13.   memcpy(argv[j],"MSET",4); 
14.   argvlen[j] = 4; 
15.   ++j; 
16.  
17.  
18.   for(int i = 0 ; i < vtKey.size();i++) 
19.   {   
20.     argvlen[j] = vtKey[i].length(); 
21.     argv[j] = new char[argvlen[j]]; 
22.      memset((void*)argv[j],0,argvlen[j] ); 
23.     memcpy((void*)argv[j],vtKey[i].data(),vtKey[i].length()); 
24.     j++; 
25.  
26.     argvlen[j] = vtVal[i].length(); 
27.     argv[j] = new char[argvlen[j]]; 
28.     memset((void*)argv[j],0,argvlen[j]); 
29.     memcpy((void*)argv[j],vtVal[i].data(),vtVal[i].length()); 
30.     j++; 
31.   } 
32.  
33.   //if not use const_cast<const char**> ,compile error 
34.   //for why assign from char** to const char** error, see my blog ... 
35.    void *r = redisCommandArgv(c, vtKey.size() + vtVal.size() + 1, const_cast<const char**>(argv), argvlen ); 
36.   if ( !r ) 
37.     throw runtime_error( "Redis error" ); 
38.   freeReplyObject( r ); 
39.  
40.   for(int i = 0;i < vtKey.size();i++) 
41.   { 
42.     delete [] argv[i]; 
43.     argv[i] = NULL; 
44.   } 
45.  
46.   delete []argv; 
47.   delete []argvlen; 
48.   argv = NULL; 
49. } 

redisCommandArgv接口傳遞的Vector方案

還是使用redisCommandArgv接口，使用vector來構造這個const char **，這個方法是從參考資料1中學到的：
 

1. void mset2( redisContext *c, const vector<string> &vtKey, const vector<string> & vtVal) 
2. { 
3.   if(vtKey.size() != vtVal.size()) 
4.   { 
5.     throw runtime_error( "Redis error" ); 
6.   } 
7.  
8.   vector<const char *> argv( vtKey.size() + vtVal.size() + 1 ); 
9.   vector<size_t> argvlen( vtKey.size() + vtVal.size() + 1 ); 
10.   int j = 0; 
11.  
12.   static char msetcmd[] = "MSET"; 
13.   argv[j] = msetcmd; 
14.   argvlen[j] = sizeof(msetcmd)-1; 
15.   ++j; 
16.  
17.   for(int i = 0;i< vtKey.size();++i) 
18.   { 
19.     argvlen[j] = vtKey[i].length(); 
20.     argv[j] = new char[argvlen[j]]; 
21.      memset((void*)argv[j],0,argvlen[j] ); 
22.     memcpy((void*)argv[j],vtKey[i].data(),vtKey[i].length()); 
23.     j++; 
24.  
25.     argvlen[j] = vtVal[i].length(); 
26.     argv[j] = new char[argvlen[j]]; 
27.     memset((void*)argv[j],0,argvlen[j]); 
28.     memcpy((void*)argv[j],vtVal[i].data(),vtVal[i].length()); 
29.     j++; 
30.   } 
31.  
32.   void *r = redisCommandArgv(c, argv.size(), &(argv[0]), &(argvlen[0]) ); 
33.   if ( !r ) 
34.     throw runtime_error( "Redis error" ); 
35.   freeReplyObject( r ); 
36. } 

這樣，就實現二進制數據的傳遞；

二進制校驗

程序執行后，可以用redis-cli來驗證：

對于非二進制安全的實現，二進制內容是截斷的：

而二進制安全的實現接口，二進制數據的0通過轉義方式顯示：

完整可執行的代碼詳見github：https://github.com/me115/cppset/tree/master/2DimArray

以上所述就是本文的全部內容了，希望大家能夠喜歡。