萌新笔记——封装hiredis——C++与redis对接(一)(string的SET与GET *** 作)

萌新笔记——封装hiredis——C++与redis对接(一)(string的SET与GET *** 作),第1张

萌新笔记——封装hiredis——C++与redis对接(一)(string的SET与GET *** 作)

  在菜鸟教程自学了redis,总想着像Mysql一样,在C/C++中进行对接。


于是查询了一些资料,最后找到了hiredis。


然而直接用它的话,难免有点不方便。


于是,对其进行封装。


  hiredis直接去git上克隆,地址:https://github.com/redis/hiredis。


  下载好之后,由于其自带Makefile,只要make一下就编译出静态库与动态库了,接着把头文件和静/动态库放在相应的文件夹里就可以了。


注意如果使用动态库,而且是放在/usr/local/lib/里,得执行ldconfig命令,来更新一下配置,或者得配置一下动态库路径。


  安装好了就是如何使用的事了。


  学习hiredis主要是参考这两个链接:

  http://blog.csdn.net/gqtcgq/article/details/51344232

  http://blog.csdn.net/achelloworld/article/details/41598389?utm_source=tuicool&utm_medium=referral

  一共就五个函数


1、redisContext* redisConnect(const char *ip, int port)

2、redisContext* redisConnectWithTimeout(const char *ip, int port, timeval tv)

3、void redisFree(redisContext *c)

4、void *redisCommand(redisContext *c, const char *format...)

5、void freeReplyObject(void *reply)

  和Mysql一样,要对接,第一件事就是用IP和端口号建立连接什么的。


redis的端口号一般是6379,IP直接用127.0.0.1就可以了。


既然要用到IP和端口号,又是可能会变的东西,为了不使想要改变它们的时候得直接修改代码,我写了个配置文件:

redisConf.json

 {
"IP" : "127.0.0.1" ,
"PORT" :
}

  相应地,有提取配置信息的类

redisConf.h

 #ifndef __REDISCONF_H__
#define __REDISCONF_H__
#include <string>
namespace ccx{
using std::string;
class RedisConf
{
public:
RedisConf();
void getConf();
string getIP();
int getPort();
private:
string _ip;
int _port;
};
}
#endif

redisconf.cc

 #include "redisConf.h"
#include <stdlib.h>
#include <json/json.h>
#include <string>
#include <iostream>
#include <fstream> namespace ccx{ using std::ifstream;
using std::cout;
using std::endl; RedisConf::RedisConf()
{
getConf();
} void RedisConf::getConf()
{
ifstream ifs;
ifs.open("redisConf.json");
if(!ifs.good())
{
cout << "open RedisConf.json error" << endl;
exit(EXIT_FAILURE);
} Json::Value root;
Json::Reader reader;
if(!reader.parse(ifs, root, false))
{
cout << "RedisConf json reader error" << endl;
exit(EXIT_FAILURE);
} _ip = root["IP"].asString();
_port = root["PORT"].asInt();
ifs.close();
} string RedisConf::getIP()
{
return _ip;
} int RedisConf::getPort()
{
return _port;
} }

  

  然后是目前的redis类:

redis.h

 #ifndef __REDIS_H__
#define __REDIS_H__ #include "redisConf.h" #include <hiredis/hiredis.h> namespace ccx{ class Redis
{
public:
Redis();
public:
void Connect();
void disConnect();
public:
void setString(const string & key, const string & value);
void setString(const string & key, const int & value);
void setString(const string & key, const float & value);
private:
void setString(const string & data);
public:
void getString(const string & key, string & value);
void getString(const string & key, int & value);
void getString(const string & key, float & value);
private:
void getString(const string & key);
private:
void freeReply();
bool isError();
private:
RedisConf _conf;
redisContext * _context;
redisReply * _reply;
};
} #endif

  

  下面结合写好的代码说说前面的五个函数。


  函数1是用来连接redis的,具体如下:

 void Redis::Connect()
{
_context = ::redisConnect(_conf.getIP().c_str(), _conf.getPort());
cout << _conf.getIP() << "-" << _conf.getPort() << endl;
if(_context && _context->err)
{
cout << "connect redis error" << endl;
exit(EXIT_FAILURE);
}
cout << "redis Connect success" << endl;
}

  

  函数2是在1的基础上,添加了一个超时功能。


  函数3是在不使用redis了,要断开连接时使用的:

 void Redis::disConnect()
{
::redisFree(_context);
cout << "redis disConnect success" << endl;
}

  

  函数4稍微复杂一些,有点像C中的printf:

 printf("%d%s%d",d1,s1,d2);
printf("hello,world");

  

  可以这样用:

 char * command = "SET name lili";
reply = (redisReply*)::redisCommand(context, command);
char * s1 = "name";
char * s2 = "lili";
reply = (redisReply*)::redisCommand(context, "SET %s %s", s1, s2);
reply = (redisReply*)::redisCommand(context, "SET name lili");
7 ...

  第一个参数context是函数1或者2的返回值,告诉它要与哪里的redis进行交互。


reply指向命令结果的存储位置。


  函数5是用来清理函数4 的返回结果的:

 void Redis::freeReply()
{
if(_reply)
{
::freeReplyObject(_reply);
_reply = NULL;
}
}

  第6行是因为对这个函数不熟,就干脆清完之后给它赋值NULL。


  由于redis的string中存的可能是字符串、整形、浮点数,于是各自重载了三个版本的get与set方法,并重用一些函数,以减少代码量。


  对于set,直接用一个宏替换:

 #define SETSTRING(key, value) \
stringstream ss;\
ss << "SET " << key << " " << value;\
string s;\
getline(ss, s);\
setString(s);
 void Redis::setString(const string & key, const string & value)
{
SETSTRING(key, value);
}
void Redis::setString(const string & key, const int & value)
{
SETSTRING(key, value);
}
void Redis::setString(const string & key, const float & value)
{
SETSTRING(key, value);
}

  使用C++中的stringstream,会比用“%d”、“%s”、“%f”来区分类型少些代码。


两种方法的结果是相同的。


  它们共用的setString方法:

 void Redis::setString(const string & data)
{
freeReply();
_reply = (redisReply*)::redisCommand(_context, data.c_str());
if(!isError())
{
if (!(_reply->type == REDIS_REPLY_STATUS && strcasecmp(_reply->str,"OK") == ))
{
cout << "Failed to execute SET(string)" << endl;
}
}
}

  这里的isError是用来判断是否连接异常的:

 bool Redis::isError()
{
if(NULL == _reply)
{
freeReply();
disConnect();
Connect();
return true;
}
return false;
}

  如果连接异常,得断开重连。


  在redis命令行里,如果set成功,会提示“OK”。


于是,这里先判断了一下命令结果的数据类型,如果是字符串,再判断它是不是“OK”,以此来判断set是否成功。


  对于get,我试了各种方法,都无法直接从命令结果中提取出数字,暂时还没找到原因。


但是数字却可以以字符串格式得到。


于是,使用了atoi来处理:

 void Redis::getString(const string & key)
{
freeReply();
_reply = (redisReply*)::redisCommand(_context, "GET %s", key.c_str());
} void Redis::getString(const string & key, string & value)
{
getString(key);
if(!isError() && _reply->type == REDIS_REPLY_STRING)
{
value = _reply->str;
}
} void Redis::getString(const string & key, int & value)
{
getString(key);
if(!isError() && _reply->type == REDIS_REPLY_STRING)
{
value = ::atoi(_reply->str);
}
} void Redis::getString(const string & key, float & value)
{
getString(key);
if(!isError() && _reply->type == REDIS_REPLY_STRING)
{
value = ::atof(_reply->str);
}
}

redis.cc

 #include "redis.h"

 #include <string.h>
#include <stdlib.h> #include <sstream>
#include <iostream> namespace ccx{ using std::cout;
using std::endl;
using std::stringstream; #define SETSTRING(key, value) \
stringstream ss;\
ss << "SET " << key << " " << value;\
string s;\
getline(ss, s);\
setString(s); Redis::Redis()
: _conf()
{
} void Redis::Connect()
{
_context = ::redisConnect(_conf.getIP().c_str(), _conf.getPort());
cout << _conf.getIP() << "-" << _conf.getPort() << endl;
if(_context && _context->err)
{
cout << "connect redis error" << endl;
exit(EXIT_FAILURE);
}
cout << "redis Connect success" << endl;
} void Redis::disConnect()
{
::redisFree(_context);
cout << "redis disConnect success" << endl;
} void Redis::setString(const string & data)
{
freeReply();
_reply = (redisReply*)::redisCommand(_context, data.c_str());
if(!isError())
{
if (!(_reply->type == REDIS_REPLY_STATUS && strcasecmp(_reply->str,"OK") == ))
{
cout << "Failed to execute SET(string)" << endl;
}
}
} void Redis::setString(const string & key, const string & value)
{
SETSTRING(key, value);
} void Redis::setString(const string & key, const int & value)
{
SETSTRING(key, value);
} void Redis::setString(const string & key, const float & value)
{
SETSTRING(key, value);
} void Redis::getString(const string & key)
{
freeReply();
_reply = (redisReply*)::redisCommand(_context, "GET %s", key.c_str());
} void Redis::getString(const string & key, string & value)
{
getString(key);
if(!isError() && _reply->type == REDIS_REPLY_STRING)
{
value = _reply->str;
}
} void Redis::getString(const string & key, int & value)
{
getString(key);
if(!isError() && _reply->type == REDIS_REPLY_STRING)
{
value = ::atoi(_reply->str);
}
} void Redis::getString(const string & key, float & value)
{
getString(key);
if(!isError() && _reply->type == REDIS_REPLY_STRING)
{
value = ::atof(_reply->str);
}
} void Redis::freeReply()
{
if(_reply)
{
::freeReplyObject(_reply);
_reply = NULL;
}
} bool Redis::isError()
{
if(NULL == _reply)
{
freeReply();
disConnect();
Connect();
return true;
}
return false;
} }

test.cc

 #include "redis.h"

 #include <string>
#include <iostream> using std::cout;
using std::endl;
using std::string; int main()
{
ccx::Redis redis;
redis.Connect();
redis.setString("name", "lii"); string s;
redis.getString("name", s);
cout << s << endl; redis.setString("age", "");
redis.getString("age", s);
cout << s << endl; int i;
redis.getString("age", i);
cout << i << endl; redis.disConnect();
}

  测试结果如下:

127.0.0.1-
redis Connect success
lii redis disConnect success

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/587964.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-04-12
下一篇 2022-04-12

发表评论

登录后才能评论

评论列表(0条)

保存