Redis 客户端Jedis使用---连接池

本文主要是介绍Redis 客户端Jedis使用---连接池，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Jedis 是Redis 的Java客户端，通过一段时间的使用，jedis基本实现redis的所有功能，并且jedis在客户端实现redis数据分片功能，Redis本身是没有数据分布功能。

一、下载jedis 代码

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

再次感受到开源的强大。呵呵，大家有时间可以看看源码。

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

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

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

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);// 设置最大阻塞时间，记住是毫秒数millisecondsconfig.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<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 ,不过功能还不够强大。

参考资料：http://blog.csdn.net/songylwq/article/details/26008327

    http://my.oschina.net/lilw/blog/169635

这篇关于Redis 客户端Jedis使用---连接池的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---