【第四章 客户端】4.2、Java客户端Jedis

in with 0 comment

Redis Redis开发与运维

Java客户端Jedis

Java有很多优秀的Redis客户端（详见：http://redis.io/clients#java ）， 这里介绍使用较为广泛的客户端Jedis，本节将按照以下几个方面对Jedis进行介 绍：

- 获取Jedis
- Jedis的基本使用
- Jedis连接池使用
- Jedis中Pipleline使用
- Jedis的Lua脚本使用

  1. 获取Jedis

    Jedis属于Java的第三方开发包，在Java中获取第三方开发包通常有两种方式：

    • 直接下载目标版本的Jedis-${version}.jar包加入到项目中。
    • 使用集成构建工具，例如maven、gradle等将Jedis目标版本的配置加入到项 目中。

    通常在实际项目中使用第二种方式，但如果只是想测试一下Jedis，第一种方法 也是可以的。在写本书时，Jedis最新发布的稳定版本2.8.2，以Maven为例 子，在项目中加入下面的依赖即可：

    <dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.8.2</version>
</dependency>

    对于第三方开发包，版本的选择也是至关重要的，因为Redis更新速度比较快， 如果客户端跟不上服务端的速度，有些特性和bug不能及时更新，不利于日常开 发。通常来讲选取第三方开发包有如下两个策略：

    • 选择比较稳定的版本，也就是尽可能选择稳定的里程碑版本，这些版本已经经 过多次alpha，beta的修复，基本算是稳定了。

    • 选择更新活跃的第三方开发包，例如Redis3.0有了Redis Cluster新特性， 但是如果使用的客户端一直不支持，并且维护的人也比较少，这种就谨慎选择。

    本节介绍的Jedis基本满足上述两个特点，下面将对Jedis的基本使用方法进行 介绍。

  2. Jedis的基本使用方法

    Jedis的使用方法非常简单，只要下面三行代码就可以实现get功能：

    # 1. 生成一个Jedis对象，这个对象负责和指定Redis实例进行通信
Jedis jedis = new Jedis("127.0.0.1", 6379);
# 2. jedis执行set操作
jedis.set("hello", "world");
# 3. jedis执行get操作，value="world"
String value = jedis.get("hello");

    可以看到初始化Jedis需要两个参数：Redis实例的IP和端口，除了这两个参数 外，还有一个包含了四个参数的构造函数是比较常用的：

    Jedis(final String host, final int port, final int connectionTimeout, final int soTImeout)

    参数说明：

    • host：Redis实例的所在机器的IP。
    • port：Redis实例的端口。
    • connectionTimeout：客户端连接超时。
    • soTimeout：客户端读写超时。

    如果想看一下执行如果：

    String setResult = jedis.set("hello", "world");
String getResult = jedis.get("hello");
System.out.println(setResult);
System.out.println(getResult);

    输入结果为：

    OK
world

    可以看到jedis.set的返回结果是OK，和redis-cli的执行效果是一样的，只不 过结果类型变为了Java的数据类型。上面的这种写法只是为了演示使用，在实 际项目中比较推荐使用try catch finally的形式来进行来进行代码的书写： 一方面可以在Jedis出现异常的时候（本身是网络操作），将异常进行捕获或者 抛出；另一个方面无论执行成功或者失败，将Jedis连接关闭掉，在开发中关闭 不用的连接资源是一种好的习惯，代码类似如下：

    Jedis jedis = null;
try{
    jedis = new Jedis("127.0.0.1", 6379);
    jedis.get("hello");
}catch (Exception e){
    logger.error(e.getMessage(), e);
}finally{
    if(jedis != null){
        jedis.close();
    }
}

    下面用一个例子说明Jedis对于Redis五种数据结构的操作，为了节省篇幅，所 有返回结果放在注释中。

    //1.string
//输出结果：OK
jedis.set("hello", "world");
//输出结果：world
jedis.get("hello");
//输出结果：1
jedis.incr("counter");

//2.hash
jedis.hset("myhash", "f1", "v1");
jedis.hset("myhash", "f2", "v2");
//输出结果：{f1=v1, f2=v2}
jedis.hgetAll("myhash");

//3.list
jedis.rpush("mylist", "1");
jedis.rpush("mylist", "2");
jedis.rpush("mylist", "3");
//输出结果：{1, 2, 3}
jedis.lrange("mylist", 0, -1);

//4.set
jedis.sadd("myset", "a");
jedis.sadd("myset", "b");
jedis.sadd("myset", "a");
//输出结果：{b, a}
jedis.smemebers{b, a};

//5.zset
jedis.zadd("myzset", 99, "tom");
jedis.zadd("myzset", 66, "peter");
jedis.zadd("myzset", 33, "james");
//输出结果：[[["james"], 33.0], [["peter"], 66.0], [["tom"],99.0]]
jedis.zrangeWithScores("myset", 0, -1);

    参数除了可以是字符串，Jedis还提供了字节数组的参数，例如：

    public String set(final String key, String value)
public String set(final String key, final byte[] value)
public byte[] get(final byte[] key
public String get(final String key)

    有了这些API的支持，就可以将Java对象序列化为二进制，当应用需要获取Java 对象时， 使用get(final byte[] key)函数将字节数组取出，然后反序列化为 Java对象即可。和很多NoSQL数据库的客户端不同，Jedis本身没有提供序列化 的工具，也就是说开发者需要自己引入序列化的工具。序列化的工具有很多，例 如XML、Json、谷歌的Protobuf、Facebook的Thrift等等，对于序列化工具的 选择开发者可以根据自己需求决定。

  3. Jedis连接吃的使用方法

    上节介绍的是Jedis的直连方式，所谓直连是指Jedis每次都会新建TCP连接，使 用后再断开连接，对于频繁访问Redis的场景显然不是高效的使用方式。因此生 产环境中一般使用连接池的方式对Jedis连接进行管理，所有Jedis对象预先放 在池子中（JedisPool），每次要连接Redis，只需要在池子中劫，用完了再归 还给池子。

    客户端连接Redis使用的是TCP协议，直连的方式每次需要建立TCP连接，而连接 池的方式可以预先初始化号Jedis连接，所以每次只需要从Jedis连接池借用即 可，而借用和归还操作是在本地进行的，只有少量的并发同步开销，远远小于新 建TCP连接的开销。另外智联的方式无法限制Jedis对象的个数，在极端情况下 可能会造成连接泄露，而连接池的形式可以有效地保护和控制资源的使用。但是 直连的方式也并不是一无是处，下表给出两种方式各自的优劣势。

    方式优点缺点
    直连简单方便，适用于少量长期连接的场景1.存在每次/关闭TCP连接开销 2.资源无法控制，极端情况会出现连接泄露 3.Jedis对象线程不安全
    连接池1.无需每次连接都生成Jedis对象，降低开销 2.使用连接池的形式保护和控制资源的使用相对于直连，使用相对麻烦，尤其在资源的管理上需要很多参数来保证，一旦规划不合理也会出现问题

    Jedis提供了JedisPool这个类作为对Jedis的连接池，同时使用了Apache的通 用对象池工具common-pool作为资源的管理工具，下面是使用JedisPool操作 Redis的代码实例：

    1） Jedis连接池（通常JedisPool是单例的）：

    //common-pool连接池配置，这里使用默认配置，后面小节会介绍具体配置说明
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
//初始化Jedis连接池
JedisPool jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379);

    2）获取Jedis对象不再是直接生成一个Jedis对象进行直连，而是从连接池直接 获取，代码如下：

    Jedis jedis = null;
try{
    //1. 从连接池获取jedis对象
    jedis = jedisPool.getResource();
    //2. 执行操作
    jedis.get("hello");
}catch (Exception e){
    logger.error(e.getMessage(), e);
}finally{
    if(jedis != null){
        //如果适应JedisPool，close操作不是关闭连接，代表归还连接池
        jedis.close();
    }
}

    这里可以看到在finally中依然是jedis.close()操作，为什么会把连接关闭 呢，这不和连接池的原则违背了吗？但实际上Jedis的close()实现方式如下：

    public void close(){
    //使用Jedis连接池
    if(dataSource != null){
        if(client.isBroken){
            this.dataSource.returnBrokenResource(this);
        }else{
            this.dataSource.returnResource(this);
        }
    }else{
        client.close();
    }
}

    参数说明：

    • dataSource != null代表使用的是连接池，所以jedis.close()代表兑换连 接给连接池，而且Jedis会判断当前连接是否已经断开。

    • dataSource == null代表直连，jedis.close()代表关闭连接。

    前面GenericObjectPoolConfig使用的是默认配置，实际它提供有很多参数， 例如池子中最大连接数、最大空闲连接数、最小空闲李娜结束、连接活性检测， 等等，下表给出GenericObjectPoolConfig其他属性及其含义解释。

    参数名含义默认值
    maxActive连接池中最大连接数8
    maxIdle连接池中最大空闲的连接数8
    minIdle连接池中最少空间的李娜结束0
    maxWaitMillis当连接池资源用尽后，调用者的最大等待时间（单位为毫秒），一般不建议使用默认值-1，表示永远不超时，一直等。
    jmxEnabled是否开启jmx监控，如果应用开启了jmx端口并且jmxEnabled设置为true，就可以通过jconsole或者jvisualvm看到关于连接池的相关统计，有助于了解连接池的使用情况，并且可以针对其做监控统计。true
    minEvictableIdleTimeMillis连接的最小空间时间，达到此值后空闲连接将被移除1000L * 60L * 30毫秒 = 30分钟
    numTestsPerEvictionRun做空间连接检测时，每次的采样数3
    testOnBorrow想连接池借用连接是否做连接有效性检测（ping），无效连接会被移除，每次借用多执行一次ping命令false
    testOnReturn向连接池归还连接时是否做连接有效性检测（ping），无效连接会被移除，每次归还多执行一次ping命令false
    timeBetweenEvictionRunMillis空闲连接的检测周期（单位为毫秒）-1:表示不做检测
    blockWhenExhausted当连接池用尽后，调用者是否要等待，这个参数是和maxWaitMillis对应的，只有当此参数为true时，maxWaitMillis才会生效true

  4. Redis中Pipeline的使用方法

    下面代码是借助Pipeline来模拟批量删除：

    public void mdel(List<String> keys){
    Jedis jedis = new Jedis("127.0.0.1", 6379);
    //1)生成pipeline对象
    Pipeline pipeline = jedis.pipelined();
    //2)pipeline执行命令，注意此事命令并未真正执行
    for(String key : keys){
        pipeline.del(key);
    }
    //3)执行命令
    pipeline.sync();
}

    除了pipeline。sync(),还可以使用pipeline.syncAndReturnAll()将 pipeline的命令进行返回，例如下面代码将set和incr做了一次pipeline操 作，并顺序打印了两个命令的结果：

    Jedis jedis = new Jedis("127.0.0.1", 6379);
Pipeline pipeline = jedis.pipelined();
pipeline.set("hello", "world");
pipeline.incr("counter");
List<Object> resultList = pipeline.syncAndReturnAll();
for(Object object : resultList){
    System.out.println(object);
}

    输出结果为：

    OK
1

  5. Jedis的Lua脚本

    Jedis中执行Lua脚本和redis-cli十分类似，Jedis提供了三个重要的函数实现 Lua脚本的执行：

    Object eval(String script, int key count, String ... params)
Object evalSha(Stirng sha1, int keyCount, String ... params)
String scriptLoad(String script)

    eval函数有三个参数，分别是：

    • script：Lua脚本内容。
    • keyCount：键的个数。
    • params：相关参数KEYS和ARGV。

    scriptLoad和evalSha函数要一起使用，首先使用scriptLoad将脚本加载到 Redis中，evalSha函数用来执行脚本的SHA1校验和，它需要三个参数：

    • scriptSha：脚本的SHA1。
    • keyCount：键的个数。
    • params：相关参数KEYS和ARGV

  6. 重点注意以下几点：

    1） Jedis操作放在 try catch finally里更加合理。 2） 区分直连和连接池两种实现方式的优缺点。 3） jedis.close()方法的两种实现方式。 4） Jedis依赖了common-pool 5） 如果key和value涉及了字节数组，需要自己选择适合的序列化方法。

本文由 Meridian 创作，采用 知识共享署名4.0 国际许可协议进行许可
本站文章除注明转载/出处外，均为本站原创或翻译，转载前请务必署名
最后编辑时间为: Jul 25,2019

← → ↓ ↑