tair整合Spring Cache

Spring从3.1开始定义了org.springframework.cache.Cache和org.springframework.cache.CacheManager接口来统一不同的缓存技术；并支持使用JCache（JSR-107）注解简化我们开发；

Cache接口为缓存的组件规范定义，包含缓存的各种操作集合；

Cache接口下Spring提供了各种xxxCache的实现；如RedisCache，EhCacheCache ,ConcurrentMapCache等；

但是Spring官方是没有提供Spring Cache tair的实现，需要自己去实现，当然要实现也比较简单，自己定义一个TairCache，实现Cache接口：

public class TairCache extends AbstractValueAdaptingCache implements Cache {private static final Logger log = LoggerFactory.getLogger(TairCache.class);private TairManager tairManager;private final String name;private int namespace;private int timeout;//是否允许null(默认true，高并发下防止缓存穿透)private boolean allowNullValues = true;public TairCache(String name, TairManager tairManager, int namespace) {this(name, tairManager, namespace, 0);}public TairCache(String name, TairManager tairManager, int namespace, int timeout) {this(name, tairManager, namespace,timeout, true);}public TairCache(String name, TairManager tairManager, int namespace, int timeout, boolean allowNullValues) {super(allowNullValues);this.name = name;this.tairManager = tairManager;this.namespace = namespace;this.timeout = timeout;}@Overridepublic String getName() {return this.name;}@Overridepublic Object getNativeCache() {return this.tairManager;}@Overridepublic ValueWrapper get(Object key) {final String tairKey = String.format("%s:%s", this.name, key);final Result<DataEntry> result = this.tairManager.get(this.namespace, tairKey);if (result.isSuccess() && (result.getRc() == ResultCode.SUCCESS)) {final Object value = result.getValue().getValue();return this.toValueWrapper(value);}return null;}@Overridepublic <T> T get(Object key, Class<T> type) {return (T) this.get(key).get();}@Overrideprotected Object lookup(Object o) {return null;}@Overridepublic <T> T get(Object o, Callable<T> callable) {return null;}@Overridepublic void put(Object key, Object value) {if (value == null) {value = this.isAllowNullValues() ? NullValue.INSTANCE : null;}if (value instanceof Serializable) {final String tairKey = String.format("%s:%s", this.name, key);final ResultCode resultCode = this.tairManager.put(this.namespace,tairKey,(Serializable) value,0,this.timeout);if (resultCode != ResultCode.SUCCESS) {TairCache.log.error(String.format("[CachePut]: unable to put %s => %s into tair due to: %s",key,value,resultCode.getMessage()));}} else {throw new RuntimeException(String.format("[CachePut]: value %s is not Serializable",value));}}public ValueWrapper putIfAbsent(Object key, Object value) {final ValueWrapper vw = this.get(key);if (vw.get() == null) {this.put(key, value);}return vw;}@Overridepublic void evict(Object key) {final String tairKey = String.format("%s:%s", this.name, key);final ResultCode resultCode = this.tairManager.delete(this.namespace, tairKey);if ((resultCode == ResultCode.SUCCESS)|| (resultCode == ResultCode.DATANOTEXSITS)|| (resultCode == ResultCode.DATAEXPIRED)) {return;}else {final String errMsg = String.format("[CacheDelete]: unable to evict key %s, resultCode: %s",key,resultCode);TairCache.log.error(errMsg);throw new RuntimeException(errMsg);}}public <T,E> List<T> mget(List<E> keys){List<String> tairKeys = keys.stream().map(k -> String.format("%s-%s", this.name, k)).collect(Collectors.toList());Result<List<DataEntry>> result = tairManager.mget(namespace, tairKeys);if (result.isSuccess() && (result.getRc() == ResultCode.SUCCESS) || result.getRc() == ResultCode.PARTSUCC) {return result.getValue().stream().map(dataEntry -> (T)dataEntry.getValue()).collect(Collectors.toList());}return new ArrayList<>();}@Overridepublic void clear() {//TODO fgz: implement here later}public void setTairManager(TairManager tairManager) {this.tairManager = tairManager;}public void setNamespace(int namespace) {this.namespace = namespace;}public void setTimeout(int timeout) {this.timeout = timeout;}
}

tair的属性配置：

@Configuration
public class TairConfig {@Bean(initMethod = "init", destroyMethod = "close")public TairManager mdbTairManager(@Value("${tair.configserver.master}") String masterConfigServer,@Value("${tair.configserver.slave}") String slaveConfigServer,@Value("${tair.groupName}") String groupName) {final DefaultTairManager tairManager = new DefaultTairManager();tairManager.setGroupName(groupName);tairManager.setConfigServerList(Arrays.asList(masterConfigServer,slaveConfigServer));return tairManager;}@Bean(initMethod = "init", destroyMethod = "close")public TairManager ldbTairManager(@Value("${tair.configserver.master}") String masterConfigServer,@Value("${tair.configserver.slave}") String slaveConfigServer,@Value("${tair.ldbGroupName}") String groupName) {final DefaultTairManager tairManager = new DefaultTairManager();tairManager.setGroupName(groupName);tairManager.setConfigServerList(Arrays.asList(masterConfigServer,slaveConfigServer));return tairManager;}
}

然后引入tair的配置TairCacheConfig,基本上就可以正常使用了。

@EnableCaching
@Configuration
public class TairCacheConfig {@Resourceprivate TairManager tairManager;@Value("${spring.tair.namespace}")private int namespace;@Bean@Qualifier("tairCacheManager")public CacheManager cacheManager() {final SimpleCacheManager simpleCacheManager = new SimpleCacheManager();final Cache cacheShort = new TairCache("tairShortTimeCache", this.tairManager, this.namespace, 60);final Cache cacheMiddle = new TairCache("tairMiddleTimeCache", this.tairManager, this.namespace, 60 * 5);final Cache cacheLong = new TairCache("tairLongTimeCache", this.tairManager, this.namespace, 60 * 60);simpleCacheManager.setCaches(Arrays.asList(cacheLong, cacheMiddle, cacheShort));return simpleCacheManager;}
}

注解正常使用：

@Cacheable(value = "user", key = "#userId")
public User findById(Long userId) {...
}

tair整合Spring Cache相关推荐

springboot整合spring @Cache和Redis
转载自 springboot整合spring @Cache和Redis spring基于注解的缓存对于缓存声明,spring的缓存提供了一组java注解: @Cacheable:触发缓存写入. @ ...
spring boot 整合 spring cache 简单使用
spring boot 整合 spring cache 简单使用 spring cache简介使用spring cache spring cache简介 Spring 3.1起,提供了基于注解的对C ...
springboot整合spring Cache(redis)
前言前面有介绍过spring整合redis和redis的一些注意点,在实际开发中,spring cache方便简化的缓存操作的大部分内容.通过注解的方式实现缓存. 阅读前推荐先阅读:redis缓存介 ...
maven整合@data注解_springboot整合spring Cache(redis)
前言前面有介绍过spring整合redis和redis的一些注意点,在实际开发中,spring cache方便简化的缓存操作的大部分内容.通过注解的方式实现缓存. 缓存抽象的核心是将缓存应用于Jav ...
java 项目做多级缓存_【开源项目系列】如何基于 Spring Cache 实现多级缓存（同时整合本地缓存 Ehcache 和分布式缓存 Redis）...
一.缓存当系统的并发量上来了,如果我们频繁地去访问数据库,那么会使数据库的压力不断增大,在高峰时甚至可以出现数据库崩溃的现象.所以一般我们会使用缓存来解决这个数据库并发访问问题,用户访问进来,会先从 ...
玩转Spring Cache --- 整合进程缓存之王Caffeine Cache和Ehcache3.x【享学Spring】
每篇一句人到中年就是一部西游记:悟空的压力,八戒的身材,沙僧的发型,唐僧的唠叨前言前面文章大篇幅详细讲解了Spring Cache缓存抽象.三大缓存注解的工作原理等等.若是细心的小伙伴会发现:讲 ...
Spring Cache抽象-使用Java类注解的方式整合EhCache
概述工程结构源码概述 Spring Cache抽象-之缓存注解这篇博文中我们介绍了SpringCache抽象注解的使用方式既然这是一个抽象,我们需要一个具体的缓存存储实现.比价流行的有:基于J ...
redis,Spring Cache,Mango,ES
目录 Redis Redis下载与安装 Redis常用命令在Java中操作Redis Jedis Spring Data Redis Spring Cache Spring Cache介绍 Spri ...
Echache整合Spring缓存实例讲解
2019独角兽企业重金招聘Python工程师标准>>> 摘要:本文主要介绍了EhCache,并通过整合Spring给出了一个使用实例. 一.EhCache 介绍 EhCache 是一 ...

tair整合Spring Cache

tair整合Spring Cache相关推荐

最新文章

热门文章