当前位置

网站首页> 程序设计 > 程序资讯 > 软件更新资讯 > 浏览文章

acl 框架中的 Redis 库已经支持集群版 Redis 3.0

作者:小梦 来源: 网络 时间: 2024-01-12 阅读:

3月21日 深圳 OSC 源创会开始报名罗,送华为海思开发板

据 redis 官方网站显示,支持集群版的 redis3.0 快要发布了(现在已经到了redis3.0 rc4 版本),这样使用者就不需要自己花很大力气来针对 redis 进行分库了,之前人们为了使单机版的 redis 能支持集群方式,往往是在客户端或通过加一个中间的代理层(比如使用 tweaproxy)做很多工作,现在有了集群版的 redis3.0 ,这些额外的操作都不再需要。

为了能够支持集群版的 redis 服务,另外增加了两个主要的重定向指令需要客户端能够支持:MOVE, ASK。其中以 MOVE 指令为例,之所以增加此重定向指令,主要是考虑效率的因素,redis-server 集群以哈希槽的方式存放数据(目前最大是 16384 个哈希槽),各个 redis-server 结点都会记录着每个哈希槽所在的最终结点的位置,所以当 redis 客户端访问一个 redis-server 时,如果该服务结点在计算完哈希槽后发现该哈希槽在别的服务结点上,则会给客户端返回一个重定向指令(如:MOVE hash_slot ip:port),客户端在获得此重定向指令后会去连接最终的服务结点;另外,不了尽量减少重定向次数(有利于提高处理效率),官方协议文档中建议客户端应该缓存住哈希槽的存储位置。

虽然集群版本的 redis3.0 即将发布,但目前主要的问题是缺乏客户端的支持(目前据说可以支持的只有少数的几个客户端库:象JAVA版的 jedis,ruby 版本),尤其是 C/C++ 客户端库更是匮乏,好消息是 acl 库中的 redis 客户端模块已经很好地支持集群 redis3.0 了,该库不仅支持 redis 的重定向指令及哈希槽的自动缓存及自动更新功能,同时还支持 redis 服务结点自动发布机制,即在初始 acl redis 客户端库时只需添加 一个或多个 redis 服务器结点地址,在运行过程中会根据服务器返回的重定向信息动态添加新的 redis 服务器结点。下面是使用 acl redis 库集群版本的例子:

#include "acl_cpp/lib_acl.hpp"

static void test_redis_string(acl::redis_string& cmd, const char* key)
{
    acl::string val("test_value");

    // 向 redis 集群中添加一条字符串类型的数据对象
    // 对应的 redis 命令:SET key value
    if (cmd.set(key, val.c_str()) == false)
    {
        printf("redis set error\r\n");
        return;
    }
    else
        printf("redis set ok\r\n");

    // 清除缓冲区
    val.clear();

    // 重置 redis 客户端命令的状态,以便可以复用该操作对象
    cmd.reset();

    // 从 redis 集群中获取指定键值的数据
    if (cmd.get(key, val) == false)
        printf("get key error\r\n");
    else
        printf("get key ok, value: %s\r\n", val.c_str());

}

static void test_redis_key(acl::redis_key& cmd, const char* key)
{
    // 查询给定键在 redis 服务端是否存在
    if (cmd_key.exists(key) == false)
        printf("key not exists\r\n");
    else
        printf("key exists\r\n");
}

int main(void)
{
    const char* redis_addr = "127.0.0.1:6379";
    int conn_timeout = 10, rw_timeout = 10, max_conns = 100;

    // 定义 redis 客户端集群管理对象
    acl::redis_cluster cluster;
    // 添加一个 redis 服务结点,可以多次调用此函数添加多个服务结点,
    // 因为 acl redis 模块支持 redis 服务结点的自动发现及动态添加
    // 功能,所以添加一个服务结点即可
    cluster.set(redis_addr, max_conns);

    // redis 字符串类 (STRING) 操作对象
    acl::redis_string cmd_string;

    // redis 键值类(KEY) 操作对象
    acl::redis_key cmd_key;

    // 给 redis 操作对象绑定 redis 客户端集群对象
    cmd_string.set_cluster(&cluster, max_conns);
    cmd_key.set_cluster(&cluster, max_conns);

    const char* key = "test_key";

    // redis 集群命令操作的测试过程

    test_redis_string(cmd_string, key);
    test_redis_key(cmd_key, key);

    return 0;
}

参考:

1、acl 库地址:http://git.oschina.net/zsxxsz/acl/tree/master  

2、acl redis 头文件地址:http://git.oschina.net/zsxxsz/acl/tree/master/lib_acl_cpp/include/acl_cpp/redis 

3、acl redis 源文件地址:http://git.oschina.net/zsxxsz/acl/tree/master/lib_acl_cpp/src/redis 

4、acl redis 示例地址:http://git.oschina.net/zsxxsz/acl/tree/master/lib_acl_cpp/samples/redis 

热点阅读

网友最爱