前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >jedis连接redis集群中的一台无法操作?_jedis连接redis哨兵

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

作者头像
全栈程序员站长
发布2022-09-30 10:16:03
5960
发布2022-09-30 10:16:03
举报
文章被收录于专栏:全栈程序员必看

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

代码语言: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");

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

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022年9月9日 下,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档