一、简介1、场景由于数据字典的变化不是很频繁，而且系统对数据字典的访问较频繁，所以我们有必要把数据字典的数据存入缓存，减少数据库压力和提高访问速度。这里，我们使用redis作为系统的分布式缓存中间件。
2、redistemplate在spring boot项目中中，默认集成spring data redis，spring data redis针对redis提供了非常方便的操作模版redistemplate，并且可以进行连接池自动管理。
二、引入redis1、项目中集成redisservice-base模块中添加redis依赖，spring boot 2.0以上默认通过commons-pool2连接池连接redis
<!-- spring boot 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><!-- redis 存储 json序列化 --><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
三、测试redistemplate1、存值测试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<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存储
3、取值测试@testpublic void getdict(){ dict dict = (dict)redistemplate.opsforvalue().get("dict"); system.out.println(dict);}
四、将数据字典存入redisdictserviceimpl
注意：当redis服务器宕机时，我们不要抛出异常，要正常的执行后面的流程，使业务可以正常的运行
@resourceprivate redistemplate redistemplate;@overridepublic 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并返回数据。
以上就是redis缓存实例代码分析的详细内容。