SpringBoot + RedisConnectionFactory 主从同步+哨兵配置

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实现高可用性和数据可靠性