首页 > 编程语言 > Redis连接池配置及初始化实现
2021
03-30

Redis连接池配置及初始化实现

加入db选择后的redis连接池配置代码

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
public class RedisPoolConfigure {
 
 //Redis服务器IP
 private String ADDR ;
  
 //Redis的端口号
 private int PORT ;
  
 //可用连接实例的最大数目
 private int MAX_ACTIVE ;
  
 //pool中的idle jedis实例数
 private int MAX_IDLE ;
  
 //等待可用连接的最大时间，单位毫秒
 private int MAX_WAIT ;
 //超时时间，单位毫秒
 private int TIME_OUT ;
 //设置的逐出策略类名, 默认DefaultEvictionPolicy(当连接超过最大空闲时间,或连接数超过最大空闲连接数)
 private String EVICTION_POLICY_CLASS_NAME ;
  
 //连接耗尽时是否阻塞, false报异常,ture阻塞直到超时
 private boolean BLOCK_WHEN_EXHAUSTED;
  
 //是否启用pool的jmx管理功能, 默认true
 private boolean JMX_ENABLED;
  
 //在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
 private boolean TEST_ON_BORROW ;
  
 //服务器密码
 private String REDIS_PASS;
 //redis选择数据库DB
 private int REDIS_DB;
  
  
 private String LUASHA;
  
 private Map<String, String> configure = null;
  
 /**
  * 根据配置文件,将RedisPool连接配置初始化
  */
 public RedisPoolConfigure(){
  try {
  configure = new ConfigureReader().readProperties("redis.properties");
 } catch (IOException e) {
 e.printStackTrace();
 }
  this.ADDR = configure.get("REDIS.ADDR");
  this.LUASHA = configure.get("REDIS.LUA_HASH");
  this.EVICTION_POLICY_CLASS_NAME = configure.get("REDIS.EVICTION_POLICY_CLASS_NAME");
  this.BLOCK_WHEN_EXHAUSTED = Boolean.parseBoolean(configure.get("REDIS.BLOCK_WHEN_EXHAUSTED"));
  this.JMX_ENABLED = Boolean.parseBoolean(configure.get("REDIS.JMX_ENABLED"));
  this.TEST_ON_BORROW = Boolean.parseBoolean(configure.get("REDIS.TEST_ON_BORROW"));
  this.REDIS_PASS=configure.get("REDIS.PASS");
   
  if(typeCheck()){
  this.PORT = new Integer(configure.get("REDIS.PORT"));
  this.MAX_ACTIVE = new Integer(configure.get("REDIS.MAX_ACTIVE"));
  this.MAX_IDLE = new Integer(configure.get("REDIS.MAX_IDLE"));
  this.MAX_WAIT = new Integer(configure.get("REDIS.MAX_WAIT"));
  this.REDIS_DB=new Integer(configure.get("REDIS.DB"));
  }else{
  System.out.println("error");
  }
 }
  
 /**
  * 辅助工具,检查map中数据的类型
  * @return
  */
 private boolean typeCheck() {
 if (isNumeric(configure.get("REDIS.PORT"))
 && isNumeric(configure.get("REDIS.MAX_ACTIVE"))
 && isNumeric(configure.get("REDIS.MAX_IDLE"))
 && isNumeric(configure.get("REDIS.MAX_WAIT"))
 && isNumeric(configure.get("REDIS.DB"))) {
 return true;
 }
 return false;
 }
 
 public String getADDR() {
 return ADDR;
 }
 
 public int getPORT() {
 return PORT;
 }
 
 
 public int getMAX_ACTIVE() {
 return MAX_ACTIVE;
 }
 
 public int getMAX_IDLE() {
 return MAX_IDLE;
 }
 
 public int getMAX_WAIT() {
 return MAX_WAIT;
 }
 
 public int getTIME_OUT() {
 return TIME_OUT;
 }
 
 public boolean isTEST_ON_BORROW() {
 return TEST_ON_BORROW;
 }
 
 public String getEVICTION_POLICY_CLASS_NAME() {
 return EVICTION_POLICY_CLASS_NAME;
 }
 
 public boolean isBLOCK_WHEN_EXHAUSTED() {
 return BLOCK_WHEN_EXHAUSTED;
 }
 
 public boolean isJMX_ENABLED() {
 return JMX_ENABLED;
 }
 /**
 * 判断传入的数据是否为纯数字构成
 * @param str
 * @return
 */
 public boolean isNumeric(String str) {
 if(str==null || "".equals(str)){
 return false;
 }
 for (int i = 0; i < str.length(); i++) {
 if (!Character.isDigit(str.charAt(i))) {
 return false;
 }
 }
 return true;
 }
 
 public String getLUASHA() {
 return LUASHA;
 }
 
 public void setLUASHA(String lUASHA) {
 LUASHA = lUASHA;
 }
 
 public String getREDIS_PASS() {
 return REDIS_PASS;
 }
 
 public void setREDIS_PASS(String rEDIS_PASS) {
 REDIS_PASS = rEDIS_PASS;
 }
 
 public int getREDIS_DB() {
 return REDIS_DB;
 }
 
 public void setREDIS_DB(int rEDIS_DB) {
 REDIS_DB = rEDIS_DB;
 }
}

redis连接池初始化、获取Jedis实例和释放Jedis实例

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
/**
 * jedis的连接池,返回未封装的jedis对象
 * 一般只有在RedisCache类提供的操作粒度不足使用时才使用此类提供的原生jedis方法
 * @author Hector
 *
 */
public class RedisPool {
  
 private static JedisPool jedisPool = null;
  
 /**
  * 初始化Redis连接池
  */
 static {
  try {
   RedisPoolConfigure configure = new RedisPoolConfigure();
   JedisPoolConfig config = new JedisPoolConfig();
   config.setBlockWhenExhausted(configure.isBLOCK_WHEN_EXHAUSTED());
   config.setEvictionPolicyClassName(configure.getEVICTION_POLICY_CLASS_NAME());
   config.setJmxEnabled(configure.isJMX_ENABLED());
   config.setMaxIdle(configure.getMAX_IDLE());
   config.setMaxTotal(configure.getMAX_ACTIVE());
   config.setMaxWaitMillis(configure.getMAX_WAIT());
   config.setTestOnBorrow(configure.isTEST_ON_BORROW());
   jedisPool = new JedisPool(config, configure.getADDR(), configure.getPORT(), configure.getTIME_OUT(),configure.getREDIS_PASS(),configure.getREDIS_DB());
  } catch (Exception e) {
   e.printStackTrace();
  }
 }
  
 /**
  * 获取Jedis实例
  * @return
  */
 public synchronized static Jedis getJedis() {
  Jedis resource=null;
  try {
   if (jedisPool != null) {
    resource = jedisPool.getResource();
    return resource;
   } else {
    return null;
   }
  } catch (Exception e) {
   e.printStackTrace();
   return null;
  }
 }
  
  
 /**
  * 释放jedis资源
  * @param jedis
  */
 public static void close(final Jedis jedis) {
  if (jedis != null) {
   jedis.close();
  }
 }
  
 public static JedisPool getJedisPool() {
 return jedisPool;
 }
}

到此这篇关于Redis连接池配置及初始化实现的文章就介绍到这了,更多相关Redis连接池配置内容请搜索自学编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持自学编程网！

编程技巧