Spring boot 配置 Redis哨兵模式-蒲公英云

Spring boot 配置 Redis哨兵模式

- 日理万妓 2022-05-08 14:56 1466阅读 0赞

Spring官方提供了Redis哨兵的配置，这篇文章主要指导读者手动配置Redis哨兵模式
ps: 参考我的文章<<Spring boot 配置 Redis集群模式>>可将该配置改成按资源文件加载

以下是我搜集并整理出来的一个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.RedisNode;
import org.springframework.data.redis.connection.RedisSentinelConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.util.StringUtils;
import javax.naming.Context;
import javax.naming.InitialContext;
import java.util.HashSet;
import java.util.Set;
/**
 * Redis 配置集群
 */
@Configuration
public class RedisConfig {
    private final Logger logger = LoggerFactory.getLogger(RedisConfig.class);
    @Value("${redis.jndi-name}")
    private String redisJndiName;
    /**
     * 创建连接工厂
     * @return
     */
    @Bean
    public JedisConnectionFactory createConnectionFactory() {
        JedisConnectionFactory jedisConnectionFactory = null;
        // 哨兵模式
        RedisSentinelConfiguration redisSentinelConfiguration = new RedisSentinelConfiguration();
        try {
            // 加载JNDI配置(因为有些敏感信息运维是不希望IT直接看到的)
            Context context = new InitialContext();
            RedisConfigBean redisConfigBean = (RedisConfigBean)context.lookup(redisJndiName);
            // 设置哨兵Master
            redisSentinelConfiguration.setMaster(redisConfigBean.getMasterName());
            // 获取到所有节点
            Set<String> serviceRedisNodes = redisConfigBean.getSentinelNodes();
            // 转换成Redis点节
            Set<RedisNode> sentinelNodes = new HashSet<>();
            for(String node : serviceRedisNodes) {
                String[] ipAndPort = StringUtils.split(node, ":");
                String ip = ipAndPort[0];
                Integer port = Integer.parseInt(ipAndPort[1]);
                sentinelNodes.add(new RedisNode(ip, port));
            }
            redisSentinelConfiguration.setSentinels(sentinelNodes);
            // 创建连接工厂
            jedisConnectionFactory = new JedisConnectionFactory(redisSentinelConfiguration, redisConfigBean.getMasterPoolConfig());
            jedisConnectionFactory.setDatabase(redisConfigBean.getDatabase());
            jedisConnectionFactory.setPassword(redisConfigBean.getPassword());
        } 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;
    }
}
package cn.xt.config;
import redis.clients.jedis.JedisPoolConfig;
import java.util.Set;
/**
 * Redis配置(若为规范项目，该类包名请配置到项目的DTO中)
 */
public class RedisConfigBean {
    private String masterName;
    private Set<String> sentinelNodes;
    private JedisPoolConfig masterPoolConfig;
    private Integer database;
    private String password;
    public String getMasterName() {
        return masterName;
    }
    public void setMasterName(String masterName) {
        this.masterName = masterName;
    }
    public Set<String> getSentinelNodes() {
        return sentinelNodes;
    }
    public void setSentinelNodes(Set<String> sentinelNodes) {
        this.sentinelNodes = sentinelNodes;
    }
    public JedisPoolConfig getMasterPoolConfig() {
        return masterPoolConfig;
    }
    public void setMasterPoolConfig(JedisPoolConfig masterPoolConfig) {
        this.masterPoolConfig = masterPoolConfig;
    }
    public Integer getDatabase() {
        return database;
    }
    public void setDatabase(Integer database) {
        this.database = database;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
}