hiredis之异步调用

下面是 hiredis 异步调用使用的一个例子（算是对于官方简单例子的一个补充，可能长得更像实际业务中使用的样子），一般使用场景是我们监听一个端口，当有请求来的时候，就执行回调，而回调里面可能需要读写 Redis。（涉及 IO 的操作都需要异步处理！）

#include <hiredis/hiredis.h>
#include <hiredis/adapters/libevent.h>
#include <sys/socket.h>

void do_accept(evutil_socket_t listener, short event, void *arg) {
    redisAsyncContext *ac = (redisAsyncContext *)arg;
    evutil_socket_t fd;
    struct sockaddr_in sin;
    socklen_t slen = sizeof(sin);
    fd = accept(listener, (struct sockaddr *)&sin, &slen);
    if (fd < 0) {
        perror("[ERROR] accept error");
        return;
    }
    redisAsyncCommand(ac, NULL, NULL, "SET key test");
}
int main() {
    signal(SIGPIPE, SIG_IGN);
    struct event_base *base = event_base_new();

    /* 创建套接字 */
    int listenfd;
    struct sockaddr_in servaddr;
    if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        printf("[ERROR] socket error");
        exit(-1);
    }

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port = htons(17777);

    bind(listenfd, (const struct sockaddr*) &servaddr, sizeof(servaddr));

    if (listen(listenfd, 1024) < 0) {
        printf("[ERROR] listen error");
        exit(-1);
    }


    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);
    c->data = (void *)base;

    struct event *listen_event;
    listen_event = event_new(base, listenfd, EV_READ|EV_PERSIST, do_accept, (void *)c);
    event_add(listen_event, NULL);

    event_base_dispatch(base);

    return 0;
}