尚融宝14-集成redis缓存

港控/mmm° 2023-10-11 21:28 59阅读 0赞

**目录**

一、简介

1、场景

2、RedisTemplate

二、引入Redis

1、项目中集成Redis

2、添加Redis连接配置

3、启动Redis服务

三、测试RedisTemplate

1、存值测试

2、Redis配置文件

3、取值测试

四、将数据字典存入redis

--------------------

## 一、简介 ##

### 1、场景 ###

由于数据字典的变化不是很频繁，而且系统对数据字典的访问较频繁，所以我们有必要把数据字典的数据存入缓存，减少数据库压力和提高访问速度。这里，我们使用Redis作为系统的分布式缓存中间件。

### 2、RedisTemplate ###

在Spring Boot项目中中，默认集成Spring Data Redis，Spring Data Redis针对Redis提供了非常方便的操作模版RedisTemplate，并且可以进行连接池自动管理。

## 二、引入Redis ##

### 1、项目中集成Redis ###

**service-base**模块中添加redis依赖，Spring Boot 2.0以上默认通过commons-pool2连接池连接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>
    
    
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.datatype</groupId>
        <artifactId>jackson-datatype-jsr310</artifactId>
    </dependency>

### 2、添加Redis连接配置 ###

**service-core** 的 application.yml 中添加如下配置

#spring: 
      redis:
        host: 192.168.100.100
        port: 6379
        database: 0
        password: 123456 #默认为空
        timeout: 3000ms #最大等待时间，超时则抛出异常，否则请求一直等待
        lettuce:
          pool:
            max-active: 20  #最大连接数，负值表示没有限制，默认8
            max-wait: -1    #最大阻塞等待时间，负值表示没限制，默认-1
            max-idle: 8     #最大空闲连接，默认8
            min-idle: 0     #最小空闲连接，默认0

### 3、启动Redis服务 ###

远程连接Linux服务器，这里本地使用centos虚拟机上的redis

#启动服务
    cd /usr/local/redis-5.0.7
    bin/redis-server redis.conf

## 三、测试RedisTemplate ##

### 1、存值测试 ###

test中创建测试类RedisTemplateTests

@SpringBootTest
    @RunWith(SpringRunner.class)
    public class RedisTemplateTests {
        @Resource
        private RedisTemplate redisTemplate;
        @Resource
        private DictMapper dictMapper;
        @Test
        public void saveDict(){
            Dict dict = dictMapper.selectById(1);
            //向数据库中存储string类型的键值对, 过期时间5分钟
            redisTemplate.opsForValue().set("dict", dict, 5, TimeUnit.MINUTES);
        }
    }

发现RedisTemplate默认使用了JDK的序列化方式存储了key和value，可读性差

![ae063a48f2e44b5a9bed3d2eb8935fd8.png][]

### 2、Redis配置文件 ###

**service-base**中添加RedisConfig，我们可以在这个配置文件中配置Redis序列化方案

@Configuration
    public class RedisConfig {
    
    
        @Bean
        public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory redisConnectionFactory) {
    
            RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
            redisTemplate.setConnectionFactory(redisConnectionFactory);
    
            //首先解决key的序列化方式
            StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
            redisTemplate.setKeySerializer(stringRedisSerializer);
    
            //解决value的序列化方式
            Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
    
            //序列化时将类的数据类型存入json，以便反序列化的时候转换成正确的类型
            ObjectMapper objectMapper = new ObjectMapper();
            //objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
    
            // 解决jackson2无法反序列化LocalDateTime的问题
            objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
            objectMapper.registerModule(new JavaTimeModule());
    
            jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
    
    
            redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
            return redisTemplate;
        }
    }

再次测试，key使用了字符串存储，value使用了json存储

![3c6bb65130c24e05947e6d20fa54a0e3.png][]

### 3、取值测试 ###

@Test
    public void getDict(){
        Dict dict = (Dict)redisTemplate.opsForValue().get("dict");
        System.out.println(dict);
    }

##  ##

## 四、将数据字典存入redis ##

DictServiceImpl

注意：当redis服务器宕机时，我们不要抛出异常，要正常的执行后面的流程，使业务可以正常的运行

@Resource
    private RedisTemplate redisTemplate;
    
    @Override
    public List<Dict> listByParentId(Long parentId) {
    
        //先查询redis中是否存在数据列表
        List<Dict> dictList = null;
        try {
            dictList = (List<Dict>)redisTemplate.opsForValue().get("srb:core:dictList:" + parentId);
            if(dictList != null){
                log.info("从redis中取值");
                return dictList;
            }
        } catch (Exception e) {
            log.error("redis服务器异常：" + ExceptionUtils.getStackTrace(e));//此处不抛出异常，继续执行后面的代码
        }
    
        log.info("从数据库中取值");
        dictList = baseMapper.selectList(new QueryWrapper<Dict>().eq("parent_id", parentId));
        dictList.forEach(dict -> {
            //如果有子节点，则是非叶子节点
            boolean hasChildren = this.hasChildren(dict.getId());
            dict.setHasChildren(hasChildren);
        });
    
        //将数据存入redis
        try {
            redisTemplate.opsForValue().set("srb:core:dictList:" + parentId, dictList, 5, TimeUnit.MINUTES);
            log.info("数据存入redis");
        } catch (Exception e) {
            log.error("redis服务器异常：" + ExceptionUtils.getStackTrace(e));//此处不抛出异常，继续执行后面的代码
        }
        return dictList;
    }

> **集成redis总结**：
> 
> （1）导入相关依赖；
> 
> （2）配置redis连接信息；
> 
> （3）测试连接，取值测试，存值测试；
> 
> （4）根据自己的需要配置序列化器，否则默认使用jdk的序列化器。
> 
> **redis业务总结：**
> 
> （1）首先查询redis中有无对应的缓存信息，有的话取出直接返回，没有执行（2），如果redis因为某种原因连接不上比如宕机，此时打印错误日志，继续查询数据库；
> 
> （2）没有的话查询数据库，将数据存放进redis并返回数据。

[ae063a48f2e44b5a9bed3d2eb8935fd8.png]: https://img-blog.csdnimg.cn/ae063a48f2e44b5a9bed3d2eb8935fd8.png
[3c6bb65130c24e05947e6d20fa54a0e3.png]: https://img-blog.csdnimg.cn/3c6bb65130c24e05947e6d20fa54a0e3.png