目录

一、简介

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

    org.springframework.boot    spring-boot-starter-data-redis    org.apache.commons    commons-pool2    com.fasterxml.jackson.core    jackson-databind    com.fasterxml.jackson.datatype    jackson-datatype-jsr310

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.7bin/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,可读性差

2、Redis配置文件

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

@Configurationpublic class RedisConfig {    @Bean    public RedisTemplate redisTemplate(LettuceConnectionFactory redisConnectionFactory) {        RedisTemplate redisTemplate = new RedisTemplate();        redisTemplate.setConnectionFactory(redisConnectionFactory);        //首先解决key的序列化方式        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();        redisTemplate.setKeySerializer(stringRedisSerializer);        //解决value的序列化方式        Jackson2JsonRedisSerializer 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存储

3、取值测试

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

四、将数据字典存入redis

DictServiceImpl

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

@Resourceprivate RedisTemplate redisTemplate;@Overridepublic List listByParentId(Long parentId) {    //先查询redis中是否存在数据列表    List dictList = null;    try {        dictList = (List)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().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并返回数据。

Copyright © maxssl.com 版权所有 浙ICP备2022011180号