SpringBoot使用Redis缓存

耗时一月收集的学习资料,强烈建议学习一下https://pan.quark.cn/s/b5638e1405d7正文开始1pom.xml引入jar包如下dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-redis/artifactId/dependency2修改项目启动类增加注解EnableCaching开启缓存功能如下packagespringboot;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cache.annotation.EnableCaching;importorg.springframework.scheduling.annotation.EnableScheduling;SpringBootApplicationEnableSchedulingEnableCachingpublicclassSpringbootApplication{publicstaticvoidmain(String[]args){SpringApplication.run(SpringbootApplication.class,args);}}3application.properties中配置Redis连接信息如下#Redis数据库索引默认为0 spring.redis.database0#Redis服务器地址 spring.redis.host172.31.19.222#Redis服务器连接端口 spring.redis.port6379#Redis服务器连接密码默认为空 spring.redis.password# 连接池最大连接数使用负值表示没有限制 spring.redis.pool.max-active8# 连接池最大阻塞等待时间使用负值表示没有限制 spring.redis.pool.max-wait-1# 连接池中的最大空闲连接 spring.redis.pool.max-idle8# 连接池中的最小空闲连接 spring.redis.pool.min-idle0# 连接超时时间毫秒 spring.redis.timeout04新建Redis缓存配置类RedisConfig如下packagespringboot.config;importorg.springframework.beans.factory.annotation.Value;importorg.springframework.cache.CacheManager;importorg.springframework.cache.annotation.CachingConfigurerSupport;importorg.springframework.cache.annotation.EnableCaching;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.data.redis.cache.RedisCacheManager;importorg.springframework.data.redis.connection.RedisConnectionFactory;importorg.springframework.data.redis.core.RedisTemplate;importorg.springframework.data.redis.core.StringRedisTemplate;importorg.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;importcom.fasterxml.jackson.annotation.JsonAutoDetect;importcom.fasterxml.jackson.annotation.PropertyAccessor;importcom.fasterxml.jackson.databind.ObjectMapper;/** * Redis缓存配置类 * author szekinwin * */ConfigurationEnableCachingpublicclassRedisConfigextendsCachingConfigurerSupport{Value(${spring.redis.host})privateStringhost;Value(${spring.redis.port})privateintport;Value(${spring.redis.timeout})privateinttimeout;//自定义缓存key生成策略// Bean// public KeyGenerator keyGenerator() {// return new KeyGenerator(){// Override// public Object generate(Object target, java.lang.reflect.Method method, Object... params) {// StringBuffer sb new StringBuffer();// sb.append(target.getClass().getName());// sb.append(method.getName());// for(Object obj:params){// sb.append(obj.toString());// }// return sb.toString();// }// };// }//缓存管理器BeanpublicCacheManagercacheManager(SuppressWarnings(rawtypes)RedisTemplateredisTemplate){RedisCacheManagercacheManagernewRedisCacheManager(redisTemplate);//设置缓存过期时间cacheManager.setDefaultExpiration(10000);returncacheManager;}BeanpublicRedisTemplateString,StringredisTemplate(RedisConnectionFactoryfactory){StringRedisTemplatetemplatenewStringRedisTemplate(factory);setSerializer(template);//设置序列化工具template.afterPropertiesSet();returntemplate;}privatevoidsetSerializer(StringRedisTemplatetemplate){SuppressWarnings({rawtypes,unchecked})Jackson2JsonRedisSerializerjackson2JsonRedisSerializernewJackson2JsonRedisSerializer(Object.class);ObjectMapperomnewObjectMapper();om.setVisibility(PropertyAccessor.ALL,JsonAutoDetect.Visibility.ANY);om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(om);template.setValueSerializer(jackson2JsonRedisSerializer);}}5新建UserMapper如下packagespringboot.dao;importorg.apache.ibatis.annotations.Delete;importorg.apache.ibatis.annotations.Insert;importorg.apache.ibatis.annotations.Mapper;importorg.apache.ibatis.annotations.Param;importorg.apache.ibatis.annotations.Select;importorg.apache.ibatis.annotations.Update;importorg.springframework.cache.annotation.CacheConfig;importorg.springframework.cache.annotation.CacheEvict;importorg.springframework.cache.annotation.CachePut;importorg.springframework.cache.annotation.Cacheable;importspringboot.domain.User;MapperCacheConfig(cacheNamesusers)publicinterfaceUserMapper{Insert(insert into user(name,age) values(#{name},#{age}))intaddUser(Param(name)Stringname,Param(age)Stringage);Select(select * from user where id #{id})Cacheable(key#p0)UserfindById(Param(id)Stringid);CachePut(key#p0)Update(update user set name#{name} where id#{id})voidupdataById(Param(id)Stringid,Param(name)Stringname);//如果指定为 true则方法调用后将立即清空所有缓存CacheEvict(key#p0,allEntriestrue)Delete(delete from user where id#{id})voiddeleteById(Param(id)Stringid);}Cacheable将查询结果缓存到redis中key“#p0”指定传入的第一个参数作为redis的key。CachePut指定key将更新的结果同步到redis中CacheEvict指定key删除缓存数据allEntriestrue,方法调用后将立即清除缓存6service层与controller层跟上一篇整合一样启动redis服务器redis服务器的安装与启动可以参考之前的博客地址如下http://www.cnblogs.com/gdpuzxs/p/6623171.html7配置log4j日志信息如下##LOG4J配置 log4j.rootCategoryDEBUG,stdout ## 控制台输出 log4j.appender.stdoutorg.apache.log4j.ConsoleAppenderlog4j.appender.stdout.layoutorg.apache.log4j.PatternLayoutlog4j.appender.stdout.layout.ConversionPattern%d{yyyy-MM-ddHH:mm:ss,SSS}%5p%c{1}:%L-%m%n8验证redis缓存首先我们向user表总插入一条数据数据库显示如下现在我们查询一下user表中id24的数据观擦控制台输出的信息如下通过控制台输出信息我们可以知道这次执行了数据库查询并开启了Redis缓存查询结果。接下来我们再次查询user表中id24的数据观察控制台如下通过控制台输出信息我们可以知道这次并没有执行数据库查询而是从Redis缓存中查询并返回查询结果。我们查看redis中的信息如下方法finduser方法使用了注解Cacheable(key“#p0”)即将id作为redis中的key值。当我们更新数据的时候应该使用CachePut(key“#p0”)进行缓存数据的更新否则将查询到脏数据。完结撒花