Redis 2.8 客户端应用（jedis），jedis分片

samsungsamsung

1  Redis客户端应用（jedis）、jedis分片
1.1   什么是jedis？
　　jedis是针对Java提供的用来连接Redis服务器的客户端技术，就相当于连接数据库需要jdbc一样。（连接mysql需要使用jdbc、连接Redis需要使用Jedis）
1.2   Jedis客户端连接redis缓存步骤
1.2.1  第一种创建项目方式：
　　一）下载Jedis的Jar包：官网 www.redis.io 基于maven下最简单的配置方式，来获取redis依赖jar包。
　　官网提供方式如下：
　　1）配置maven的pom.xml中配置：根据配置找到依赖的jar包
　　
　　
　　redis.clients
　　jedis
　　2.6.2
　　jar
　　compile
　　
　　
　　2）使用Java代码操作Redis服务器
　　Jedis jedis = new Jedis("192.168.13.129", 6379);
　　jedis.set("string_key01","today  is a good day");
　　String s = jedis.get("string_key01");
　　System.out.print(s);
　　jedis.close();
　　二）jedis连接池应用
　　1）创建Jedis连接池配置对象：JedisPoolConfigconfig = new JedisPoolConfig();
　　2）设置配置相关参数：
　　config.setMaxIdle(1000*60);
　　config.setMaxTotal(8);
　　config.setTestOnBorrow(ture);
　　3）通过配置对象创建连接池对象：
　　JedisPool pool = new JedisPool（config,"192.168.13.129",6379）;
　　4）通过池对象获取jedis对象，并操作redis
　　Jedis jds = pool.getResource();
　　jds.set("name","zhangsan");
　　String name = jds.get("name");
　　System.out.print(name);
1.2.2  第二种创建项目方式：
　　1）导入依赖的jar包

　　2）使用Java代码操作Redis服务器（同上）
　　Jedis jedis = new Jedis("192.168.13.129",  6379);
　　jedis.set("string_key01","today  is a good day");
　　String s = jedis.get("string_key01");
　　System.out.print(s);
　　jedis.close();
1.3   Jedis分片
1.3.1  什么是分片：
　　当一台redis服务器无法承载高并发的压力，我们就需要多台服务器来分担相应的压力。
　　图1.

　　图2.

1.3.2   jedis分片操作
　　
　　第一步：配置多台Redis服务器：因为配置多台Redis服务器不方便，所以这里使用复制配置文件，修改端口来模板第二台Redis服务器；
　　已经有一台了,复制redis.conf修改端口号6380作为第二台服务器
　　第二步：创建分片Jedis连接池对象：ShardedJedisPool
　　1）它需要三个参数：1. 配置参数、2. 多台Redis服务器信息参数、3. 算法参数。
　　JedisPoolConfig poolConfig = newJedisPoolConfig();
　　poolConfig.setMaxTotal(500);
　　poolConfig.setMaxIdle(1000  * 60);
　　poolConfig.setTestOnBorrow(true);
　　List  shards = new  ArrayList(2);
　　JedisShardInfo  A = new JedisShardInfo("192.168.13.111", 6379);
　　JedisShardInfo  B = new JedisShardInfo("192.168.13.111", 6380);
　　shards.add(A  );
　　shards.add(B);
　　ShardedJedisPoolpool = new  ShardedJedisPool(poolConfig, shards , Hashing.MURMUR_HASH);
　　2）获取jedis对象，模拟100个请求来测试如何分配资源。
　　privatestaticintindex = 1;
　　publicstaticvoid main(String[] args) {
　　for(int i=0; i