三：Redis连接池、JedisPool详解、Redisi分布式

 

单机模式：

 1 package com.ljq.utils;
 2 
 3 import redis.clients.jedis.Jedis;
 4 import redis.clients.jedis.JedisPool;
 5 import redis.clients.jedis.JedisPoolConfig;
 6 
 7 /**   
 8  * Redis操作接口
 9  *
10  * @author NiceCui
11  * @version 1.0 2017-6-14 上午08:54:14   
12  */
13 public class RedisAPI {
14     private static JedisPool pool = null;
15     
16     /**
17      * 构建redis连接池
18      * 
19      * @param ip
20      * @param port
21      * @return JedisPool
22      */
23     public static JedisPool getPool() {
24         if (pool == null) {
25             JedisPoolConfig config = new JedisPoolConfig();
26             //控制一个pool可分配多少个jedis实例，通过pool.getResource()来获取；
27             //如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
28             config.setMaxActive(500);
29             //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例。
30             config.setMaxIdle(5);
31             //表示当borrow(引入)一个jedis实例时，最大的等待时间，如果超过等待时间，则直接抛出JedisConnectionException；
32             config.setMaxWait(1000 * 100);
33             //在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
34             config.setTestOnBorrow(true);
35             pool = new JedisPool(config, "192.168.2.191", 8888);
36         }
37         return pool;
38     }
39     
40     /**
41      * 返还到连接池
42      * 
43      * @param pool 
44      * @param redis
45      */
46     public static void returnResource(JedisPool pool, Jedis redis) {
47         if (redis != null) {
48             pool.returnResource(redis);
49         }
50     }
51     
52     /**
53      * 获取数据
54      * 
55      * @param key
56      * @return
57      */
58     public static String get(String key){
59         String value = null;
60         
61         JedisPool pool = null;
62         Jedis jedis = null;
63         try {
64             pool = getPool();
65             jedis = pool.getResource();
66             value = jedis.get(key);
67         } catch (Exception e) {
68             //释放redis对象
69             pool.returnBrokenResource(jedis);
70             e.printStackTrace();
71         } finally {
72             //返还到连接池
73             returnResource(pool, jedis);
74         }
75         
76         return value;
77     }
78 }

 

分布式模式

ShardedJe、dis是基于一致性哈希算法实现的分布式Redis集群客户端

 1 package com.jd.redis.client;
 2   
 3 import java.util.ArrayList;
 4 import java.util.List;
 5   
 6 import redis.clients.jedis.JedisPoolConfig;
 7 import redis.clients.jedis.JedisShardInfo;
 8 import redis.clients.jedis.ShardedJedis;
 9 import redis.clients.jedis.ShardedJedisPool;
10 import redis.clients.util.Hashing;
11 import redis.clients.util.Sharded;
12   
13 publicclass RedisShardPoolTest {
14      
15 static ShardedJedisPoolpool;
16      
17 static{
18          
19 JedisPoolConfig config =new JedisPoolConfig();//Jedis池配置
20          
21 config.setMaxActive(500);//最大活动的对象个数
22          
23 config.setMaxIdle(1000 * 60);//对象最大空闲时间
24         
25 config.setMaxWait(1000 * 10);//获取对象时最大等待时间
26        
27 config.setTestOnBorrow(true);
28          
29 String hostA = "10.10.224.44";
30         
31 int portA = 6379;
32         
33 String hostB = "10.10.224.48";
34         
35 int portB = 6379;
36          
37 List<JedisShardInfo> jdsInfoList =new ArrayList<JedisShardInfo>(2);
38          
39 JedisShardInfo infoA = new JedisShardInfo(hostA, portA);
40          
41 infoA.setPassword("redis.360buy");
42          
43 JedisShardInfo infoB = new JedisShardInfo(hostB, portB);
44          
45 infoB.setPassword("redis.360buy");
46          
47 jdsInfoList.add(infoA);
48          
49 jdsInfoList.add(infoB);
50          
51          
52 pool =new ShardedJedisPool(config, jdsInfoList, Hashing.MURMUR_HASH,
53 Sharded.DEFAULT_KEY_TAG_PATTERN);
54     //传入连接池配置、分布式redis服务器主机信息、分片规则（存储到哪台redis服务器）
55 }
56      
57      
58 /**
59      
60  * @param args
61      
62  */
63      
64 publicstaticvoid main(String[] args) {
65          
66 for(int i=0; i<100; i++){
67            String key =generateKey();
68            //key += "{aaa}";
69            ShardedJedis jds =null;
70            try {
71                jds =pool.getResource();
72                System.out.println(key+":"+jds.getShard(key).getClient().getHost());
73                System.out.println(jds.set(key,"1111111111111111111111111111111"));
74            }catch (Exception e) {
75                e.printStackTrace();
76            }
77            finally{
78                pool.returnResourceObject(jds);
79            }
80          
81 }
82      
83 }
84   
85      
86 privatestaticintindex = 1;
87      
88 publicstatic String generateKey(){
89          
90 return String.valueOf(Thread.currentThread().getId())+"_"+(index++);
91      
92 }
93 }