Commit 7da5d28a by laigx

支持非集群模式

parent 29f725d2
...@@ -99,6 +99,15 @@ public class RedisClusterConfig { ...@@ -99,6 +99,15 @@ public class RedisClusterConfig {
*/ */
@Bean @Bean
public JedisConnectionFactory jedisConnectionFactory() { public JedisConnectionFactory jedisConnectionFactory() {
if (clusterNodes.split(",").length == 1) {
//非多节点集群
JedisConnectionFactory factory = new JedisConnectionFactory();
factory.setHostName(clusterNodes.split(":")[0]);
factory.setPort(Integer.valueOf(clusterNodes.split(":")[1]));
factory.setPassword(password);
factory.setTimeout(timeout);
return factory;
} else {
//集群模式 //集群模式
JedisConnectionFactory factory = new JedisConnectionFactory(redisClusterConfiguration(),getJedisPoolConfig()); JedisConnectionFactory factory = new JedisConnectionFactory(redisClusterConfiguration(),getJedisPoolConfig());
factory.setDatabase(0); factory.setDatabase(0);
...@@ -106,6 +115,7 @@ public class RedisClusterConfig { ...@@ -106,6 +115,7 @@ public class RedisClusterConfig {
factory.setUsePool(true); factory.setUsePool(true);
return factory; return factory;
} }
}
/** /**
* 实例化 RedisTemplate 对象 * 实例化 RedisTemplate 对象
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment