范文健康探索娱乐情感热点
热点动态
科技财经
情感日志
励志美文
娱乐时尚
游戏搞笑
探索旅游
历史星座
健康养生
美丽育儿
范文作文
教案论文

简直骚操作,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 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 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 {     @Override     public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {         filterChain.doFilter(servletRequest, servletResponse);         // 执行完后清除缓存         ThreadLocalCacheManager.removeCache();     } }自动配置类@Configuration public class ThreadLocalCacheAutoConfiguration {     @Bean     public 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;     }     @Bean     public ThreadLocalCacheAspect threadLocalCacheAspect() {         return new ThreadLocalCacheAspect();     } }使用案例@Service public class TestService {     /**      * ThreadLocalCache 会缓存,只对当前线程有效      * @return      */     @ThreadLocalCache     public 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://juejin.im/post/6859213042438275085

模块化安卓游戏掌机GPDXP,全球首发这是什么?这是全球首款模块化安卓游戏掌机品牌GPD产品名XP它能做什么?它是手柄可自由组合的安卓掌机,轻松玩转安卓FPSMOBA手游,比如和平精英王者荣耀等,以及模拟器游戏云游戏以XP明日10点预售,Linus评测WINMax2021(1195G7)反杀SteamDeck预售价格1599元(零售价1899元)预售时间2021年9月10日,上午10点整京东预售链接httpsitem。jd。com10036383257988。html天猫预售链接httG胖破防,被1195G7反超,GPDXP发布,4800U版WINMax2021加福利为了给GPD老用户谋求更大的福利!凡是后面参与预售4800U版WINMax2021的用户汪总将个人出资,赠送300元优惠券,数量不多,送完即止实际到手价5599元,也就是在预售价格GPDPocket3,可更换接口的8寸电脑,支持KVM和HDMIIN这样的电脑配置i71195G7强大的处理器,还能支持模块化替换接口,你们觉得如何?GPDPocket3是一款集大成之作,是综合了GPDMicroPC和GPDPocket系列的特点而Pocket3模块化的口袋电脑,即将发布!WIN3已更新至1195G7GPDPocket系列自Pocket2起就没有更新,这段时间很多小伙伴询问是否有更新,当然会有!而且这次更是惊艳之作。今天先放一张框线图,请关注后续公告!大家期盼的WIN3终于更新Pocket3模块化的口袋电脑,你喜欢吗?很早以前,我们就发现Pocket2MicroPC甚至是P2Max的用户存在相互叠加,于是我们萌生了将三款产品的突出优势整合为一款产品的想法。而在Intel11代处理器成功应用于WIGPDXP吃鸡手游安卓掌机,支持王者荣耀一键换装大家玩FPS类手游时,比如和平精英或者使命召唤手游,不知道有没有遇到这样一种怪现像,与敌人面对面遭遇时,对面居然傻傻的站着一动不动开枪,就像个活靶子,动作看起来无比的笨拙?其实你们Pocket3预售时间和价格公布!官网专题页上线!XP评测全额返现近期,Pocket3的内测用户发了很多图片和视频,我在这里引用一些哈!更多的评测,可以查看本条发布的其它视频消息,包括手写输入KVM演示安卓模拟器下,手游键鼠和触屏模式操作Wind模块化掌上电脑Pocket3更多细节曝光,满满的干货!下周内测Pocket3内置10000mAh(7。7V5000mAh2,串联)大容量电池,实测可播放本地视频8。5小时,更强劲的电池续航。搭配45WPD快充,直接向主板供电,电池更加节省,让3000元内最值得入手的手机?realme真我GT大师探索版申请出战就在今天,让大家心心念念的realme真我GT大师版系列新机终于发布了,该系列包含了realme真我GT大师版以及realme真我GT大师探索版这两款手机,而realme这个品牌一智能家居行业奥斯卡揭晓!TCL斩获葵花奖十四项大奖随着5GAIIoT飞速发展以及后疫情时代推动下的宅经济带来广收益效应,智能家居被认定为未来510年最大风口之一。作为智能科技巨头企业,TCL始终是布局智能家居的领头羊和先行者。面对
大厂都在构建元宇宙App元宇宙整合了视频游戏,社交网络,娱乐等,其中用户共创内容增强了互动性。从某种程度上来说,当下各个互联网的app都在往这个方向发展,游戏泛娱乐用户创造内容。当前阶段的用户逐步提高了对如何建立一个面向中东的跨境电商独立站,可以使用哪些工具?很多跨境电商卖家都会做独立站,有多个好处首先,可以绕开平台的高额佣金(以Souq为例,每卖一件商品都会收10左右的佣金)第二,不受海外仓的限制,可以直接从国内发货第三,不需要注册本安卓旗舰用上18GB内存,iPhoneSE3却只有3GB,苹果哪来的底气?你用旗舰机去对比iPhonese,你哪来的底气?第一个方面是系统和硬件的匹配,人苹果系统和芯片都自己研发的,严丝合缝。安卓手机系统不是自己的,芯片不是自己的,再不堆料怎么玩?靠深度联想合作伙伴突然被查,柳传志们的后路被堵死了最近一个多月,联想事件频频登上热搜,而且据目前来看的话,联想这件事很有可能会像泡沫一样越滚越大,越滚越多。这不,最近联想又一合作伙伴突然被查,它就是著名的泛海控股。对于泛海控股这次iQOOU5正式发售5000毫安大电池120Hz电竞屏,1299元起售熟悉iQOO的小伙伴都知道,iQOO其实是有着三条生产线的,分别是数字系列NEO系列以及U系列。前几天iQOOneo5S和iQOOneo5SE两款机型已经发布了,不过比较让小芳感觉松下lx100m2和黑卡6哪个画质好?我觉得是松下比较好,下面看介绍。松下LX100M2采用全新的43英寸高灵敏度MOS传感器,总计2177万像素,有效像素1700万,比上代1280万像素的LX100分辨率更高。这款全浴霸是灯暖省电,还是风暖省电?为什么?朋友们好,我是电子及工控技术,我来回答这个问题。浴霸是卫生间里十分重要的一种取暖照明和通风设备,浴霸特别是在冬天秋天和春天这三个季经常使用,在夏季一般只使用浴霸的通风功能。对于浴霸空气能热水器不加热是怎么回事?基本上泄露是主要原因,其它的原因很少。我们的空气能热水器出现过这情况。售后检查后是因为空气压缩机坏掉了。所以最靠谱的还是直接售后服务!一水垢太多热水器的水箱是非常容易结水垢的,而水电脑上下载软件都是安装包,带好多广告,有什么好的下载途径吗?最简单的是用电脑管理软件下载,比如360,腾讯电脑管家,都有专门安装卸载软件的功能,不会携带垃圾软件。网页搜索的软件多数是软件收集网站,下载的是软件下载器,其实在最下方是有真实的下移动10086跟用户联系,说装宽带是免费的,你们怎么看?移动10086通过电话的方式通知用户,可以免费体验安装宽带,怎么看?以下是个人的观点假设10086通过电话的方式通知我,说您是什么?什么用户?目前可以免费体验安装移动100M或者5请简述一下RS485通讯连接方式及其应用?请简述一下RS485通讯连接方式及其应用?RS485通讯采用差分信号负逻辑控制模式,其接线方式主要有两线制和四线制两种。虽然有两种接线方式,但现在用的较多的还是两线制接线方式,为总