一、简介
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.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，可读性差
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
登录后复制
再次测试，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并返回数据。
以上就是Redis缓存实例代码分析的详细内容，更多请关注【创想鸟】其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至253000106@qq.com举报，一经查实，本站将立刻删除。
发布者：PHP中文网，转转请注明出处：https://www.chuangxiangniao.com/p/2030698.html
