用spring boot 写一段redis 主从复制

以下是使用Spring Boot编写Redis主从复制的示例代码：

1. 引入Redis依赖

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

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

2. 配置Redis连接信息

在application.properties中添加以下配置信息：

# 主库
spring.redis.host=127.0.0.1
spring.redis.port=6379

# 从库
spring.redis.master.host=127.0.0.1
spring.redis.master.port=6380

3. 配置RedisTemplate

创建一个RedisTemplate配置类，用于配置RedisTemplate的序列化方式和连接工厂。以下是示例代码：

@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
        return redisTemplate;
    }

}

4. 编写Redis主从复制代码

创建一个Redis主从复制的Service类，使用Redisson框架实现。以下是示例代码：

@Service
public class RedisReplicationService {

    @Autowired
    private RedissonClient redissonClient;

    public void replicate() {
        RKeys keys = redissonClient.getKeys();
        Iterable<String> iterable = keys.getKeys();

        for (String key : iterable) {
            RMap<Object, Object> map = redissonClient.getMap(key);
            map.readAllMap();
        }
    }

}

5. 测试Redis主从复制

编写一个测试类，测试Redis主从复制是否正常工作。以下是示例代码：

@SpringBootTest
public class RedisReplicationServiceTest {

    @Autowired
    private RedisReplicationService redisReplicationService;

    @Test
    public void replicateTest() {
        redisReplicationService.replicate();
    }

}

以上就是使用Spring Boot编写Redis主从复制的示例代码。当主库的数据发生变化时，从库也会同步更新。