springboot2.x怎么集成缓存注解及设置过期时间
本篇内容介绍了“springboot2.x怎么集成缓存注解及设置过期时间”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
公司主营业务:成都网站制作、成都网站设计、外贸营销网站建设、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。成都创新互联是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。成都创新互联推出阿荣免费做网站回馈大家。
添加以下配置信息;
/** * 基于注解添加缓存 */ @Configuration @EnableCaching public class CacheConfig extends CachingConfigurerSupport { private final redisConnectionFactory redisConnectionFactory; CacheConfig(RedisConnectionFactory redisConnectionFactory) { this.redisConnectionFactory = redisConnectionFactory; } @Bean @Override public KeyGenerator keyGenerator() { return (o, method, objects) -> { StringBuilder sb = new StringBuilder(32); sb.append(o.getClass().getSimpleName()); sb.append("."); sb.append(method.getName()); if (objects.length > 0) { sb.append("#"); } String sp = ""; for (Object object : objects) { sb.append(sp); if (object == null) { sb.append("NULL"); } else { sb.append(object.toString()); } sp = "."; } return sb.toString(); }; } /** * 配置 RedisCacheManager,使用 cache 注解管理 redis 缓存 */ @Bean @Override public CacheManager cacheManager() { // 初始化一个RedisCacheWriter RedisCacheWriter cacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory); // 设置默认过期时间:30 分钟 RedisCacheConfiguration defaultCacheConfig = RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofMinutes(30)) // .disableCachingNullValues() // 使用注解时的序列化、反序列化 .serializeKeysWith(MyRedisCacheManager.STRING_PAIR) .serializeValuesWith(MyRedisCacheManager.FASTJSON_PAIR); return new MyRedisCacheManager(cacheWriter, defaultCacheConfig); } }
redis
配置信息:
@Configuration @ConditionalOnClass(RedisOperations.class) @EnableConfigurationProperties(RedisProperties.class) @Import({LettuceConnectionConfiguration.class}) public class RedisConfig { @Bean @ConditionalOnMissingBean(name = "redisTemplate") public RedisTemplate
重写RedisCacheManager
:
public class MyRedisCacheManager extends RedisCacheManager implements ApplicationContextAware, InitializingBean { private static final Logger LOGGER = LoggerFactory.getLogger(MyRedisCacheManager.class); private ApplicationContext applicationContext; private MapinitialCacheConfiguration = new LinkedHashMap<>(); /** * key serializer */ public static final StringRedisSerializer STRING_SERIALIZER = new StringRedisSerializer(); /** * value serializer * * 使用 FastJsonRedisSerializer 会报错:java.lang.ClassCastException * FastJsonRedisSerializer*/ public static final GenericFastJsonRedisSerializer FASTJSON_SERIALIZER = new GenericFastJsonRedisSerializer(); /** * key serializer pair */ public static final RedisSerializationContext.SerializationPairfastSerializer = new FastJsonRedisSerializer<>(Object.class); * STRING_PAIR = RedisSerializationContext .SerializationPair.fromSerializer(STRING_SERIALIZER); /** * value serializer pair */ public static final RedisSerializationContext.SerializationPair FASTJSON_PAIR = RedisSerializationContext .SerializationPair.fromSerializer(FASTJSON_SERIALIZER); public MyRedisCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration) { super(cacheWriter, defaultCacheConfiguration); } @Override public Cache getCache(String name) { Cache cache = super.getCache(name); return new RedisCacheWrapper(cache); } @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { this.applicationContext = applicationContext; } @Override public void afterPropertiesSet() { String[] beanNames = applicationContext.getBeanNamesForType(Object.class); for (String beanName : beanNames) { final Class clazz = applicationContext.getType(beanName); add(clazz); } super.afterPropertiesSet(); } @Override protected Collection loadCaches() { List caches = new LinkedList<>(); for (Map.Entry entry : initialCacheConfiguration.entrySet()) { caches.add(super.createRedisCache(entry.getKey(), entry.getValue())); } return caches; } private void add(final Class clazz) { ReflectionUtils.doWithMethods(clazz, method -> { ReflectionUtils.makeAccessible(method); CacheExpire cacheExpire = AnnotationUtils.findAnnotation(method, CacheExpire.class); if (cacheExpire == null) { return; } Cacheable cacheable = AnnotationUtils.findAnnotation(method, Cacheable.class); if (cacheable != null) { add(cacheable.cacheNames(), cacheExpire); return; } Caching caching = AnnotationUtils.findAnnotation(method, Caching.class); if (caching != null) { Cacheable[] cs = caching.cacheable(); if (cs.length > 0) { for (Cacheable c : cs) { if (cacheExpire != null && c != null) { add(c.cacheNames(), cacheExpire); } } } } else { CacheConfig cacheConfig = AnnotationUtils.findAnnotation(clazz, CacheConfig.class); if (cacheConfig != null) { add(cacheConfig.cacheNames(), cacheExpire); } } }, method -> null != AnnotationUtils.findAnnotation(method, CacheExpire.class)); } private void add(String[] cacheNames, CacheExpire cacheExpire) { for (String cacheName : cacheNames) { if (cacheName == null || "".equals(cacheName.trim())) { continue; } long expire = cacheExpire.expire(); LOGGER.info("cacheName: {}, expire: {}", cacheName, expire); if (expire >= 0) { // 缓存配置 RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofSeconds(expire)) .disableCachingNullValues() // .prefixKeysWith(cacheName) .serializeKeysWith(STRING_PAIR) .serializeValuesWith(FASTJSON_PAIR); initialCacheConfiguration.put(cacheName, config); } else { LOGGER.warn("{} use default expiration.", cacheName); } } } protected static class RedisCacheWrapper implements Cache { private final Cache cache; RedisCacheWrapper(Cache cache) { this.cache = cache; } @Override public String getName() { // LOGGER.info("name: {}", cache.getName()); try { return cache.getName(); } catch (Exception e) { LOGGER.error("getName ---> errmsg: {}", e.getMessage(), e); return null; } } @Override public Object getNativeCache() { // LOGGER.info("nativeCache: {}", cache.getNativeCache()); try { return cache.getNativeCache(); } catch (Exception e) { LOGGER.error("getNativeCache ---> errmsg: {}", e.getMessage(), e); return null; } } @Override public ValueWrapper get(Object o) { // LOGGER.info("get ---> o: {}", o); try { return cache.get(o); } catch (Exception e) { LOGGER.error("get ---> o: {}, errmsg: {}", o, e.getMessage(), e); return null; } } @Override public T get(Object o, Class aClass) { // LOGGER.info("get ---> o: {}, clazz: {}", o, aClass); try { return cache.get(o, aClass); } catch (Exception e) { LOGGER.error("get ---> o: {}, clazz: {}, errmsg: {}", o, aClass, e.getMessage(), e); return null; } } @Override public T get(Object o, Callable callable) { // LOGGER.info("get ---> o: {}", o); try { return cache.get(o, callable); } catch (Exception e) { LOGGER.error("get ---> o: {}, errmsg: {}", o, e.getMessage(), e); return null; } } @Override public void put(Object o, Object o1) { // LOGGER.info("put ---> o: {}, o1: {}", o, o1); try { cache.put(o, o1); } catch (Exception e) { LOGGER.error("put ---> o: {}, o1: {}, errmsg: {}", o, o1, e.getMessage(), e); } } @Override public ValueWrapper putIfAbsent(Object o, Object o1) { // LOGGER.info("putIfAbsent ---> o: {}, o1: {}", o, o1); try { return cache.putIfAbsent(o, o1); } catch (Exception e) { LOGGER.error("putIfAbsent ---> o: {}, o1: {}, errmsg: {}", o, o1, e.getMessage(), e); return null; } } @Override public void evict(Object o) { // LOGGER.info("evict ---> o: {}", o); try { cache.evict(o); } catch (Exception e) { LOGGER.error("evict ---> o: {}, errmsg: {}", o, e.getMessage(), e); } } @Override public void clear() { // LOGGER.info("clear"); try { cache.clear(); } catch (Exception e) { LOGGER.error("clear ---> errmsg: {}", e.getMessage(), e); } } } }
应用:
@GetMapping("/getShopByShopNO/{shopNo}") public MonogetShopByShopNO(@PathVariable("shopNo") final String shopNo){ final ShopDO shopByShopNO = shopDAO.getShopByShopNO(shopNo); return Mono.just(shopByShopNO); } /** * 查询店铺详情 * @param shopNo * @return */ @Cacheable(value = "shop",key = "'shop_'.concat(#root.args[0])",sync = true) @CacheExpire(30) ShopDO getShopByShopNO(String shopNo);
参考:https://www.cnblogs.com/wjwen/p/9301119.html
“springboot2.x怎么集成缓存注解及设置过期时间”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!
当前文章:springboot2.x怎么集成缓存注解及设置过期时间
链接URL:http://myzitong.com/article/ghseop.html