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

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

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

       <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");
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195666.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号