SpringBoot154+spring-data-redis181+LettucePool实现Redis哨兵模式

Redis哨兵模式是Redis的一种高可用方案，它通过自动监控Redis Master和Slave的健康状态，当Master不可用时会自动切换到Slave上。在SpringBoot中，我们可以使用spring-data-redis和LettucePool来实现Redis哨兵模式。

添加依赖

在pom.xml中添加以下依赖：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

<dependency>
  <groupId>io.lettuce</groupId>
  <artifactId>lettuce-core</artifactId>
  <version>5.1.1.RELEASE</version>
</dependency>

配置Redis

在application.properties中配置Redis的连接信息和哨兵信息：

spring.redis.sentinel.master=mymaster
spring.redis.sentinel.nodes=127.0.0.1:26379,127.0.0.1:26380,127.0.0.1:26381

配置RedisTemplate

在配置类中配置RedisTemplate：

@Configuration
public class RedisConfig {

    @Autowired
    private LettuceConnectionFactory lettuceConnectionFactory;

    @Bean
    public RedisTemplate<String, Object> redisTemplate() {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(lettuceConnectionFactory);
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
        return redisTemplate;
    }

}

配置LettucePool

在配置类中配置LettucePool：

@Configuration
public class RedisConfig {

    @Value("${spring.redis.sentinel.master}")
    private String masterName;

    @Value("${spring.redis.sentinel.nodes}")
    private String sentinelNodes;

    @Bean
    public LettuceConnectionFactory lettuceConnectionFactory() {
        RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration()
                .master(masterName)
                .sentinel(sentinels(sentinelNodes));

        LettucePoolingClientConfiguration lettucePoolingClientConfiguration = LettucePoolingClientConfiguration.builder()
                .poolConfig(new GenericObjectPoolConfig())
                .build();

        return new LettuceConnectionFactory(sentinelConfig, lettucePoolingClientConfiguration);
    }

    private Set<RedisNode> sentinels(String nodes) {
        Set<RedisNode> sentinelNodes = new HashSet<>();
        String[] nodesArray = nodes.split(",");
        for (String node : nodesArray) {
            String[] parts = node.split(":");
            sentinelNodes.add(new RedisNode(parts[0], Integer.valueOf(parts[1])));
        }
        return sentinelNodes;
    }

}

使用RedisTemplate

在Controller中使用RedisTemplate操作Redis：

@RestController
public class RedisController {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @RequestMapping("/set")
    public String set() {
        redisTemplate.opsForValue().set("test", "Hello Redis Sentinel");
        return "OK";
    }

    @RequestMapping("/get")
    public String get() {
        return redisTemplate.opsForValue().get("test").toString();
    }

}

以上就是SpringBoot1.5.4+spring-data-redis1.8.1+LettucePool实现Redis哨兵模式的步骤