客户端采用最新的jedis 2.7
1.maven依赖:
?
1
2
3
4
5
|
< dependency >
< groupId >redis.clients</ groupId >
< artifactId >jedis</ artifactId >
< version >2.7.3</ version >
</ dependency >
|
2.增加spring 配置
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
< bean name = "genericObjectPoolConfig" class = "org.apache.commons.pool2.impl.GenericObjectPoolConfig" >
< property name = "maxWaitMillis" value = "-1" />
< property name = "maxTotal" value = "1000" />
< property name = "minIdle" value = "8" />
< property name = "maxIdle" value = "100" />
</ bean >
< bean id = "jedisCluster" class = "xxx.JedisClusterFactory" >
< property name = "addressConfig" >
< value >classpath:connect-redis.properties</ value >
</ property >
< property name = "addressKeyPrefix" value = "address" /> <!-- 属性文件里 key的前缀 -->
< property name = "timeout" value = "300000" />
< property name = "maxRedirections" value = "6" />
< property name = "genericObjectPoolConfig" ref = "genericObjectPoolConfig" />
</ bean >
|
3.增加connect-redis.properties 配置文件
这里配置了6个节点
?
1
2
3
4
5
6
|
address1=*:*
address2=*:*
address3=*:*
address4=*:*
address5=*:*
address6=*:*
|
4.增加java类:
?
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
|
import java.util.HashSet;
import java.util.Properties;
import java.util.Set;
import java.util.regex.Pattern;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.core.io.Resource;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
public class JedisClusterFactory implements FactoryBean<JedisCluster>, InitializingBean {
private Resource addressConfig;
private String addressKeyPrefix ;
private JedisCluster jedisCluster;
private Integer timeout;
private Integer maxRedirections;
private GenericObjectPoolConfig genericObjectPoolConfig;
private Pattern p = Pattern.compile( "^.+[:]\\\\d{1,5}\\\\s*$" );
@Override
public JedisCluster getObject() throws Exception {
return jedisCluster;
}
@Override
public Class<? extends JedisCluster> getObjectType() {
return ( this .jedisCluster != null ? this .jedisCluster.getClass() : JedisCluster. class );
}
@Override
public Boolean isSingleton() {
return true ;
}
private Set<HostAndPort> parseHostAndPort() throws Exception {
try {
Properties prop = new Properties();
prop.load( this .addressConfig.getInputStream());
Set<HostAndPort> haps = new HashSet<HostAndPort>();
for (Object key : prop.keySet()) {
if (!((String) key).startsWith(addressKeyPrefix)) {
continue ;
}
String val = (String) prop.get(key);
Boolean isIpPort = p.matcher(val).matches();
if (!isIpPort) {
throw new IllegalArgumentException( "ip 或 port 不合法" );
}
String[] ipAndPort = val.split( ":" );
HostAndPort hap = new HostAndPort(ipAndPort[ 0 ], Integer.parseint(ipAndPort[ 1 ]));
haps.add(hap);
}
return haps;
}
catch (IllegalArgumentException ex) {
throw ex;
}
catch (Exception ex) {
throw new Exception( "解析 jedis 配置文件失败" , ex);
}
}
@Override
public void afterPropertiesSet() throws Exception {
Set<HostAndPort> haps = this .parseHostAndPort();
jedisCluster = new JedisCluster(haps, timeout, maxRedirections,genericObjectPoolConfig);
}
public void setAddressConfig(Resource addressConfig) {
this .addressConfig = addressConfig;
}
public void setTimeout( int timeout) {
this .timeout = timeout;
}
public void setMaxRedirections( int maxRedirections) {
this .maxRedirections = maxRedirections;
}
public void setAddressKeyPrefix(String addressKeyPrefix) {
this .addressKeyPrefix = addressKeyPrefix;
}
public void setGenericObjectPoolConfig(GenericObjectPoolConfig genericObjectPoolConfig) {
this .genericObjectPoolConfig = genericObjectPoolConfig;
}
}
|
5.到此配置完成
使用时,直接注入即可, 如下所示:
?
1
2
|
@Autowired
JedisCluster jedisCluster;
|
总结
以上就是本文关于spring集成redis cluster详解的全部内容,希望对大家有所帮助。如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!
原文链接:http://www.open-open.com/code/view/1453520799651
相关文章
猜你喜欢
- 个人网站搭建:如何挑选具有弹性扩展能力的服务器? 2025-06-10
- 个人服务器网站搭建:如何选择适合自己的建站程序或框架? 2025-06-10
- 64M VPS建站:能否支持高流量网站运行? 2025-06-10
- 64M VPS建站:怎样选择合适的域名和SSL证书? 2025-06-10
- 64M VPS建站:怎样优化以提高网站加载速度? 2025-06-10
TA的动态
- 2025-07-10 怎样使用阿里云的安全工具进行服务器漏洞扫描和修复?
- 2025-07-10 怎样使用命令行工具优化Linux云服务器的Ping性能?
- 2025-07-10 怎样使用Xshell连接华为云服务器,实现高效远程管理?
- 2025-07-10 怎样利用云服务器D盘搭建稳定、高效的网站托管环境?
- 2025-07-10 怎样使用阿里云的安全组功能来增强服务器防火墙的安全性?
快网idc优惠网
QQ交流群
您的支持,是我们最大的动力!
热门文章
-
2025-05-25 77
-
2025-05-29 23
-
2025-06-04 52
-
2025-06-04 22
-
2025-05-29 58
热门评论