jedis连接redis集群中的一台无法操作?_jedis连接redis哨兵

大家好，又见面了，我是你们的朋友全栈君。

代码语言：javascript复制

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

代码语言：javascript复制

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

代码语言：javascript复制

@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);
    }
}

代码语言：javascript复制

@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;
    }
}

代码语言：javascript复制

    @Autowired
    private JedisPool jedisPool;

    @Cleanup Jedis jedis = jedisPool.getResource();
    jedis.set("name","sgh");

代码语言：javascript复制

 @Autowired
 private JedisCluster jedisCluster;

jedisCluster.set("name","sgh");

互联网全栈

0 人点赞