redis++的编译 安装 使用方案
更新时间：2023年03月27日 08:10:35 作者：wx63993a9e4baf6
这篇文章主要介绍了redis++的编译 安装 使用方案的相关资料,需要的朋友可以参考下
前言
之前给公司作网关，一直想找个牛逼点的C++ 的 或者 C的 redis连接库。 结果很多都不近人意。
常见的是：hiredis 和hirredisvip
hiredis 和hirredisvip 都是最基础的。也没封装什么连接池啊，自动重连啊，那些东西。适合简单的场景。或者你自己手艺好，能自己封装一层好的接口。
后来尝试：cloredis
最后发现：redisplus plus
直到有一天我问同事，他们给我看redis官网推荐的C++的连接库，有好多库。好几页。而平时看的redis中文网推荐的才几个。艾玛。耽误事儿啊。
然后我接触了redisplus plus (redis++）。感觉蛮给力的玩意。
redis++地址
https://github.com/sewenew/redis-plus-plus
详细的信息可以看他们网站里的介绍。我这里只贴一段代码。
连接单机模式的
#include <unistd.h>
#include <chrono>
#include <tuple>
#include <iostream>
#include <vector>
#include <map>
#include <unordered_set>
#include <sw/redis++/redis++.h>
#include <sw/redis++/sentinel.h>
#include <sw/redis++/connection.h>
#include <sw/redis++/connection_pool.h>
//using namespace std;
using namespace sw::redis;
using namespace std::chrono;
int main()
{
ConnectionOptions connection_options;
connection_options.host = "192.168.11.85"; // Required.
connection_options.port = 16379; // Optional. The default port is 6379.
//connection_options.password = "auth"; // Optional. No password by default.
connection_options.db = 5; // Optional. Use the 0th database by default.
ConnectionPoolOptions pool_options;
pool_options.size = 3; // Pool size, i.e. max number of connections.
pool_options.wait_timeout = std::chrono::milliseconds(100);
ConnectionOptions connection_options2;
connection_options2.host = "192.168.11.85";
connection_options2.port = 16379;
connection_options2.db = 7;
ConnectionPoolOptions pool_options7;
pool_options7.size = 3;
pool_options7.wait_timeout = std::chrono::milliseconds(100);
Redis * redisofDB1 = NULL;
Redis * redisofDB7 = NULL;
// 开始连接
try{
redisofDB1 = new Redis(connection_options, pool_options);
redisofDB7 = new Redis(connection_options2, pool_options7);
}catch (const ReplyError &err) {
printf("RedisHandler-- ReplyError：%s \n",err.what());
return false ;
}catch (const TimeoutError &err) {
printf("RedisHandler-- TimeoutError%s \n",err.what());
return false ;
}catch (const ClosedError &err) {
printf("RedisHandler-- ClosedError%s \n",err.what());
return false ;
}catch (const IoError &err) {
printf("RedisHandler-- IoError%s \n",err.what());
return false ;
}catch (const Error &err) {
printf("RedisHandler-- other%s \n",err.what());
return false ;
}
/*
std::map<std::string, std::string> hashTerm;
redisofDB7->hgetall("FORWARD.PLAT.DETAIL",std::inserter(hashTerm, hashTerm.end()));
for(auto it1 = hashTerm.begin() ;it1 != hashTerm.end(); it1++)
{
std::cout <<"Plat ID：" <<it1->first <<std::endl;
std::cout << "Plat UserName & Password"<<it1->second <<std::endl;
}
*/
// 开始干活
auto cursor = 0LL;
auto pattern = "*";
auto count = 5;
//std::unordered_set<std::string> keys;
std::map<std::string, std::string> hashs;
while (true) {
cursor = redisofDB7->hscan("FORWARD.PLAT.DETAIL",cursor, pattern, count, std::inserter(hashs, hashs.begin()));
if (cursor == 0) {
break;
}
}
if(hashs.size() < 1)
{
printf("we get nothing !\n");
}
for(auto it1 = hashs.begin() ;it1 != hashs.end(); it1++)
{
std::cout <<"Plat ID：" <<it1->first <<std::endl;
std::cout << "Plat UserName & Password"<<it1->second <<std::endl;
}
OptionalString strValue = redisofDB1->hget("XNY.CARINFO","CRC01211711100232");
std::cout<< " CRC01211711100232 的 vin :" << *strValue << std::endl;
std::string straa = *strValue;
if(straa.empty())
{
std::cout << "we gete nothing " << std::endl ;
}
std::cout<< " ---- CRC01211711100232 的 details :" << straa << std::endl;
std::cout<< " ---- 下面试试hincrby ---- " << std::endl;
auto cursor2 = 0LL;
auto pattern2 ="*";
auto count2 = 20;
std::map<std::string, std::string> vv;
std::vector<std::string> vlist;
while (true) {
cursor2 = redisofDB7->hscan("FORWARD.LIST.002",cursor2, pattern2, count2, std::inserter(vv, vv.begin()));
if (cursor2 == 0) {
break;
}
}
for(auto it1 = vv.begin() ;it1 != vv.end(); it1++)
{
vlist.push_back(it1->first);
}
for(auto uu = vlist.begin(); uu !=vlist.end(); uu ++ )
{
std::cout << *uu << std::endl;
}
return 0;
}连接哨兵模式的
#include <unistd.h>
#include <chrono>
#include <tuple>
#include <iostream>
#include <vector>
#include <map>
#include <sw/redis++/redis++.h>
#include <sw/redis++/sentinel.h>
#include <sw/redis++/connection.h>
#include <sw/redis++/connection_pool.h>
//using namespace std;
using namespace sw::redis;
int main()
{
SentinelOptions sentinel_opts;
// sentinel_opts.nodes = {{"127.0.0.1", 9000},
// {"127.0.0.1", 9001},
// {"127.0.0.1", 9002}}; // Required. List of Redis Sentinel nodes.
sentinel_opts.nodes = {{"192.168.127.134", 26379}};// Required. List of Redis Sentinel nodes.
// Optional. Timeout before we successfully connect to Redis Sentinel.
// By default, the timeout is 100ms.
sentinel_opts.connect_timeout = std::chrono::milliseconds(200);
// Optional. Timeout before we successfully send request to or receive response from Redis Sentinel.
// By default, the timeout is 100ms.
sentinel_opts.socket_timeout = std::chrono::milliseconds(200);
auto sentinel = std::make_shared<Sentinel>(sentinel_opts);
ConnectionOptions connection_opts;
//connection_opts.password = "auth"; // Optional. No password by default.
connection_opts.db = 1;
connection_opts.connect_timeout = std::chrono::milliseconds(100); // Required.
connection_opts.socket_timeout = std::chrono::milliseconds(100); // Required.
ConnectionPoolOptions pool_opts;
pool_opts.size = 3; // Optional. The default size is 1.
auto redis = Redis(sentinel, "mymaster", Role::MASTER, connection_opts, pool_opts);
Redis* p = &redis;
std::map<std::string, std::string> hash;
p->hgetall("PLATINFO",std::inserter(hash, hash.end()));
for(auto it = hash.begin() ;it != hash.end(); it++)
{
std::cout <<"Plat ID：" <<it->first <<std::endl;
std::cout << "Plat UserName & Password"<<it->second <<std::endl;
}
ConnectionOptions connection_opts2;
//connection_opts.password = "auth"; // Optional. No password by default.
connection_opts2.db = 2;
connection_opts2.connect_timeout = std::chrono::milliseconds(100); // Required.
connection_opts2.socket_timeout = std::chrono::milliseconds(100); // Required.
auto redisDB2 = Redis(sentinel, "mymaster", Role::MASTER, connection_opts2, pool_opts);
Redis*pp = &redisDB2;
std::map<std::string, std::string> hashTerm;
pp->hgetall("TERMINAL:LIST:test123456789012",std::inserter(hashTerm, hashTerm.end()));
for(auto it1 = hashTerm.begin() ;it1 != hashTerm.end(); it1++)
{
std::cout <<"Plat ID：" <<it1->first <<std::endl;
std::cout << "Plat UserName & Password"<<it1->second <<std::endl;
}
// 是否存在
bool bb = p->hexists("PLATINFO","test123456789012");
std::cout << "PLATINFO 里 存在 test123456789012:" << bb << std::endl;
// hget - 注意这里，OptionalString 是大部分查询命令的返回值类型，要想转为string 需要加*
OptionalString strValue = p->hget("PLATINFO","test1234567890123");
std::cout<< " test123456789012 的 details :" << *strValue << std::endl;
std::string straa = *strValue;
if(straa.empty())
{
std::cout << "we gete nothing " << std::endl ;
}
std::cout<< " ---- test123456789012 的 details :" << straa << std::endl;
// 测试hkeys
std::vector<std::string> vPaltIDs;
p->hkeys("PLATINFO",std::inserter(vPaltIDs, vPaltIDs.end()));
for(auto vIter = vPaltIDs.begin();vIter != vPaltIDs.end(); vIter ++)
{
std::cout << *vIter << std::endl;
}
return 0;
}
//g++ -std=c++11 -I/usr/local/include -L/usr/local/lib -Wl,-rpath=../libc++ -o app testRedisSentinel.cpp -lredis++ -lhiredis -pthread
//连接集群模式的
#include <unistd.h>
#include <chrono>
#include <tuple>
#include <iostream>
#include <vector>
#include <map>
#include <unordered_set>
#include <sw/redis++/redis++.h>
#include <sw/redis++/sentinel.h>
#include <sw/redis++/connection.h>
#include <sw/redis++/connection_pool.h>
//using namespace std;
using namespace sw::redis;
using namespace std::chrono;
int main()
{
ConnectionOptions connection_options;
connection_options.host = "192.168.11.124"; // Required.
connection_options.port = 7001; // Optional. The default port is 6379.
//connection_options.password = "auth"; // Optional. No password by default.
connection_options.db = 0; // Optional. Use the 0th database by default.
ConnectionPoolOptions pool_options;
pool_options.size = 5; // Pool size, i.e. max number of connections.
pool_options.wait_timeout = std::chrono::milliseconds(100);
RedisCluster* redisofDB1 = NULL;
try{
redisofDB1 = new RedisCluster(connection_options, pool_options);
}catch (const ReplyError &err) {
printf("RedisHandler-- ReplyError：%s \n",err.what());
return false ;
}catch (const TimeoutError &err) {
printf("RedisHandler-- TimeoutError%s \n",err.what());
return false ;
}catch (const ClosedError &err) {
printf("RedisHandler-- ClosedError%s \n",err.what());
return false ;
}catch (const IoError &err) {
printf("RedisHandler-- IoError%s \n",err.what());
return false ;
}catch (const Error &err) {
printf("RedisHandler-- other%s \n",err.what());
return false ;
}
// 连接成功- 下面开始干活儿。
printf("-----连接成功，下面开始干活儿-----\n");
#if 1
//1.先测试一个gethall 用hscan代替得吧
auto cursor = 0LL;
auto pattern = "*";
auto count = 5;
//std::unordered_set<std::string> keys;
std::map<std::string, std::string> hashs;
while (true) {
cursor = redisofDB1->hscan("farm:status:NJTEST0000000005_20200702132812",cursor, pattern, count, std::inserter(hashs, hashs.begin()));
if (cursor == 0) {
break;
}
}
if(hashs.size() < 1)
{
printf("we get nothing !\n");
}
std::cout << "the hashs.size = " << hashs.size() << std::endl;
for(auto it1 = hashs.begin() ;it1 != hashs.end(); it1++)
{
std::cout <<"key:" <<it1->first << "Value:"<<it1->second <<std::endl;
}
#endif
#if 0
// 2.测试hsetnx
std::cout << "------------------------测试hsetnx---------------------------" << std::endl;
std::string strValue = "SUBMIT$2$TES21129BH2000001$UPDATE$TIME:20200818163607,TYPE:3,VALUE:MjIzLjIyMy4xODcuMzUsMTA1MCxmdGFkbWluLGZ0YWRtaW44MTY0NSxINENfVjEuMy4zN18yMDIwMDgxN19hNDdhLmJpbiww,MODEL:2";
//std::string strfeild = "1597739777";
bool vBol = redisofDB1->hsetnx("farm:command:TES21129BH2000001", std::to_string(1597739778), strValue);
std::cout << "hsetnx wanbi : " << vBol << std::endl;
//3.测试hdel
bool vBol2 = redisofDB1->hdel("farm:command:TES21129BH2000001", strfeild);
std::cout << "hdel wanbi : " << vBol2 << std::endl;
//4.测试del
bool vBol3 = redisofDB1->del("farm:command:NJTEST0000000009");
std::cout << "del wanbi : " << vBol3 << std::endl;
//5.hlen
long long llen = redisofDB1->hlen("farm:status:TST1010191210110_20200701114501");
std::cout<< "the len is :" << llen << std::endl;
//6.测试hset
bool bbb = redisofDB1->hset("farm:clientnum","WUZ11010BC100009","009");
std::cout << "hset finished is :" << bbb << std::endl;
//7.测试expire
redisofDB1->expire("farm:status:NJTEST0000000005_20200624135512",60);
#endif
return 0;
}到此这篇关于redis++的编译 安装 使用方案的文章就介绍到这了,更多相关redis++的使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
本文主要介绍了k8s部署redis哨兵的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-07-07
本文主要介绍了Redis底层数据结构SkipList的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-05-05
用redis做缓存，是因为redis有着很优秀的读写能力，在集群下可以保证数据的高可用，那么今天通过本文给大家讲解下SpringBoot使用Redis的缓存的方法，感兴趣的朋友一起看看吧2021-08-08
这篇文章主要介绍了redis安装和配置,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-08-08
这篇文章主要介绍了redis hash应用场景和常用命令,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-08-08
这篇文章主要介绍了使用redis获取自增序列号实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-12-12
如果结构规划不合理、命令使用不规范,会造成系统性能达到瓶颈、活动高峰系统可用性下降,也会增大运维难度,本文主要介绍了redis key命名规范的设计,感兴趣的可以了解一下2024-03-03
详解RedisTemplate下Redis分布式锁引发的系列问题
这篇文章主要介绍了详解RedisTemplate下Redis分布式锁引发的系列问题，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-03-03
在使用redis的过程中，发现有些时候需要原子性去操作redis命令，而redis的lua脚本正好可以实现这一功能。这篇文章主要介绍了redis中lua脚本的简单使用,需要的朋友可以参考下2021-10-10
这篇文章主要介绍了redis脚本命令执行问题(redis.call),分别介绍了redis-cli命令行中执行及linux命令行中执行问题，本文给大家介绍的非常详细，需要的朋友参考下吧2022-03-03
最新评论