Redis服务器的客户端Jedis分片连接

企鹅你生气 贡献于2015-08-30

作者 dzd  创建于2015-07-27 06:04:22   修改者dzd  修改于2015-07-27 06:05:15字数2922

文档摘要:原Redis客户端Jedis使用(一)Jedis是Redis的Java客户端,通过一段时间的使用,jedis基本实现redis的所有功能,并且jedis在客户端实现redis数据分片功能,Redis本身是没有数据分布功能。
关键词:

原 Redis 客户端Jedis使用(一) Jedis 是Redis 的Java客户端,通过一段时间的使用,jedis基本实现redis的所有功能,并且jedis在客户端实现redis数据分片功能,Redis本身是没有数据分布功能。 一、下载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 ,不过功能还不够强大。

下载文档到电脑,查找使用更方便

文档的实际排版效果,会与网站的显示效果略有不同!!

需要 5 金币 [ 分享文档获得金币 ] 0 人已下载

下载文档