Redis 客户端Jedis使用（一）

Jedis 是Redis 的Java客户端，经过一段时间的使用，jedis基本实现redis的全部功能，而且jedis在客户端实现redis数据分片功能，Redis自己是没有数据分布功能。

1、下载jedis 代码

jedis 代码地址：https://github.com/xetorthio/jedis

再次感觉到开源的强大。呵呵，你们有时间能够看看源码。

2、项目中如何使用Jedis使用

如今你们都喜欢用maven做为项目管理利器，那我只说明一下Maven如何使用jedis，只须要添加如下依赖就能够。

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

OK, 用maven管理jar包依赖真的很方便。建议你们都采用maven管理项目。

3、创建一个简单的链接

 

public class JedisUtil {

    public static Jedis createJedis() {
        Jedis jedis = new Jedis("127.0.0.1");
        return jedis;
    }

    public static Jedis createJedis(String host, int port) {
        Jedis jedis = new Jedis(host, port);

        return jedis;
    }

    public static Jedis createJedis(String host, int port, String passwrod) {
        Jedis jedis = new Jedis(host, port);

        if (!StringUtils.isNotBlank(passwrod))
            jedis.auth(passwrod);
        
        return jedis;
    }
}

建立一个简单Jedis对象就是这样，告诉它的IP地址和端口号就能够，若是redis有密码，那须要在创建链接时，须要调用auth方法设置密码。

固然，简单链接不适合真实的环境使用，须要有链接池支持 。

4、创建Jedis链接池

 

建立链接jedis 链接池，jedis 提供JedisPool对象，使用比较方便。jedis pool 是基于apache common pool 实现。

package cn.opensv.example.redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisPoolUtils {

    private static JedisPool pool;

    /**
 * 创建链接池 真实环境，通常把配置参数缺抽取出来。
 * 
 */
    private static void createJedisPool() {

        // 创建链接池配置参数
        JedisPoolConfig config = new JedisPoolConfig();

        // 设置最大链接数
        config.setMaxActive(100);

        // 设置最大阻塞时间，记住是毫秒数milliseconds
        config.setMaxWait(1000);

        // 设置空间链接
        config.setMaxIdle(10);

        // 建立链接池
        pool = new JedisPool(config, "127.0.0.1", 6379);

    }

    /**
 * 在多线程环境同步初始化
 */
    private static synchronized void poolInit() {
        if (pool == null)
            createJedisPool();
    }

    /**
 * 获取一个jedis 对象
 * 
 * @return
 */
    public static Jedis getJedis() {

        if (pool == null)
            poolInit();
        return pool.getResource();
    }

    /**
 * 归还一个链接
 * 
 * @param jedis
 */
    public static void returnRes(Jedis jedis) {
        pool.returnResource(jedis);
    }

}

5、Jedis 实现分片

Jedis分片采用Hash算法和基于的Key模式匹配。Jedis定义一个Hash接口，若是以为自带的不爽，能够本身实现一个Hash算法。Jedis自带的Hash的算法是MurmurHash 2.0 。

MurmurHash算法：高运算性能，低碰撞率，由Austin Appleby建立于2008年，现已应用到Hadoop、libstdc++、nginx、libmemcached等开源系统。2011年Appleby被Google雇佣，随后Google推出其变种的CityHash算法。

官方网站：https://sites.google.com/site/murmurhash/

MurmurHash算法，自称超级快的hash算法，是FNV的4-5倍。

 

/**
 * 建立分片对象
 * @return
 */
    public static ShardedJedis createShardJedis() {
        
        //创建服务器列表
        List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
        
        //添加第一台服务器信息
        JedisShardInfo si = new JedisShardInfo("localhost", 6379);
        si.setPassword("123");
        shards.add(si);
        
        //添加第二台服务器信息
        si = new JedisShardInfo("localhost", 6399);
        si.setPassword("123");
        shards.add(si);
        //创建分片链接对象
        ShardedJedis jedis = new ShardedJedis(shards);        
        
        //创建分片链接对象,并指定Hash算法
        //ShardedJedis jedis = new ShardedJedis(shards,selfHash);
        return jedis;
    }

分片也能够支持链接池，具体以下：

private static void createPool() {
        List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
        JedisShardInfo si = new JedisShardInfo("localhost", 6379);
        si.setPassword("123");
        shards.add(si);
        si = new JedisShardInfo("localhost", 6399);
        si.setPassword("123");
        shards.add(si);
        pool = new ShardedJedisPool(new JedisPoolConfig(), shards);
    }

其它与普通的链接池没有区别。

除Jedis是redis的Java客户端实现，还有其余的一些开源库，如：Spring Redis Data ,不过功能还不够强大。