简直骚操作,ThreadLocal还能当缓存用
背景说明
有朋友问我一个关于接口优化的问题,他的优化点很清晰,由于接口中调用了内部很多的 service 去组成了一个完成的业务功能。每个 service 中的逻辑都是独立的,这样就导致了很多查询是重复的,看下图你就明白了。
上层查询传递下去
对于这种场景最好的就是在上层将需要的数据查询出来,然后传递到下层去消费。这样就不用重复查询了。
如果开始写代码的时候是这样做的没问题,但很多时候,之前写的时候都是独立的,或者复用的老逻辑,里面就是有独立的查询。
如果要做优化就只能将老的方法重载一个,将需要的信息直接传递过去。
public void xxx(int goodsId) {Goods goods = goodsService.get(goodsId);.....
}
public void xxx(Goods goods) {.....
}
加缓存
如果你的业务场景允许数据有一定延迟,那么重复调用你可以直接通过加缓存来解决。这样的好处在于不会重复查询数据库,而是直接从缓存中取数据。
更大的好处在于对于优化类的影响最小,原有的代码逻辑都不用改变,只需要在查询的方法上加注解进行缓存即可。
public void xxx(int goodsId) {Goods goods = goodsService.get(goodsId);.....
}
public void xxx(Goods goods) {Goods goods = goodsService.get(goodsId);.....
}
class GoodsService {@Cached(expire = 10, timeUnit = TimeUnit.SECONDS)public Goods get(int goodsId) {return dao.findById(goodsId);}
}
如果你的业务场景不允许有缓存的话,上面这个方法就不能用了。那么是不是还得改代码,将需要的信息一层层往下传递呢?
自定义线程内的缓存
我们总结下目前的问题:
同一次请求内,多次相同的查询获取 RPC 等的调用。
数据实时性要求高,不适合加缓存,主要是加缓存也不好设置过期时间,除非采用数据变更主动更新缓存的方式。
只需要在这一次请求里缓存即可,不影响其他地方。
不想改动已有代码。
总结后发现这个场景适合用 ThreadLocal 来传递数据,对已有代码改动量最小,而且也只对当前线程生效,不会影响其他线程。
public void xxx(int goodsId) {Goods goods = ThreadLocal.get();if (goods == null) {goods = goodsService.get(goodsId);}.....
}
上面代码就是使用了 ThreadLocal 来获取数据,如果有的话就直接使用,不用去重新查询,没有的话就去查询,不影响老逻辑。
虽然能实现效果,但是不太好,不够优雅。也不够通用,如果一次请求内要缓存多种类型的数据怎么处理? ThreadLocal 就不能存储固定的类型。还有就是老的逻辑还是得改,加了个判断。
下面介绍一种比较优雅的方式:
自定义缓存注解,加在查询的方法上。
定义切面切到加了缓存注解的方法上,第一次获取返回值存入 ThreadLocal。第二次直接从 ThreadLocal 中取值返回。
ThreadLocal 中存储 Map,Key 为某方法的某一标识,这样可以缓存多种类型的结果。
在 Filter 中将 ThreadLocal 进行 remove 操作,因为线程是复用的,使用完需要清空。
注意:ThreadLocal 不能跨线程,如果有跨线程需求,请使用阿里的 ttl 来装饰。
注解定义
@Target({ ElementType.METHOD })
@Retention(RetentionPolicy.RUNTIME)
public @interface ThreadLocalCache {/*** 缓存key,支持SPEL表达式* @return*/String key() default "";
}
存储定义
/*** 线程内缓存管理** @作者 尹吉欢* @时间 2020-07-12 10:47*/
public class ThreadLocalCacheManager {private static ThreadLocal<Map> threadLocalCache = new ThreadLocal<>();public static void setCache(Map value) {threadLocalCache.set(value);}public static Map getCache() {return threadLocalCache.get();}public static void removeCache() {threadLocalCache.remove();}public static void removeCache(String key) {Map cache = threadLocalCache.get();if (cache != null) {cache.remove(key);}}
}
切面定义
/*** 线程内缓存** @作者 尹吉欢* @时间 2020-07-12 10:48*/
@Aspect
public class ThreadLocalCacheAspect {@Around(value = "@annotation(localCache)")public Object aroundAdvice(ProceedingJoinPoint joinpoint, ThreadLocalCache localCache) throws Throwable {Object[] args = joinpoint.getArgs();Method method = ((MethodSignature) joinpoint.getSignature()).getMethod();String className = joinpoint.getTarget().getClass().getName();String methodName = method.getName();String key = parseKey(localCache.key(), method, args, getDefaultKey(className, methodName, args));Map cache = ThreadLocalCacheManager.getCache();if (cache == null) {cache = new HashMap();}Map finalCache = cache;Map<String, Object> data = new HashMap<>();data.put("methodName", className + "." + methodName);Object cacheResult = CatTransactionManager.newTransaction(() -> {if (finalCache.containsKey(key)) {return finalCache.get(key);}return null;}, "ThreadLocalCache", "CacheGet", data);if (cacheResult != null) {return cacheResult;}return CatTransactionManager.newTransaction(() -> {Object result = null;try {result = joinpoint.proceed();} catch (Throwable throwable) {throw new RuntimeException(throwable);}finalCache.put(key, result);ThreadLocalCacheManager.setCache(finalCache);return result;}, "ThreadLocalCache", "CachePut", data);}private String getDefaultKey(String className, String methodName, Object[] args) {String defaultKey = className + "." + methodName;if (args != null) {defaultKey = defaultKey + "." + JsonUtils.toJson(args);}return defaultKey;}private String parseKey(String key, Method method, Object[] args, String defaultKey){if (!StringUtils.hasText(key)) {return defaultKey;}LocalVariableTableParameterNameDiscoverer nameDiscoverer = new LocalVariableTableParameterNameDiscoverer();String[] paraNameArr = nameDiscoverer.getParameterNames(method);ExpressionParser parser = new SpelExpressionParser();StandardEvaluationContext context = new StandardEvaluationContext();for(int i = 0;i < paraNameArr.length; i++){context.setVariable(paraNameArr[i], args[i]);}try {return parser.parseExpression(key).getValue(context, String.class);} catch (SpelEvaluationException e) {// 解析不出SPEL默认为类名+方法名+参数return defaultKey;}}
}
过滤器定义
/*** 线程缓存过滤器** @作者 尹吉欢* @个人微信 jihuan900* @微信公众号 猿天地* @GitHub https://github.com/yinjihuan* @作者介绍 http://cxytiandi.com/about* @时间 2020-07-12 19:46*/
@Slf4j
public class ThreadLocalCacheFilter implements Filter {@Overridepublic void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {filterChain.doFilter(servletRequest, servletResponse);// 执行完后清除缓存ThreadLocalCacheManager.removeCache();}
}
自动配置类
@Configuration
public class ThreadLocalCacheAutoConfiguration {@Beanpublic FilterRegistrationBean idempotentParamtFilter() {FilterRegistrationBean registration = new FilterRegistrationBean();ThreadLocalCacheFilter filter = new ThreadLocalCacheFilter();registration.setFilter(filter);registration.addUrlPatterns("/*");registration.setName("thread-local-cache-filter");registration.setOrder(1);return registration;}@Beanpublic ThreadLocalCacheAspect threadLocalCacheAspect() {return new ThreadLocalCacheAspect();}
}
使用案例
@Service
public class TestService {/*** ThreadLocalCache 会缓存,只对当前线程有效* @return*/@ThreadLocalCachepublic String getName() {System.out.println("开始查询了");return "yinjihaun";}/*** 支持SPEL表达式* @param id* @return*/@ThreadLocalCache(key = "#id")public String getName(String id) {System.out.println("开始查询了");return "yinjihaun" + id;}
}
功能代码:https://github.com/yinjihuan/kitty[1]
案例代码:https://github.com/yinjihuan/kitty-samples[2]
关于作者 :尹吉欢,简单的技术爱好者,《Spring Cloud 微服务-全栈技术与案例解析》, 《Spring Cloud 微服务 入门 实战与进阶》作者。
特别推荐一个分享架构+算法的优质内容,还没关注的小伙伴,可以长按关注一下:
长按订阅更多精彩▼如有收获,点个在看,诚挚感谢
简直骚操作,ThreadLocal还能当缓存用相关推荐
- 直接保存 DataFrame 表格到本地,这个“骚操作”你还不知道?
作者 | 黄伟呢 来源 | 数据分析与科学之美 头图 | 东方ic 知识是需要积累的,有些冷知识.骚操作,你可能现在不需要,但是只有当你玩儿过,以后再碰到这个需求,你才会有印象,方便查询. 引入问题 ...
- 骚操作!图片缩小后 内容竟变得完全不同?
点击上方"AI算法与图像处理",选择加"星标"或"置顶" 重磅干货,第一时间送达 编辑:AI算法与图像处理 仅作为学习交流分享,如有侵权请联 ...
- 80%开发者都不知道的以太坊骚操作:「事件」和「日志」还可以这么玩!
80%开发者都不知道的以太坊骚操作:「事件」和「日志」还可以这么玩! 2018年05月02日 00:00:00 阅读数:366 作者 | 蔡一 志顶科技技术总监 4月6日,Daniel Larime ...
- Word原来还能制作请柬,这些Word的骚操作你都知道多少呢?
不管是学习还是工作,我们经常会使用到Word文档,不过,在大家的常规印象中,Word是一个文字编辑工具,但其实,它还有很多其他的特殊功能哦!今天我们就一起来揭开Word的另类面纱. 一.修改图片背景 ...
- GitHub 骚操作,个人页还能这么玩?
点击上方蓝色"方志朋",选择"设为星标" 回复"666"获取独家整理的学习资料! 之前写过一篇 GitHub 骚操作的文章 GitHub 竟 ...
- 工程师不仅能调试自动化立体库,还能用PLC“不务正业”做这些“骚”操作
写在面前 大家好,我是智能仓储物流技术研习社的社长,老K.PLC和触摸屏是我们自动化仓储物流系统中常用控制器和人机界面,电气控制工程师们天天花费很多的精力在上边.今天老K给大家分享几个控制工程师们的现 ...
- 骚操作!有了这款神器,轻轻松松用Python写APP!(文末彩蛋)
本文转自机器之心 作者:Adrien Treuille 机器之心编译 参与:魔王.一鸣 机器学习开发者想要打造一款 App 有多难?事实上,你只需要会 Python 代码就可以了,剩下的工作都可以交 ...
- C++和Rust_Kotlin、Rust两个充满了骚操作的编程语言,值得一玩
Kotlin和Rust都是两个年轻的编程语言,而且相比现在流行的Python.JavaScript/Typescript语言来说,Kotlin和Rust更接近底层,对于学习理解计算机原理,学习Kotl ...
- 这帮吃货程序猿,给阿里食堂来了一波骚操作
我叫宋爽,在别人眼里,我是一个程序猿. 别的程序猿,喜欢摁键盘,我嘛,就喜欢吃. 有一次,去医院体检,拿到CT片的我,看着自己的脊椎骨,脑子中一直在想:啊!什么时候去吃顿羊蝎子! 身为吃货的我,最近和 ...
最新文章
- Android 实时文件夹
- exchange邮件中继服务器搭建,使用 Exchange 2010 传输中继应用程序服务器 SMTP 通信...
- 6.windows线程切换_主动切换
- MYSQL不同字段之间四则运算
- ubuntu无法激活输入法,Zendstudio无法激活中文输入法问题
- python配色方案_python 生成18年写过的博客词云
- 善用VS中的Code Snippet来提高开发效率
- 微软:从“开源是毒瘤”到“我爱 Linux”的 20 年
- Scanf函数,取地址符和字符数组的联系
- 计算机没有休眠,没有休眠选项,电脑没有休眠选项
- python京东注册机_京东自动注册
- 面对对象之差异化的网络数据交互方式--单机游戏开发之无缝切换到C/S模式
- 回顾《网易数据基础平台建设》
- 使用React Hooks 时要避免的5个错误!
- vue-tree-chart 组织架构-树形图-流程图(含鼠标右击事件)
- 2019年苹果iOS App上架详细图文教程
- 运动耳机选择哪种好、什么款式的耳机戴着舒服
- 一招解决电脑卡吧咔吧
- 阅读笔记《CKF滤波算法及其在航天器自主导航中的应用》
- 贝叶斯神经网络----从贝叶斯准则到变分推断
热门文章
- 51单片机可以做什么实用的产品?
- gis中的擦除_GIS案例分析 | 公园建设选址
- HDU2682(最小生成树)
- matlab显示YCrCb的图像,【Matlab系列】读取并显示YUV视频文件
- 2016 ACM / ICPC Asia dalian Regional Contest 题解(11 / 11)【每日亿题2021 / 2 / 17】
- 解题报告:POJ 3281 Dining(最大流 / “三分图”建图)
- dcut matlab,cut 命令详解
- java开源springboot项目_springBoot 搭建web项目(前后端分离,附项目源代码地址)...
- 微服务之API网关接口设计
- 开源 java CMS - FreeCMS2.8 模板管理