Redis——redispluspls库list及set范例相干接口利用

list 范例相干接口

lpush和lrange

1. void lrange_lpush(sw::redis::Redis& redis){
2.     std::cout<<"lpush 和 lrange"<<std::endl;
3.     redis.flushall();
5.     //插入单个元素
6.     redis.lpush("key","111");
8.     //插入一组元素，基于初始化列表
9.     redis.lpush("key",{"222","333","444"});
11.     //插入一组元素，基于迭代器
12.     vector<string> values = {"555","666","777"};
13.     redis.lpush("key",values.begin(),values.end());
15.     //lrange获取列表中元素
16.     vector<string> result;
17.     auto it  = std::back_inserter(result);
18.     redis.lrange("key",0,-1,it);
20.     for(const auto& elem:result){
21.         std::cout<<elem<<std::endl;
22.     }
23. }

复制代码

由于lpush是头插，所以后来的元素在前面
rpush

1. std::cout<<"lpush 和 lrange"<<std::endl;
2.     redis.flushall();
4.     //插入单个元素
5.     redis.lpush("key","111");
7.     //插入一组元素，基于初始化列表
8.     redis.lpush("key",{"222","333","444"});
10.     //插入一组元素，基于迭代器
11.     vector<string> values = {"555","666","777"};
12.     redis.lpush("key",values.begin(),values.end());
14.     //lrange获取列表中元素
15.     vector<string> result;
16.     auto it  = std::back_inserter(result);
17.     redis.lrange("key",0,-1,it);
19.     for(const auto& elem:result){
20.         std::cout<<elem<<std::endl;
21.     }

复制代码

lpop和rpop

1. void lpop_rpop(sw::redis::Redis& redis){
2.     std::cout<<"rpush 和 lrange"<<std::endl;
3.     redis.flushall();
5.     redis.rpush("key",{"1","2","3","4"});
7.     auto result = redis.lpop("key");
8.     //插入一组元素，基于迭代器
9.    if(result) std::cout<<"lpop:"<<result.value()<<std::endl;
11.    result = redis.rpop("key");
12.    if(result) std::cout<<"rpop:"<<result.value()<<std::endl;
13. }

复制代码

blpop和brpop

这里先了解一下blpop的返回值

   什么是 OptionalStringPair, optional里面包裹了一个pair，pair里面是string
  blpop要返回的内容是两个部分

• 这个元素属于哪个list（blpop可以同时监听多个list）
  
• 当前被删除的元素
  

blpop还可以设置超时时间，如果在指定时间内，还没有其他客户端往指定的list中插入元素，此时blpop就直接返回了，此时返回的就是一个无效值了

1. std::cout<<"blpop"<<std::endl;
2.     redis.flushall();
4.     auto result =  redis.blpop("key");
5.     if(result) {
6.         std::cout<<"key:"<<result.value().first<<std::endl;//result->first
7.         std::cout<<"elem:"<<result.value().second<<std::endl;//result->second
8.     }else{
9.         std::cout<<"result 无效"<<std::endl;
10.     }

复制代码

这里由于没有元素在里面，blpop就被阻塞到这里了，别的开一个中端在redis-cli中插入key，就没有阻塞了

  auto result = redis.blpop({"key","key2","key3"});当然也可以一次监听多个key，只要其中有一个key有元素插入，就会制止阻塞
设置超时时间

1.   using namespace std::chrono_literals;
2.     std::cout<<"blpop"<<std::endl;
3.     redis.flushall();
5.     auto result =  redis.blpop("key",5s);
6.     if(result) {
7.         std::cout<<"key:"<<result.value().first<<std::endl;
8.         std::cout<<"elem:"<<result.value().second<<std::endl;
9.     }else{
10.         std::cout<<"result 无效"<<std::endl;
11.     }

复制代码

llen

1. void llen(sw::redis::Redis& redis){
2.     std::cout<<"llen"<<std::endl;
3.     redis.flushall();
5.     redis.lpush("key",{"111","222","333","444"});
6.     long long len = redis.llen("key");
7.     std::cout<<len<<std::endl;
8. }
9. int main()
10. {
11.     sw::redis::Redis redis("tcp://127.0.0.1:6379");
12.     llen(redis);
13.     return 0;
14. }

复制代码

   看到这里不难发现，redis-plus-plus这个库，接口设计的风格，好坏常统一的
  当一个函数，参数需要通报多个参数的时候，往往都是支持 初始化列表 大概是一对迭代器的方式来实现的
  当一个函数 返回值需要多个数据的时候，也往往会借助插入迭代器，来实现往一个容器中添加元素的效果
  当某些场景涉及到无效值的时候，往往会搭配 std:ptional来举行利用
  很多C++的代码，都是按照上方式来设计的
  set 范例相干接口

sadd和smembers

1. std::cout<<"sadd 和 smemers"<<std::endl;
2.     redis.flushall();
4.     //一次添加一个元素
5.     redis.sadd("key","111");
6.    
7.     //一次添加多个元素使用初始化列表
8.     redis.sadd("key",{"222","333","444"});
10.     //一次添加多个元素使用迭代器
11.     std::set<string> elems = {"555","666","777"};
12.     redis.sadd("key",elems.begin(),elems.end());
14.     //获取上述元素
15.     //vector<string> result;
16.     //auto it  = std::back_inserter(result);
17.      std::set<string> result;
18.     //由于set的元素的顺序是固定的，插入的位置无所谓，最终都是有序的，但是这里必须要 传入一个插入的位置
19.     auto it  = std::inserter(result,result.end());//begin,end,或者其他位置都可以
20.     redis.smembers("key",it);
21.     for(const auto&x:result){
22.         std::cout<<x<<std::endl;
23.     }

复制代码

sismember

1. std::cout<<"sismember "<<std::endl;
2.     redis.flushall();
4.     redis.sadd("key",{"222","333","444"});
5.     bool ret =  redis.sismember("key","222");
6.     std::cout<<"222-ret:"<<ret<<std::endl;
8.     ret =  redis.sismember("key","111");
9.     std::cout<<"111-ret:"<<ret<<std::endl;

复制代码

scard

1.   std::cout<<"scard "<<std::endl;
2.     redis.flushall();
4.     redis.sadd("key",{"222","333","444"});
5.    
6.     long long result = redis.scard("key");
7.     std::cout<<"result:"<<result<<std::endl;

复制代码

spop

1. std::cout<<"spop "<<std::endl;
2.     redis.flushall();
4.     redis.sadd("key",{"111","222","333","444"});
5.    
6.     auto result = redis.spop("key");
7.     if(result) std::cout<<result.value()<<std::endl;
8.     else std::cout<<"result 无效"<<std::endl;

复制代码

sinster

1. std::cout<<"sinter "<<std::endl;
2.     redis.flushall();
4.     redis.sadd("key1",{"222","333","444"});
5.     redis.sadd("key2",{"111","222","333"});
7.     std::set<string> result;
8.     auto it = std::inserter(result,result.end());
9.     redis.sinter({"key1","key2"},it);
10.     for(const auto&elem:result){
11.         std::cout<<elem<<std::endl;
12.     }

复制代码

sinterstore

1. std::cout<<"sinterstore "<<std::endl;
2.     redis.flushall();
4.     redis.sadd("key1",{"222","333","444"});
5.     redis.sadd("key2",{"111","222","333"});
6.     long long len = redis.sinterstore("key3",{"key1","key2"});
7.     std::cout<<"len: "<<len<<std::endl;
8.    
9.     std::set<string> result;
10.     auto it  = std::inserter(result,result.end());
11.     redis.smembers("key3",it);
13.     for(const auto&x:result){
14.         std::cout<<x<<std::endl;
15.     }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。