Spring boot 配置 Redis集群模式

港控/mmm° 2022-05-07 09:36 424阅读 0赞

**Spring官方提供了Redis集群的配置，这里不复述官方的文档，这篇文章主要指导读者手动配置Redis集群**

ps: 参考我的文章<<[Spring boot 配置 Redis哨兵模式][Spring boot _ Redis]>>可将该配置改成JNDI形式加载

以下是我搜集并整理出来的一个configuration，不足之处或错误请大家提出并指正

package cn.xt.config;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.RedisClusterConfiguration;
    import org.springframework.data.redis.connection.RedisNode;
    import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.util.StringUtils;
    import redis.clients.jedis.JedisPoolConfig;
    
    import java.util.Arrays;
    import java.util.HashSet;
    import java.util.Set;
    
    /**
     * Redis 配置集群
     */
    @Configuration
    public class RedisConfig {
    
        private final Logger logger = LoggerFactory.getLogger(RedisConfig.class);
    
        // private final String defaultClusterNodes = "10.16.5.43:6379,10.16.5.44:6379,10.16.5.45:6379";
    
        @Value("${redis.cluster.nodes}")
        private String clusterNodes;
    
        @Value("${redis.password}")
        private String password;
    
        @Value("${redis.pool.max-active}")
        private Integer maxTotal;
    
        @Value("${redis.pool.max-idle}")
        private Integer maxIdle;
    
        @Value("${redis.pool.min-idle}")
        private Integer minIdle;
    
        @Value("${redis.pool.max-wait}")
        private Integer maxWaitMillis;
    
        /**
         * 创建连接工厂
         * @return
         */
        @Bean
        public JedisConnectionFactory createConnectionFactory() {
            JedisConnectionFactory jedisConnectionFactory = null;
            // 集群模式
            RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
            // 加载服务器集群节点
            Set<String> serviceRedisNodes = new HashSet<>(Arrays.asList(clusterNodes.split(",")));
            try {
                // 转换成Redis点节
                Set<RedisNode> clusterNodes = new HashSet<>(serviceRedisNodes.size());
                for(String node : serviceRedisNodes) {
                    String[] ipAndPort = StringUtils.split(node, ":");
                    String ip = ipAndPort[0];
                    Integer port = Integer.parseInt(ipAndPort[1]);
                    clusterNodes.add(new RedisNode(ip, port));
                }
                redisClusterConfiguration.setClusterNodes(clusterNodes);
    
                // Redis 连接池配置
                JedisPoolConfig poolConfig = new JedisPoolConfig();
                poolConfig.setMaxIdle(maxIdle);
                poolConfig.setMaxTotal(maxTotal);
                poolConfig.setMinIdle(minIdle);
                poolConfig.setMaxWaitMillis(maxWaitMillis);
    
                // 创建连接工厂
                jedisConnectionFactory = new JedisConnectionFactory(redisClusterConfiguration, poolConfig);
                // 设置数据库
                jedisConnectionFactory.setDatabase(0);
                // 设置密码
                jedisConnectionFactory.setPassword(password);
            } catch (Exception e) {
                logger.error("创建Redis连接工厂错误：{}", e);
            }
            return jedisConnectionFactory;
        }
    
        /**
         * 注册RedisTemplate
         * @param factory 连接工厂
         * @return
         */
        @Bean
        public RedisTemplate registerRedisTemplate(JedisConnectionFactory factory) {
            RedisTemplate redisTemplate = new RedisTemplate();
            redisTemplate.setConnectionFactory(factory);
            return redisTemplate;
        }
    
    }

[Spring boot _ Redis]: https://blog.csdn.net/qq_20698983/article/details/83056689