12
12
import redis .clients .jedis .JedisPoolConfig ;
13
13
import redis .clients .jedis .JedisSentinelPool ;
14
14
15
- /***
16
- * cluster模式 https://cloud.tencent.com/developer/article/1985822
17
- */
18
15
@ Data
19
16
@ Slf4j
20
17
public class RedisDataSource {
@@ -45,7 +42,7 @@ public class RedisDataSource {
45
42
public void createSingle () {
46
43
// 创建Jedis配置对象
47
44
String host = "127.0.0.1" ;
48
- String password = "root " ;
45
+ String password = "" ;
49
46
Integer port = 6379 ;
50
47
JedisPoolConfig config = new JedisPoolConfig ();
51
48
config .setMaxTotal (MAX_TOTAL );
@@ -62,9 +59,9 @@ public void createSingle() {
62
59
}
63
60
64
61
public void createSentinel () {
65
- Set <String > sentinels = new HashSet <String >(Arrays .asList ("47.108.49.213 :26379" , "47.108.49.213 :26380" , "47.108.49.213 :26381" ));
62
+ Set <String > sentinels = new HashSet <String >(Arrays .asList ("xxx :26379" , "xxx :26380" , "xxx :26381" ));
66
63
// 创建Jedis配置对象
67
- String password = "redis_pwd " ;
64
+ String password = "" ;
68
65
Integer port = 6379 ;
69
66
JedisPoolConfig poolConfig = new JedisPoolConfig ();
70
67
poolConfig .setMaxTotal (MAX_TOTAL );
@@ -84,12 +81,12 @@ public void createSentinel() {
84
81
public void createCluster () {
85
82
Set <HostAndPort > jedisClusterNode = new HashSet <HostAndPort >();
86
83
String password = "ztzh@smart666" ;
87
- jedisClusterNode .add (new HostAndPort ("47.108.49.213 " , 6371 ));
88
- jedisClusterNode .add (new HostAndPort ("47.108.49.213 " , 6372 ));
89
- jedisClusterNode .add (new HostAndPort ("47.108.49.213 " , 6373 ));
90
- jedisClusterNode .add (new HostAndPort ("47.108.49.213 " , 6374 ));
91
- jedisClusterNode .add (new HostAndPort ("47.108.49.213 " , 6375 ));
92
- jedisClusterNode .add (new HostAndPort ("47.108.49.213 " , 6376 ));
84
+ jedisClusterNode .add (new HostAndPort ("xxx " , 6371 ));
85
+ jedisClusterNode .add (new HostAndPort ("xxx " , 6372 ));
86
+ jedisClusterNode .add (new HostAndPort ("xxx " , 6373 ));
87
+ jedisClusterNode .add (new HostAndPort ("xxx " , 6374 ));
88
+ jedisClusterNode .add (new HostAndPort ("xxx " , 6375 ));
89
+ jedisClusterNode .add (new HostAndPort ("xxx " , 6376 ));
93
90
JedisPoolConfig poolConfig = new JedisPoolConfig ();
94
91
/*
95
92
* 注意: 在高版本的jedis jar包,比如本版本2.9.0,JedisPoolConfig没有setMaxActive和setMaxWait属性了
0 commit comments