jedisCluster

深碍√TFBOYSˉ_ 2022-06-16 06:11 139阅读 0赞

![category_icon.jpg][]  分类：

redis/memcached（12） ![arrow_triangle_20_down.jpg][]  Spring（19） ![arrow_triangle_20_down.jpg][]

最近在公司做了 jedisCluster整合[spring][] 的配置， 分享如下

客户端采用最新的jedis 2.7

maven依赖：

<dependency>  
<groupId>redis.clients</groupId>  
<artifactId>jedis</artifactId>  
<version>2.8.0</version>  
</dependency>

增加spring 配置

Java代码   ![收藏代码][icon_star.png]

1.  <bean name="genericObjectPoolConfig" **class**="org.apache.commons.pool2.impl.GenericObjectPoolConfig" >  
2.          <property name="maxWaitMillis" value="-1" />  
3.          <property name="maxTotal" value="1000" />  
4.          <property name="minIdle" value="8" />  
5.          <property name="maxIdle" value="100" />  
6.  </bean>  
7.    
8.  <bean id="jedisCluster" **class**="xxx.JedisClusterFactory">  
9.      <property name="addressConfig">  
10.         <value>classpath:connect-redis.properties</value>  
11.     </property>  
12.     <property name="addressKeyPrefix" value="address" />     
13.       
14.     <property name="timeout" value="300000" />  
15.     <property name="maxRedirections" value="6" />  
16.     <property name="genericObjectPoolConfig" ref="genericObjectPoolConfig" />  
17. </bean>

增加connect-redis.properties  配置文件

这里配置了6个节点

Java代码   ![收藏代码][icon_star.png]

1.  address1=172.16.23.27:6379  
2.  address2=172.16.23.27:6380  
3.  address3=172.16.23.27:6381  
4.  address4=172.16.23.27:6382  
5.  address5=172.16.23.27:6383  
6.  address6=172.16.23.27:6384

增加[Java][]类：

Java代码   ![收藏代码][icon_star.png]

1.  **import** java.util.HashSet;  
2.  **import** java.util.Properties;  
3.  **import** java.util.Set;  
4.  **import** java.util.regex.Pattern;  
5.    
6.  **import** org.apache.commons.pool2.impl.GenericObjectPoolConfig;  
7.  **import** org.springframework.beans.factory.FactoryBean;  
8.  **import** org.springframework.beans.factory.InitializingBean;  
9.  **import** org.springframework.core.io.Resource;  
10.   
11. **import** redis.clients.jedis.HostAndPort;  
12. **import** redis.clients.jedis.JedisCluster;  
13.   
14. **public** **class** JedisClusterFactory **implements** FactoryBean<JedisCluster>, InitializingBean \{  
15.   
16.     **private** Resource addressConfig;  
17.     **private** String addressKeyPrefix ;  
18.   
19.     **private** JedisCluster jedisCluster;  
20.     **private** Integer timeout;  
21.     **private** Integer maxRedirections;  
22.     **private** GenericObjectPoolConfig genericObjectPoolConfig;  
23.       
24.     **private** Pattern p = Pattern.compile("^.+\[:\]\\\\d\{1,5\}\\\\s\*$");  
25.   
26.     @Override  
27.     **public** JedisCluster getObject() **throws** Exception \{  
28.         **return** jedisCluster;  
29.     \}  
30.   
31.     @Override  
32.     **public** Class<? **extends** JedisCluster> getObjectType() \{  
33.         **return** (**this**.jedisCluster != **null** ? **this**.jedisCluster.getClass() : JedisCluster.**class**);  
34.     \}  
35.   
36.     @Override  
37.     **public** **boolean** isSingleton() \{  
38.         **return** **true**;  
39.     \}  
40.   
41.   
42.   
43.     **private** Set<HostAndPort> parseHostAndPort() **throws** Exception \{  
44.         **try** \{  
45.             Properties prop = **new** Properties();  
46.             prop.load(**this**.addressConfig.getInputStream());  
47.   
48.             Set<HostAndPort> haps = **new** HashSet<HostAndPort>();  
49.             **for** (Object key : prop.keySet()) \{  
50.   
51.                 **if** (!((String) key).startsWith(addressKeyPrefix)) \{  
52.                     **continue**;  
53.                 \}  
54.   
55.                 String val = (String) prop.get(key);  
56.   
57.                 **boolean** isIpPort = p.matcher(val).matches();  
58.   
59.                 **if** (!isIpPort) \{  
60.                     **throw** **new** IllegalArgumentException("ip 或 port 不合法");  
61.                 \}  
62.                 String\[\] ipAndPort = val.split(":");  
63.   
64.                 HostAndPort hap = **new** HostAndPort(ipAndPort\[0\], Integer.parseInt(ipAndPort\[1\]));  
65.                 haps.add(hap);  
66.             \}  
67.   
68.             **return** haps;  
69.         \} **catch** (IllegalArgumentException ex) \{  
70.             **throw** ex;  
71.         \} **catch** (Exception ex) \{  
72.             **throw** **new** Exception("解析 jedis 配置文件失败", ex);  
73.         \}  
74.     \}  
75.       
76.     @Override  
77.     **public** **void** afterPropertiesSet() **throws** Exception \{  
78.         Set<HostAndPort> haps = **this**.parseHostAndPort();  
79.           
80.         jedisCluster = **new** JedisCluster(haps, timeout, maxRedirections,genericObjectPoolConfig);  
81.           
82.     \}  
83.     **public** **void** setAddressConfig(Resource addressConfig) \{  
84.         **this**.addressConfig = addressConfig;  
85.     \}  
86.   
87.     **public** **void** setTimeout(**int** timeout) \{  
88.         **this**.timeout = timeout;  
89.     \}  
90.   
91.     **public** **void** setMaxRedirections(**int** maxRedirections) \{  
92.         **this**.maxRedirections = maxRedirections;  
93.     \}  
94.   
95.     **public** **void** setAddressKeyPrefix(String addressKeyPrefix) \{  
96.         **this**.addressKeyPrefix = addressKeyPrefix;  
97.     \}  
98.   
99.     **public** **void** setGenericObjectPoolConfig(GenericObjectPoolConfig genericObjectPoolConfig) \{  
100.         **this**.genericObjectPoolConfig = genericObjectPoolConfig;  
101.     \}  
102.   
103. \}

到此配置完成

使用时，直接注入即可， 如下所示：

@Autowired

JedisCluster jedisCluster;

[category_icon.jpg]: /images/20220616/d823b3503746448196ebc3242b49c32c.png
[arrow_triangle_20_down.jpg]: /images/20220616/fbc29d8c659f425bac2103534c5978f8.png
[spring]: http://lib.csdn.net/base/javaee
[icon_star.png]: /images/20220616/b0e16c22118b49ceadd3e4f804bf3633.png
[Java]: http://lib.csdn.net/base/javase