文档章节

hiredis中异步的实现小结

M
 MikeMei
发布于 2017/04/07 10:51
字数 1901
阅读 36
收藏 0
点赞 0
评论 0

前言

    一般情况下我们使用的都是hiredis的同步通信机制,这种机制下每当你向服务器发送命令请求,程序都会阻塞直到收到服务器的回复并处理。而如果采用异步通信,程序就不需要阻塞等待服务器的回复,而是直接继续执行后边的代码,当服务器回复到来后由程序中预先注册的回调函数来处理回复。

    同步通信下程序写起来逻辑更清晰,代码量也少,但是由于每次请求都要停下来等待回复,可能会影响程序的运行速度。异步通信下程序逻辑会变得很复杂,你必须考虑回调函数的编写,并且需要多开一个线程来实现异步事件的处理,但是异步通信下程序在发送完redis命令请求后不需要等待回复,可以继续做其他事,程序速度的提升自然不言而喻。异步通信比较适合程序对速度要求比较高的情况下。

hiredis中的异步api

    hiredis中有一套异步api可供我们使用。要使用hiredis中的异步api你必须先了解hiredis中的异步实现。hiredis的异步主要是通过libevent等异步事件触发库来实现的。hiredis可以通过一下事件触发库:libae(redis自带的异步事件触发库)、libev、libuv、libevent中的一个实现。在我的实际使用中,libae库出现了头文件问题,libev出现了异步消息无法接受的问题,libuv没有安装成功,所有我最终选择了libevent库,而这个库的表现也非常稳定。

    要使用redis客户端的异步通信,单靠hiredis自带的那几个api是不够的,还需要事件触发库的支持。这里要黑一下hiredis的github主页,上边的异步api说明中没有讲解hiredis异步api所需的那些事件触发库,让我想当然的以为单单依靠hiredis的自带api就可以实现异步,结果浪费了大量时间去调试错误的程序,希望大家引以为戒。下边就以libevent为例讲一下hiredis异步api用到的事件触发库。

事件触发库libevent

    libevent是一个成熟事件触发库,分布式缓存软件memcached就使用了这个库。libevent可以实现对多种事件的触发管理。详细的说,你可以通过libevent去对各种IO事件进行触发注册,之后如果该IO事件发生,libevent就会直接调用你之前为IO事件注册的函数来处理这个事件。除了IO事件外,libevent还可以管理定时器事件、信号事件,功能非常的强大。

    下边简单讲一下libevent的使用。libevent本身的使用是比较复杂的,考虑到我们的重点是hiredis,所以这里只讲hiredis中要用到的。libevent首先要设置并添加你要监听的异步事件,这一步hiredis已经为你做好了,只需要两步:

    base = event_base_new();//创建一个新的libevent事件处理实例。

    redisLibeventAttach(ac, base);//对hiredis进行libevent事件注册,这里的base就是上一步创建的事件处理实例

    event_base_dispatch(base);//开始libevent事件处理循环。运行这个函数后libevent才真正开始监听并处理事件。在实际的hiredis使用中这个函数通常要单独开一个线程去运行,因为这个函数运行后就会陷入死循环。

    hiredis用到的libevent函数就这么几个,是不是觉得很简单!

hiredis异步APi的使用

    下边才是重点,如何使用hiredis的异步API来实现我们要做的redi异步通信。

    首先要创建连接:

    redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379);

    这里的创建连接跟同步下区别不大。但是需要注意的是异步的连接函数会立刻返回,不论你的程序是否真的连上了redis服务器。是否成功连接只能在连接回调函数中确定。所以不要指望依靠这个函数去检查你的连接是否成功建立。

    可以通过这个函数注册连接回调函数:

    redisAsyncSetConnectCallback(c, ccdbRedisAsync::connectCallback);

    回调函数需要是下边的格式:

    void ccdbRedisAsync::connectCallback(const redisAsyncContext *c, int status)

    其中参数status会告诉你连接是否成功。

    以下函数实现断开连接以及相应的回调函数:

    redisAsyncDisconnect(c);//断开连接

    redisAsyncSetDisconnectCallback(c, ccdbRedisAsync::disconnectCallback);//回调函数的格式和使用同连接回调函数

    如果你想实现redis的断线重连,那么就可以考虑在上边的回调函数中实现。

        注意创建连接后还要进行之前的libevent事件注册过程。

    连接创建好后解可以发送命令了。异步命令的发送方式和同步很像,区别在于异步发送函数执行后只能得到该命令是否成功过加入发送队列的返回,而无法确定这个命令是否发送成功以及命令的返回。

    int redisAsyncCommand(

    redisAsyncContext *ac, redisCallbackFn *fn, void *privdata, const char *format, ...);//参数fn是回调函数的地址,privdate可以用来存储            任意的用户指针,这个指针可以在回调函数调用的时候得到

    一般你需要设置一个回调函数来处理命令的返回:

    void(redisAsyncContext *c, void *reply, void *privdata);

    其中的reply参数指向的是与同步下有相同定义的reply结构。注意此处的reply占用的空间是会在回调函数执行后被自动释放的,这点要区别于同步。private参数是你发送命令时所指定的指针,你可以把一些信息,例如所执行的命令保存在这个指针的空间中,这样回调函数被调用的时候你才能判断这个回复是由之前执行的哪个命令产生的。

    上边就是异步redis所需的主要API了。

例程

下边的例程来自hiredis的作者。注意这个历程里边没有为libevent事件处理单开线程,这在实际运用中是不多见的。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>

#include <hiredis.h>
#include <async.h>
#include <adapters/libevent.h>

//设置命令执行后的回调函数
void getCallback(redisAsyncContext *c, void *r, void *privdata) {
    redisReply *reply = r;
    if (reply == NULL) return;
    printf("argv[%s]: %s\n", (char*)privdata, reply->str);

    /* Disconnect after receiving the reply to GET */
    redisAsyncDisconnect(c);
}

//设置连接回调函数
void connectCallback(const redisAsyncContext *c, int status) {
    if (status != REDIS_OK) {
        printf("Error: %s\n", c->errstr);
        return;
    }
    printf("Connected...\n");
}

//设置断开连接回调函数
void disconnectCallback(const redisAsyncContext *c, int status) {
    if (status != REDIS_OK) {
        printf("Error: %s\n", c->errstr);
        return;
    }
    printf("Disconnected...\n");
}

int main (int argc, char **argv) {
    signal(SIGPIPE, SIG_IGN);//捕捉程序收到数据包时候的信号
    struct event_base *base = event_base_new();//新建一个libevent事件处理

    redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379);//新建异步连接
    if (c->err) {
        /* Let *c leak for now... */
        printf("Error: %s\n", c->errstr);
        return 1;
    }

    redisLibeventAttach(c,base);//将连接添加到libevent事件处理
    redisAsyncSetConnectCallback(c,connectCallback);//设置连接回调
    redisAsyncSetDisconnectCallback(c,disconnectCallback);//设置断开连接回调
    redisAsyncCommand(c, NULL, NULL, "SET key %b", argv[argc-1], strlen(argv[argc-1]));//发送set命令
    redisAsyncCommand(c, getCallback, (char*)"end-1", "GET key");//发送get命令
    event_base_dispatch(base);//开始libevent循环。注意在这一步之前redis是不会进行连接的,前边调用的命令发送函数也没有真正发送命令
    return 0;
}

 

本文转载自:http://blog.csdn.net/l1902090/article/details/38583663?utm_source=tuicool&utm_medium=referral

共有 人打赏支持
M
粉丝 0
博文 57
码字总数 16059
作品 0
深圳
高级程序员
CentOS编译swoole 的hiredis遇到的坑

在centos6.8的环境下,最开始编译swoole不带任何参数,没任何问题。今天在测试swoole的异步redis。编译hiredis后,再执行swoole相关测试脚本,总提示如下错误: 关于类似的问题,swoole官方文...

jichun ⋅ 05/06 ⋅ 0

windows下vs2013使用C++访问redis

刚开始在windows下使用c++访问reids各种报错,经过网上到处搜方案,终于可以在windows下访问redis了, 特将注意事项记录下来: 1.获取redis Window下的开发库源码,从github获取 windows版:...

xumaojun ⋅ 04/29 ⋅ 0

开源企业级开发框架 - NodeWk

基于Sails.js MVC开发,实现常用的系统、微信、CMS等功能 PS:如果对Java开发框架感兴趣,可以看这里:https://gitee.com/wizzer/NutzWk 基于Sailsjs的Node.js开源企业级开发框架 NodeWk 1.0...

Wizzer ⋅ 2016/06/27 ⋅ 1

windows xp下redis客户端无法连接服务端(Could not connect to Redis at xxx:poll(2))

PR:https://github.com/MicrosoftArchive/redis/pull/598 错误描述与处理办法 用redis-cli连接服务端时,错误提示好像是Could not connect to Redis at xxx:poll(2),事实上使用微软的redis...

SK木眠 ⋅ 05/14 ⋅ 0

基于 Swoole 的协程 PHP 开发框架 - IMI

介绍 IMI 是基于 Swoole 开发的协程 PHP 开发框架,拥有常驻内存、协程异步非阻塞IO等优点。 IMI 框架文档丰富,上手容易,致力于让开发者跟使用传统 MVC 框架一样顺手。 IMI 框架底层开发使...

宇润 ⋅ 06/21 ⋅ 0

IMI 正式发布!基于 Swoole 的协程 PHP 开发框架

介绍 IMI 是基于 Swoole 开发的协程 PHP 开发框架,拥有常驻内存、协程异步非阻塞IO等优点。 IMI 框架文档丰富,上手容易,致力于让开发者跟使用传统 MVC 框架一样顺手。 IMI 框架底层开发使...

宇润 ⋅ 06/21 ⋅ 0

Redis使用总结(hiredis on windows in Microsoft Archive)

前段时间做的开发有缓存数据持久化的需求,最终采用了redis,实行效果还不错,聊做总结。 〇、技术选型 要解决问题首先要分析问题。应用角色是移动物联网平台OneNET和公司SCADA系统MQ中间件的...

SK木眠 ⋅ 05/15 ⋅ 0

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

在实际工作中,我需要使用redis的客户端去连接redis,于是选择了hiredis客户端(公司强推)。 hiRedis 是 Redis 官方指定的 C 语言客户端开发包,支持 Redis 完整的命令集、管线以及事件驱动编...

TrevorKuo ⋅ 2015/09/02 ⋅ 0

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

在实际工作中,我需要使用redis的客户端去连接redis,于是选择了hiredis客户端(公司强推)。 hiRedis 是 Redis 官方指定的 C 语言客户端开发包,支持 Redis 完整的命令集、管线以及事件驱动编...

jungleliu0923 ⋅ 2014/02/25 ⋅ 6

hiredis-win32+libevent

决定用redis作为cache服务器,要求其服务端和客户端都支持跨平台win和linux 但我发现redis(/作者)对windows态度极差,不考虑,不支持 微软公司的闲人们主动靠过去,推出win版。这么一来,r...

雅各宾 ⋅ 2013/07/25 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

istio 文档

https://istio.io/docs/concepts/ https://istio.io/docs/concepts/traffic-management/handling-failures/ https://istio.io/docs/concepts/traffic-management/rules-configuration/......

xiaomin0322 ⋅ 14分钟前 ⋅ 0

编程语言的作用及与操作系统和硬件的关系

一、编程语言的作用及与操作系统和硬件的关系 作用:编程语言是计算机语言,是一种程序员与计算机之间沟通的介质,通过编程语言可以使得计算机能够根据人的指令一步一步去工作,完成某种特定...

slagga ⋅ 25分钟前 ⋅ 0

runtime实现按钮点击事件

也不能说是实现吧,,,就是有点类似于RAC里边的写法,不用给btn添加另外的点击事件,就那个add...select...这样子很不友好,来看下代码: [self.btn handleControlEvent:UIControlEventTou...

RainOrz ⋅ 25分钟前 ⋅ 0

Windows系统运维转linux系统运维的经历

开篇之前,首先介绍一下我的背景把:我是一个三线城市的甲方运维。最近,在《Linux就该这么学》书籍的影响下和朋友小A(Linux运维已经三年了,工资也比我的高很多)的影响下,决定转行。最近...

linux-tao ⋅ 26分钟前 ⋅ 0

zip压缩工具,tar打包工具

zip压缩工具 zip打包工具跟前面说到的gzip,bz2,xz 工具最大的不一样是zip可以压缩目录。如果没有安装,需要使用yum install -y zip 来安装。安装完之后就可以直接使用了,跟之前提到的压缩...

李超小牛子 ⋅ 33分钟前 ⋅ 0

使用npm发布自己的npm组件包

一、注册npm账号 官网:https://www.npmjs.com/signup 注册之后需要进行邮箱验证,否则后面进行组件包发布时候会提示403错误,让进行邮箱核准。 二、本地新建一个文件夹,cd进入后使用npm i...

灰白发 ⋅ 35分钟前 ⋅ 0

010. 深入JVM学习—垃圾收集策略概览

1. 新生代可用GC策略 1. 串行GC(Serial Copying) 算法:复制(Copying)清理算法; 操作步骤: 扫描年轻代中所有存活的对象; 使用Minor GC进行垃圾回收,同时将存活对象保存到“S0”或“S...

影狼 ⋅ 36分钟前 ⋅ 0

JVM性能调优实践——JVM篇

在遇到实际性能问题时,除了关注系统性能指标。还要结合应用程序的系统的日志、堆栈信息、GClog、threaddump等数据进行问题分析和定位。关于性能指标分析可以参考前一篇JVM性能调优实践——性...

Java小铺 ⋅ 37分钟前 ⋅ 0

误关了gitlab sign-in 功能的恢复记录

本想关sign-up的,误点了sign-in 退出后登录界面提示: No authentication methods configured 一脸懵逼.. 百度后众多方案说修改application_settings 的 signin_enabled字段; 实际上新版本字段...

铂金蛋蛋 ⋅ 37分钟前 ⋅ 0

登录后,后续请求接口没有带登录cookie可能原因

1.XMLHttpRequest.withCredentials没设置好,参考https://developer.mozilla.org/zh-CN/docs/Web/API/XMLHttpRequest/withCredentials...

LM_Mike ⋅ 38分钟前 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部