更新

whycxzp

2024-01-10 9a2b1251fc48874b76d3b02dbfc306698325dfeb

 src/main/java/com/whyc/config/RedisConfig.java

@@ -31,7 +31,7 @@
    @ConditionalOnProperty(name = "redis.model", havingValue = "single")
    @Order(1)
    RedissonClient redissonClientSingle() {
        log.error("redis单机版client初始化了");
        log.error("redis single client初始化了");
        Config config = new Config();
        String node = redisProperties.getSingle().getAddress();
        SingleServerConfig serverConfig = config.useSingleServer()
@@ -53,7 +53,7 @@
    @Bean("redisClient")
    @ConditionalOnProperty(name = "redis.model", havingValue = "sentinel")
    RedissonClient redissonClientSentinel() {
        log.error("redis单机版client初始化了");
        log.error("redis sentinel client初始化了");
        Config config = new Config();

        String[] nodes = redisProperties.getSentinel().getNodes().split(",");
@@ -79,7 +79,7 @@
    @Bean("redisClient")
    @ConditionalOnProperty(name = "redis.model", havingValue = "cluster")
    RedissonClient redissonClientCluster() {
        log.error("redis单机版client初始化了");
        log.error("redis cluster client初始化了");
        Config config = new Config();
        RedisClusterProperties cluster = redisProperties.getCluster();
        RedisPoolProperties pool = redisProperties.getPool();
@@ -102,4 +102,25 @@
        return Redisson.create(config);
    }

    /**
     *
     */
    @Bean("redisClient")
    @ConditionalOnProperty(name = "redis.model", havingValue = "master-slave")
    RedissonClient redissonClientMasterSlave() {
        log.error("redis master-slave client初始化了");
        Config config = new Config();
        RedisClusterProperties cluster = redisProperties.getCluster();
        RedisPoolProperties pool = redisProperties.getPool();
        String[] nodes = cluster.getNodes().split(",");
        MasterSlaveServersConfig serversConfig = config.useMasterSlaveServers()
                .setMasterAddress(nodes[0])
                .addSlaveAddress(nodes[1]);

        if (!StringUtils.isEmpty(redisProperties.getPassword())) {
            serversConfig.setPassword(redisProperties.getPassword());
        }
        return Redisson.create(config);
    }

}