jedis连接redis集群
jedis连接redis集群
·
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>
spring:
redis:
password: 123456
database: 0
cluster:
nodes:
- 192.168.119.101:6111
- 192.168.119.101:6112
- 192.168.119.101:6113
- 192.168.119.101:6114
- 192.168.119.101:6115
- 192.168.119.101:6116
maxAttempts: 3
password: mypassword
jedis:
pool:
max-active: 1000
max-idle: 10
max-wait: -1
min-idle: 5
timeout: 6000
@Data
@Configuration
@ConfigurationProperties(prefix = "spring.redis")
@NoArgsConstructor
public class RedisProperties {
private int database = 0;
private String password;
private Duration timeout;
private String host="localhost";
private Integer port = 6379;
private RedisProperties.Cluster cluster;
private final RedisProperties.Jedis jedis = new RedisProperties.Jedis();
@Getter
@NoArgsConstructor
public static class Jedis {
private final RedisProperties.Pool pool = new RedisProperties.Pool();
}
@Data
@NoArgsConstructor
public static class Cluster {
private List<String> nodes;
private String password;
private Integer maxAttempts;
}
@Data
@NoArgsConstructor
public static class Pool {
private int maxIdle = 8;
private int minIdle = 0;
private int maxActive = 8;
private Duration maxWait = Duration.ofMillis(-1L);
}
}
@Slf4j
@Configuration
public class RedisConfig extends CachingConfigurerSupport {
@Autowired
private RedisProperties redisProperties;
@Bean
public JedisPoolConfig jedisPoolConfig() {
RedisProperties.Pool pool = redisProperties.getJedis().getPool();
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(pool.getMaxActive());
jedisPoolConfig.setMaxIdle(pool.getMaxIdle());
jedisPoolConfig.setMinIdle(pool.getMinIdle());
jedisPoolConfig.setMaxWait(pool.getMaxWait());
return jedisPoolConfig;
}
@Bean
public JedisPool jedisPool(JedisPoolConfig jedisPoolConfig) {
log.info("=====创建JedisPool连接池=====");
if(StringUtils.isNotEmpty(redisProperties.getPassword())) {
return new JedisPool(jedisPoolConfig, redisProperties.getHost(), redisProperties.getPort(),
redisProperties.getTimeout().getNano(), redisProperties.getPassword());
}
return new JedisPool(jedisPoolConfig, redisProperties.getHost(), redisProperties.getPort(),
redisProperties.getTimeout().getNano());
}
@Bean
public JedisCluster jedisCluster(){
RedisProperties.Cluster cluster = redisProperties.getCluster();
Set<HostAndPort> set = new HashSet<>();
HostAndPort hp = null;
List<String> nodes =cluster.getNodes();
if(nodes!=null&&nodes.size()>0){
for(int i=0;i<nodes.size();i++){
String[] hostPort = nodes.get(i).split(":");
if(hostPort!=null&&hostPort.length>0){
hp = new HostAndPort(hostPort[0],Integer.valueOf(hostPort[1]));
set.add(hp);
}
}
}
JedisCluster jedisCluster = new JedisCluster(set, redisProperties.getTimeout().getNano(),
redisProperties.getTimeout().getNano(), cluster.getMaxAttempts(), cluster.getPassword(), jedisPoolConfig());
/* JedisCluster jedisCluster = new JedisCluster(set);*/
return jedisCluster;
}
}
@Autowired
private JedisPool jedisPool;
@Cleanup Jedis jedis = jedisPool.getResource();
jedis.set("name","sgh");
@Autowired
private JedisCluster jedisCluster;
jedisCluster.set("name","sgh");
更多推荐
已为社区贡献12条内容
所有评论(0)