欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2022-04-15 20:13:12
单机模式: 分布式模式 ShardedJe、dis是基于一致性哈希算法实现的分布式Redis集群客户端 ......

 

单机模式:

 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 }