spring-boot配置redis多数据源 Redis

## 引用包
```
        
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>
```

## properties配置
```
redis-common:
    lettuce:
      pool:
        max-total: 16
        max-wait: -1
        max-idle: 2
        min-idle: 0
  redis-user-pool:
    host-name: bigdata005
    port: 60001
    database: 14
    password: ppwwdd
    timeout: 60000
```

## 多数据源配置
```
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * redis配置
 *
 * @author vanki
 */
@Configuration
public class RedisConfiguration {

/* ================================== 用户池Redis ================================== */

@Bean
    public StringRedisTemplate userPoolRedisTemplate(@Qualifier("userPoolRedisConnFactory") RedisConnectionFactory userPoolRedisConnFactory) {
        return getStringRedisTemplate(userPoolRedisConnFactory);
    }

@Primary
    @Bean
    public LettuceConnectionFactory userPoolRedisConnFactory(
            @Qualifier("userPoolRedisConfig") RedisStandaloneConfiguration userPoolRedisConfig,
            GenericObjectPoolConfig<?> redisPoolConfig
    ) {
        return new LettuceConnectionFactory(userPoolRedisConfig, LettucePoolingClientConfiguration.builder().poolConfig(redisPoolConfig).build());
    }

@Bean
    @ConfigurationProperties(prefix = "spring.redis-user-pool")
    public RedisStandaloneConfiguration userPoolRedisConfig() {
        return new RedisStandaloneConfiguration();
    }

/* ================================================================================ */

//    /* ================================== 多数据源模版 ================================== */
//
//    @Bean
//    public StringRedisTemplate secondRedisTemplate(@Qualifier("secondRedisConnFactory") RedisConnectionFactory secondRedisConnFactory) {
//        return getStringRedisTemplate(secondRedisConnFactory);
//    }
//
//    @Bean
//    public LettuceConnectionFactory secondRedisConnFactory(
//            @Qualifier("secondRedisConfig") RedisStandaloneConfiguration userPoolRedisConfig,
//            GenericObjectPoolConfig<?> redisPoolConfig
//    ) {
//        return new LettuceConnectionFactory(userPoolRedisConfig, LettucePoolingClientConfiguration.builder().poolConfig(redisPoolConfig).build());
//    }
//
//    @Bean
//    @ConfigurationProperties(prefix = "spring.redis-second")
//    public RedisStandaloneConfiguration secondRedisConfig() {
//        return new RedisStandaloneConfiguration();
//    }
//
//    /* ================================================================================ */

@Bean
    @ConfigurationProperties(prefix = "spring.redis-common.lettuce.pool")
    public GenericObjectPoolConfig<?> redisPoolConfig() {
        return new GenericObjectPoolConfig<>();
    }

protected StringRedisTemplate getStringRedisTemplate(RedisConnectionFactory factory) {
        final StringRedisTemplate template = new StringRedisTemplate();
        template.setConnectionFactory(factory);

StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        template.setKeySerializer(stringRedisSerializer);
        template.setHashKeySerializer(stringRedisSerializer);
        template.setValueSerializer(stringRedisSerializer);
        template.setHashValueSerializer(stringRedisSerializer);
        template.afterPropertiesSet();

return template;
    }

}
```

## 使用
```
@Autowired
private StringRedisTemplate userPoolRedisTemplate;
```

vanki

以色事他人，能得几时好。

创建： 2022-05-06 17:06:23

更新： 2022-05-06 17:08:47

spring-boot配置redis多数据源 Redis

TA的最新笔记

TA的最热笔记

欢 迎

登录

新朋友 注册

注册

老朋友 登录

spring-boot配置redis多数据源 Redis

TA的最新笔记

TA的最热笔记

欢迎

新朋友注册

老朋友登录