hiredis处理zscan的reply

  zscan的返回值可以看做是一个二维数组,第一维包含两个元素:string类型的游标cursor和集合元素数组;第二维即集合元素数组,这个数组交替存放着集合元素和score,元素和score也都是string类型的。当然所有的值都是通过指针来引用的,所以使用时务必小心。

  当cursor为0时表示,扫描结束;非0的cursor值用来进行后续扫描。

  集合元素数组reply->elements指示当前数组中包含多少个元素(指针),据此来遍历整个数组。

  示例代码如下:

//cLocal points to the local redis

llCursor=0;

done=false;

while(!done)

{

  cmd="zscan "+setName+" %lld count 10";
  reply = (redisReply *)redisCommand(cLocal, cmd.c_str(), llCursor);
  if(reply == NULL)
  {
    cout << "scan " << setName << "failed, error is: " << cLocal->errstr;
    redisFree(cLocal);
    cLocal = NULL;
    break;
  }

  if(reply->type == REDIS_REPLY_ARRAY)
  {
    if(reply->elements == 0)
    {
      done=true;
      cout << "get 0 msg from " << setName;
    }
    else
    {
      llCursor=boost::lexical_cast<long long>(reply->element[0]->str);

      redisReply ** siteCounters=reply->element[1]->element;
      for(size_t i=0; i<reply->element[1]->elements; i++)
      {
        string elem = siteCounters[i++]->str;
        string score = siteCounters[i]->str;

      }
      if(llCursor == 0)
      {
        done=true;
      }
    }
  }
  else
  {
    done=true;
  }
  freeReplyObject(reply);

}

  本文转自我的个人博客“零一积流”,原链接在这里

时间: 2024-10-10 13:51:14

hiredis处理zscan的reply的相关文章

linux下使用hiredis异步API实现sub/pub消息订阅和发布的功能

最近使用redis的c接口--hiredis,使客户端与redis服务器通信,实现消息订阅和发布(PUB/SUB)的功能,我把遇到的一些问题和解决方法列出来供大家学习. 废话不多说,先贴代码. redis_publisher.h /************************************************************************* > File Name: redis_publisher.h > Author: chenzengba > Ma

hiredis aeStop仅在redis命令的回调函数中生效 分析

hiredis 是 redis 的client端C语言 lib,  hiredis拥有同步和异步的API, 异步API的实现有多种方法,分别依赖libev, libevent, libuv, ae等等,其中ae是redis内部实现的一个异步事件处理模块. 稍微修改了hiredis的example-ae.c代码:在一个线程里面循环10次执行命令ping, 检查redisserver, 如下所示, 线程发完10次ping后,调用disconnect, 发现aeMain函数并未退出,程序一直阻塞住.

从hiredis使用出core谈谈redis多线程的使用【转】

在实际工作中,我需要使用redis的客户端去连接redis,于是选择了hiredis客户端(公司强推).  hiRedis 是 Redis 官方指定的 C 语言客户端开发包,支持 Redis 完整的命令集.管线以及事件驱动编程. 1.情景描述 1.1 使用场景 一个epool模型的服务器不断接受外界请求,这个服务器框架给用户预留一个回调函数(多线程),回调函数为用户自己去实现的业务逻辑,其中redis的使用就需要在这个回调函数内部实现. 1.2 初步实现方案 在程序启动的时候,我就初始化redi

Redis学习之路(003)- hiredis安装及测试

一. hiredis下载地址及C API  github下载:https://github.com/redis/hiredis 安装脚本: 1 #!/bin/zsh 2 git clone https://github.com/redis/hiredis.git 3 cd hiredis 4 make 5 make install 二. 文件pc,我是把libhiredis.so放到/usr/local/lib/中,把hiredis.h放到/usr/local/inlcude/hiredis/中

hiredis中异步的实现小结

前言 一般情况下我们使用的都是hiredis的同步通信机制,这种机制下每当你向服务器发送命令请求,程序都会阻塞直到收到服务器的回复并处理.而如果采用异步通信,程序就不需要阻塞等待服务器的回复,而是直接继续执行后边的代码,当服务器回复到来后由程序中预先注册的回调函数来处理回复. 同步通信下程序写起来逻辑更清晰,代码量也少,但是由于每次请求都要停下来等待回复,可能会影响程序的运行速度.异步通信下程序逻辑会变得很复杂,你必须考虑回调函数的编写,并且需要多开一个线程来实现异步事件的处理,但是异步通信下程

Redis客户端连接方式Hiredis简单封装使用,连接池、屏蔽连接细节

工作需要对Hiredis进行了简单封装,实现功能: 1.API进行统一,对外只提供一个接口: 2.屏蔽上层应用对连接的细节处理: 3.底层采用队列的方式保持连接池,保存连接会话: 4.重连时采用时间戳进行控制,每隔一定时间(3s)重连一次,防止频繁重试造成的不必要浪费. 先看一下Hiredis的常用数据结构与API: //hiredis/hiredis.h /* Context for a connection to Redis */ typedef struct redisContext {

基于Hiredis异步API的聊天系统实现

基于Hiredis异步API的聊天系统实现 上一篇文章http://blog.csdn.net/qq_34788352/article/details/51313027使用Hiredis的同步API实现了发送消息的客户端,当我使用同步API实现订阅频道客户端时,一旦订阅频道,就会出现无法操作的情况,这是就是同步和异步的问题.使用同步API,订阅频道后,客户端会进入阻塞状态,等待订阅频道发布的消息,不能实现既订阅频道,又能发布消息的功能.为了实现一个客户端既能订阅频道,又能发布消息的功能,就需要使

redis C接口hiredis 简单函数使用介绍

hiredis是redis数据库的C接口,目前只能在linux下使用,几个基本的函数就可以操作redis数据库了. 函数原型:redisContext *redisConnect(const char *ip, int port) 说明:该函数用来连接redis数据库,参数为数据库的ip地址和端口,一般redis数据库的端口为6379 该函数返回一个结构体redisContext. 函数原型:void *redisCommand(redisContext *c, const char *form

hiredis C接口

redis C接口hiredis 简单函数使用介绍 2013-10-18 13:41 7636人阅读 评论(0) 收藏 举报 from : http://blog.csdn.net/kingqizhou/article/details/8104693 hiredis是redis数据库的C接口,目前只能在linux下使用,几个基本的函数就可以操作redis数据库了. 函数原型:redisContext *redisConnect(const char *ip, int port) 说明:该函数用来