springboot+redisTemplate多库操作-编程知识

单库操作

我做了依赖管理，所以就不写版本号了
添加依赖

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

配置文件

spring:redis:database: 2host: 127.0.0.1port: 6379password: 123456

redisTemplate配置

    /*** @author liouwb*/@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);JavaTimeModule javaTimeModule = new JavaTimeModule();DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern(DateUtil.DateStyle.YYYY_MM_DD_HH_MM_SS.getValue());javaTimeModule.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(dateTimeFormatter));javaTimeModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(dateTimeFormatter));om.registerModule(javaTimeModule);jackson2JsonRedisSerializer.setObjectMapper(om);RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(jackson2JsonRedisSerializer);template.setHashKeySerializer(jackson2JsonRedisSerializer);template.setHashValueSerializer(jackson2JsonRedisSerializer);template.setDefaultSerializer(new StringRedisSerializer());template.afterPropertiesSet();return template;}

使用

    @Autowired(required = false)private RedisTemplate<String, Object> redisTemplate;@Testpublic void testRedis() {redisTemplate.opsForValue().set("redisTemplate", "redisTemplate");Object value = redisTemplate.opsForValue().get("redisTemplate");System.out.println("redis设置的值为：" + value);}

在这里插入图片描述

能够正常往redis设置数据，也可以正常获取到
可以看到数据库编号是yml里面配置的database编号

多库操作

使用lettuce连接池,添加commons-pools依赖

        <dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency>

配置类

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;/*** redis数据库配置** @author liouwb*/
@Data
@Configuration
public class RedisConfigProperties {@Value("${spring.redis.host}")private String host;@Value("${spring.redis.port}")private int port;@Value("${spring.redis.password}")private String password;/*** 连接超时时间* 目前不从配置文件获取*/private int timeout = 200;private int maxActive = 200;private int maxIdle = 8;private int minIdle = 0;private int maxWait = 100;
}

配置连接池

    /*** redis连接池** @author liouwb* @rutern org.apache.commons.pool2.impl.GenericObjectPoolConfig*/@Beanpublic GenericObjectPoolConfig getPoolConfig() {GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();poolConfig.setMaxTotal(redisConfigProperties.getMaxActive());poolConfig.setMaxIdle(redisConfigProperties.getMaxIdle());poolConfig.setMinIdle(redisConfigProperties.getMinIdle());poolConfig.setMaxWaitMillis(redisConfigProperties.getMaxWait());return poolConfig;}

设置redisTemplate操作模版工厂类

    /*** RedisTemplate连接工厂** @param database数据库编号* @author liouwb* @rutern org.springframework.data.redis.core.RedisTemplate<java.lang.String, java.lang.Object>*/private RedisTemplate<String, Object> redisTemplateFactory(int database) {// 构建工厂对象RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration();configuration.setHostName(redisConfigProperties.getHost());configuration.setPort(redisConfigProperties.getPort());configuration.setPassword(RedisPassword.of(redisConfigProperties.getPassword()));LettucePoolingClientConfiguration clientConfiguration = LettucePoolingClientConfiguration.builder().commandTimeout(Duration.ofSeconds(redisConfigProperties.getTimeout())).poolConfig(getPoolConfig()).build();// 连接工厂LettuceConnectionFactory factory = new LettuceConnectionFactory(configuration, clientConfiguration);// 设置使用的redis数据库factory.setDatabase(database);// 重新初始化工厂factory.afterPropertiesSet();// 序列化配置Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);JavaTimeModule javaTimeModule = new JavaTimeModule();DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern(DateUtil.DateStyle.YYYY_MM_DD_HH_MM_SS.getValue());javaTimeModule.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(dateTimeFormatter));javaTimeModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(dateTimeFormatter));om.registerModule(javaTimeModule);jackson2JsonRedisSerializer.setObjectMapper(om);// 初始化连接RedisTemplate<String, Object> template = new RedisTemplate<>();// 设置连接工厂template.setConnectionFactory(factory);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(jackson2JsonRedisSerializer);template.setHashKeySerializer(jackson2JsonRedisSerializer);template.setHashValueSerializer(jackson2JsonRedisSerializer);template.setDefaultSerializer(new StringRedisSerializer());template.afterPropertiesSet();return template;}

设置对应数据库的redisTemplate模版类

    /*** db0 第一个库** @author liouwb* @time 2024-01-03* @rutern org.springframework.data.redis.core.RedisTemplate<java.lang.String, java.lang.Object>*/@Beanpublic RedisTemplate<String, Object> redisTemplate0() {return this.redisTemplateFactory(0);}/*** db1 第二个库** @author liouwb* @rutern org.springframework.data.redis.core.RedisTemplate<java.lang.String, java.lang.Object>*/@Beanpublic RedisTemplate<String, Object> redisTemplate1() {return this.redisTemplateFactory(1);}

对不同redis库进行操作

    @Autowired(required = false)@Qualifier("redisTemplate0")private RedisTemplate<String, Object> redisTemplate0;@Autowired(required = false)@Qualifier("redisTemplate1")private RedisTemplate<String, Object> redisTemplate1;@Testpublic void testRedis() {redisTemplate0.opsForValue().set("redisTemplate0", "redisTemplate0");Object value0 = redisTemplate0.opsForValue().get("redisTemplate0");System.out.println("redis0设置的值为：" + value);redisTemplate1.opsForValue().set("redisTemplate1", "redisTemplate1");Object value1 = redisTemplate0.opsForValue().get("redisTemplate1");System.out.println("redis1设置的值为：" + value1);}