Redis客户端使用

yvgoodman

http://wenku.baidu.com/view/6ccd650af12d2af90242e63d.html

一、下载jedis 代码

　　jedis 代码地址：https://github.com/xetorthio/jedis
　　再次感受到开源的强大。呵呵，大家有时间可以看看源码。

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

　　现在大家都喜欢用maven作为项目管理利器，那我只说明一下Maven如何使用jedis，只需要添加以下依赖就可以。

   
redis.clients
jedis
2.1.0

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

三、建立一个简单的连接

　　

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方法设置密码。
当然，简单连接不适合真实的环境使用，需要有连接池支持 。

四、建立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);
}
}

五、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 shards = new ArrayList();
//添加第一台服务器信息
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 shards = new ArrayList();
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 ,不过功能还不够强大。