这篇文章主要介绍了SpringBoot2整合Redis缓存三步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
遵循SpringBoot三板斧
第一步加依赖
<!-- Redis --> org.springframework.bootspring-boot-starter-data-redis<!-- redis依赖commons-pool 这个依赖一定要添加 --> org.apache.commonscommons-pool22.6.0
第二步写注解
@EnableCaching//开启缓存支持
第三步写配置
spring: redis: database: 0 host: 192.168.1.11 port: 6379 password: timeout: 600 lettuce: pool: max-active: 50 max-wait: -1 max-idle: 8 min-idle: 0
编写Redis配置类
/** * @Author: zc * @Date: 2019/11/3 14:12 * @Description: SpringBoot2.0 Redis缓存配置 * @EnableCaching:开启缓存支持 */ @Slf4j @Configuration @EnableCaching public class RedisConfig extends CachingConfigurerSupport { @Value("${sys.dataCaching.expireTime:0}") private int expireTime; @Resource private LettuceConnectionFactory lettuceConnectionFactory; @Override @Bean public KeyGenerator keyGenerator() {//设置自定义key{ClassName + methodName + params} return (target, method, params) -> { StringBuilder sb = new StringBuilder(); sb.append(target.getClass().getName()); sb.append(",Method:"); sb.append(method.getName()); sb.append(",Params["); for (int i = 0; i { StringBuilder sb = new StringBuilder(); sb.append(target.getClass().getName()); sb.append(",Method:"); sb.<strong style="color:transparent">来源gaodaima#com搞(代@码网</strong>append("getById"); sb.append(",Params["); try { Field id = params[0].getClass().getDeclaredField("id"); id.setAccessible(true); sb.append(id.get(params[0]).toString()); } catch (IllegalAccessException e) { e.printStackTrace(); } catch (NoSuchFieldException e) { e.printStackTrace(); } sb.append("]"); log.debug("Data Caching Redis Key : {}", sb.toString()); return sb.toString(); }; } //自定义keyGenerator,Key生成器 @Bean public KeyGenerator deleteByIdkeyGenerator() { return (target, method, params) -> { StringBuilder sb = new StringBuilder(); sb.append(target.getClass().getName()); sb.append(",Method:"); sb.append("getById"); sb.append(",Params["); for (int i = 0; i 0) { log.info("Redis 缓存过期时间 : {}", expireTime); //设置缓存有效期 秒 redisCacheConfiguration.entryTtl(Duration.ofSeconds(expireTime)); } else { log.info("Redis 未设置缓存过期时间"); } return RedisCacheManager .builder(RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory)) .cacheDefaults(redisCacheConfiguration).build(); } @Bean public RedisTemplate redisTemplate(RedisConnectionFactory factory) {//创建RedisTemplate // 设置序列化 Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer( Object.class); ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); // 配置redisTemplate RedisTemplate redisTemplate = new RedisTemplate(); redisTemplate.setConnectionFactory(lettuceConnectionFactory); RedisSerializer stringSerializer = new StringRedisSerializer(); // key序列化 redisTemplate.setKeySerializer(stringSerializer); // value序列化 redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); // Hash key序列化 redisTemplate.setHashKeySerializer(stringSerializer); // Hash value序列化 redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer); redisTemplate.afterPropertiesSet(); return redisTemplate; } }
如何使用查询缓存
@CacheConfig(cacheNames = "demoDao") @Component public class DemoDao implements IDemoDAO { @Autowired DemoMapper mapper; //用默认配置的keyGenerator @Cacheable @Override public Demo getById(Integer id) { return mapper.getById(id); } //使用配置的keyGenerator,清空缓存 @CacheEvict(keyGenerator = "updateByIdkeyGenerator") @Override public int update(T entity) { return mapper.update(entity); } //使用配置的keyGenerator,清空缓存 @CacheEvict(keyGenerator = "deleteByIdkeyGenerator") @Override public int deleteById(Integer id) { return mapper.deleteById(id); } }
以上就是SpringBoot2整合Redis缓存三步骤代码详解的详细内容,更多请关注gaodaima搞代码网其它相关文章!