SpringBoot Redis 高可用配置：主从同步 + 哨兵

SpringBoot 是一个快速开发的框架，而 Redis 是一个开源的内存数据存储系统。Redis 支持主从同步和哨兵配置，这使得 Redis 在高可用性和数据可靠性方面表现出色。

在 SpringBoot 中使用 RedisConnectionFactory 进行 Redis 的配置。RedisConnectionFactory 是 Redis 连接工厂，它可以用于创建 Redis 连接和操作 Redis 数据库。

在主从同步配置中，Redis 服务器会自动将主服务器上的数据同步到从服务器上。在哨兵配置中，Redis 服务器会自动监控主服务器的状态，并在主服务器宕机时自动切换到从服务器。

以下是 SpringBoot + RedisConnectionFactory 主从同步 + 哨兵配置的示例代码：

添加 Redis 依赖

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

配置 Redis 连接信息

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password: 
    database: 0
    sentinel:
      master: mymaster
      nodes: 127.0.0.1:26379,127.0.0.1:26380,127.0.0.1:26381

配置 RedisConnectionFactory

@Configuration
public class RedisConfig {

    @Value("${spring.redis.host}")
    private String host;

    @Value("${spring.redis.port}")
    private int port;

    @Value("${spring.redis.password}")
    private String password;

    @Value("${spring.redis.database}")
    private int database;

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

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

    @Bean
    public RedisConnectionFactory redisConnectionFactory() {
        RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration()
                .master(sentinelMaster)
                .sentinel(hostAndPortSet(sentinelNodes));

        JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(sentinelConfig);
        jedisConnectionFactory.setPassword(password);
        jedisConnectionFactory.setDatabase(database);
        jedisConnectionFactory.afterPropertiesSet();

        return jedisConnectionFactory;
    }

    private Set<RedisNode> hostAndPortSet(String nodes) {
        Set<RedisNode> hostAndPortSet = new HashSet<>();
        String[] hostAndPorts = nodes.split(",");
        for (String hostAndPort : hostAndPorts) {
            String[] split = hostAndPort.split(":");
            hostAndPortSet.add(new RedisNode(split[0], Integer.parseInt(split[1])));
        }
        return hostAndPortSet;
    }
}

测试 Redis 连接

@Service
public class RedisService {

    private final RedisTemplate<String, String> redisTemplate;

    @Autowired
    public RedisService(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    public void set(String key, String value) {
        redisTemplate.opsForValue().set(key, value);
    }

    public String get(String key) {
        return redisTemplate.opsForValue().get(key);
    }
}

@Service
public class RedisTestService {

    private final RedisService redisService;

    @Autowired
    public RedisTestService(RedisService redisService) {
        this.redisService = redisService;
    }

    public void test() {
        String key = "test";
        String value = "hello world";
        redisService.set(key, value);
        String result = redisService.get(key);
        System.out.println(result);
    }
}

以上就是 SpringBoot + RedisConnectionFactory 主从同步 + 哨兵配置的示例代码。通过以上配置和代码，可以使用 Redis 实现高可用性和数据可靠性。