SpringBoot 项目使用 redis
1、 直接引入 spring-boot-starter-data-redis 依赖
gradle引入依赖
implementation 'org.springframework.boot:spring-boot-starter-data-redis'
2、在application.yml 增加redis配置
spring:
redis:
host: 10.111.11.111
port: 6379
database:
1
3、直接在Srevice层注入redisTemplate即可使用
@Autowired
RedisTemplate<String,String> redisTemplate;
上面这种是基础的用法，但如果我的数据存放在不同的redis库中呢?上面的方式显然只能从数据库1 中取数据。
如果配置多个数据库需要增加Redis配置
1、修改application.yml配置文件
spring:
redis:
host: 10.111.111.111
port: 6379
database:
db5: 5
db6: 6
db7: 7
timeout: 3000
pool:
max-active: 100
max-idle: 3
min-idle: 0
max-wait: -1
password:
2、增加配置类 RedisConfig
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
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 java.time.Duration;
@Configuration
public class RedisConfig {
@Value("${spring.redis.database.db5}")
private int db5;
@Value("${spring.redis.database.db6}")
private int db6;
@Value("${spring.redis.database.db7}")
private int db7;
@Value("${spring.redis.host}")
private String host;
@Value("${spring.redis.password}")
private String password;
@Value("${spring.redis.port}")
private int port;
@Value("${spring.redis.timeout}")
private int timeout;
@Value("${spring.redis.pool.max-idle}")
private int maxIdle;
@Value("${spring.redis.pool.max-active}")
private int maxActive;
@Value("${spring.redis.pool.min-idle}")
private int minIdle;
@Value("${spring.redis.pool.max-wait}")
private long maxWait;
@Bean
public GenericObjectPoolConfig getPoolConfig(){
// 配置redis连接池
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
poolConfig.setMaxTotal(maxActive);
poolConfig.setMaxIdle(maxIdle);
poolConfig.setMinIdle(minIdle);
poolConfig.setMaxWaitMillis(maxWait);
return poolConfig;
}
@Bean(name = "redisTemplate7")
public StringRedisTemplate getRedisTemplate7(){
return getStringRedisTemplate(db7);
}
@Bean(name = "redisTemplate5")
public StringRedisTemplate getRedisTemplate5(){
return getStringRedisTemplate(db5);
}
@Bean(name = "redisTemplate6")
public StringRedisTemplate getRedisTemplate6(){
return getStringRedisTemplate(db6);
}
private StringRedisTemplate getStringRedisTemplate(int database) {
// 构建工厂对象
RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
config.setHostName(host);
config.setPort(port);
//config.setPassword(RedisPassword.of(password));
LettucePoolingClientConfiguration clientConfig = LettucePoolingClientConfiguration.builder()
.commandTimeout(Duration.ofSeconds(timeout))
.poolConfig(getPoolConfig())
.build();
LettuceConnectionFactory factory = new LettuceConnectionFactory(config, clientConfig);
// 设置使用的redis数据库
factory.setDatabase(database);
// 重新初始化工厂
factory.afterPropertiesSet();
return new StringRedisTemplate(factory);
}
}
3、在配置过程中遇到的问题
关于RedisConfig配置类中的 GenericObjectPoolConfig类找不到的错误，这个类需要单独引入依赖
如果项目中有这个依赖的可以忽略
implementation 'org.apache.commons:commons-pool2'
第二个问题就是，配置好以后启动提示依赖注入的时候RedisTemplate 找到多个实现类，启动报错
Description:
Field redisTemplate in net.cnki.ds.management.userManage.service.impl.DownloadAuthorityServiceImpl required a single bean, but 3 were found:
- redisTemplate7: defined by method 'getRedisTemplate7' in class path resource [net/cnki/ds/management/userManage/config/RedisConfig.class]
- redisTemplate5: defined by method 'getRedisTemplate5' in class path resource [net/cnki/ds/management/userManage/config/RedisConfig.class]
- redisTemplate6: defined by method 'getRedisTemplate6' in class path resource [net/cnki/ds/management/userManage/config/RedisConfig.class]
Action:
这个问题的原因是使用@Autowired 进行自动注入的时候，他会去容器中查询这个类型的Bean，如果查到一个会直接装载，但是在上面配置中，虽然给Bean指定了name，但是自动注入的时候并没有指定要注入哪个，所以会查出来三个，发生上面报错。
解决方法：可以使用@Primary 注解，标识一下查找到多个库时，选择一个主要的进行注入。
image.png
但这样一直注入的都会是数据库7 显然也不满足需求。
所以还需要在@Autowired 上联合 使用@Qualifier 注解
@Autowired
@Qualifier("redisTemplate7")
RedisTemplate<String,String> redisTemplate;
@Qualifier注解就是 标识我们需要的具体是哪个实现， @Qualifier 里面的name 要和 容器里的bean name 一致。但是需要注意的是如果指定的bean name不存在，启动是会报错的，加了@Primary注解也是没用的。
