使用SpringAOP+Caffeine实现本地缓存

文章目录

  • 一、背景
  • 二、实现
    • 1、定义注解
    • 2、切面
    • 3、缓存工具类
  • 三、测试

一、背景

公司想对一些不经常变动的数据做一些本地缓存,我们使用AOP+Caffeine来实现

二、实现

1、定义注解

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/*** 本地缓存*/
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface LocalCacheable {// 过期时间 默认10分钟long expired() default 600;// key创建器String keyGenerator() default "org.springframework.cache.interceptor.KeyGenerator";
}

2、切面


import com.google.gson.internal.LinkedTreeMap;
import org.apache.commons.lang3.ArrayUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.aop.framework.AopProxyUtils;
import org.springframework.aop.support.AopUtils;
import org.springframework.cglib.proxy.Enhancer;
import org.springframework.stereotype.Component;import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.HashMap;
import java.util.List;
import java.util.Map;/*** 本地缓存*/
@Aspect
@Component
public class LocalCacheAspect {private static final String separator = ":";@Around("@annotation(com.framework.localcache.LocalCacheable)")public Object around(ProceedingJoinPoint point) throws Throwable {if (AopUtils.isAopProxy(point.getTarget())) {return point.proceed();}Method method = getMethodSignature(point).getMethod();if (method == null) {return point.proceed();}LocalCacheable annotation = method.getAnnotation(LocalCacheable.class);if (annotation == null) {return point.proceed();}// 生成keyString key = generateKey(point);
//         System.out.println("生成的key:" + key);long expired = annotation.expired();Throwable[] throwable = new Throwable[1];Object proceed = LocalCache.cacheData(key, () -> {try {return point.proceed();} catch (Throwable e) {throwable[0] = e;}return null;}, expired);if (throwable[0] != null) {throw throwable[0];}return proceed;}/*** 获取方法*/private MethodSignature getMethodSignature(ProceedingJoinPoint point) {Signature signature = point.getSignature();if (signature instanceof MethodSignature) {return ((MethodSignature) signature);}return null;}/*** 获取key*/private String generateKey(ProceedingJoinPoint point) {// 目标类、方法、参数等Class<?> targetClass = AopProxyUtils.ultimateTargetClass(point.getTarget());Method method = getMethodSignature(point).getMethod();String[] parameterNames = getMethodSignature(point).getParameterNames();Object[] args = point.getArgs();// 解析参数,生成keyLinkedTreeMap<String, Object> paramResolveResult = new LinkedTreeMap<>();if (ArrayUtils.isNotEmpty(args)) {for (int i = 0; i < args.length; i++) {resolveParam(args[i], paramResolveResult, parameterNames[i]);}}StringBuilder key = new StringBuilder(targetClass.getName() + separator + method.getName() + separator);paramResolveResult.forEach((k, v) -> {if (v != null) {key.append(k + "," + v + separator);}});// 根据方法名和参数生成唯一标识return key.toString();}private void resolveParam(Object param, Map<String, Object> paramResolveResult, String prefix) {if (param == null) {return;}Class<?> type = param.getClass();if (type == List.class) {List<Object> param0 = (List) param;for (int i = 0; i < param0.size(); i++) {resolveParam(param0.get(i), paramResolveResult, prefix + "[" + i + "]");}} else if (type == Map.class) {Map<Object, Object> param0 = (Map) param;param0.forEach((k, v) -> {resolveParam(v, paramResolveResult, prefix + "." + k);});} else if (type.isArray()) {Object[] param0 = (Object[]) param;for (int i = 0; i < param0.length; i++) {resolveParam(param0[i], paramResolveResult, prefix + "[" + i + "]");}} else if (type == Byte.class|| type == Short.class|| type == Integer.class|| type == Long.class|| type == Float.class|| type == Double.class|| type == Boolean.class|| type == Character.class|| type == String.class) {paramResolveResult.put(prefix, param);} else if (type.getName().startsWith("java.")) {} else {// 复杂类型Map<String, Object> fieldMap = new HashMap<>();// CGLIB代理if (Enhancer.isEnhanced(type)) {getAllFieldsAndValue(param, type.getSuperclass(), fieldMap);} else {getAllFieldsAndValue(param, type, fieldMap);}fieldMap.forEach((k, v) -> {if (v == null) {return;}resolveParam(v, paramResolveResult, prefix + "." + k);});}}/*** 获取所有字段和值*/private void getAllFieldsAndValue(Object o, Class type, Map<String, Object> fieldMap) {for (Method method : type.getMethods()) {if (method.getName().startsWith("get") && method.getParameterCount() == 0) {try {Object value = method.invoke(o);if (value != null) {fieldMap.put(method.getName().substring(3), value);}} catch (Exception e) {}}}}}

3、缓存工具类

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.CacheLoader;
import com.github.benmanes.caffeine.cache.Caffeine;
import org.springframework.stereotype.Component;
import org.springframework.util.Assert;import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;/*** 本地缓存*/
public class LocalCache {private static final Map<Long, Cache<Object, Object>> cacheMap = new ConcurrentHashMap<>();/*** 创建本地缓存* @param seconds 过期时间:秒*/private static Cache<Object, Object> createCache(long seconds) {return Caffeine.newBuilder().expireAfterWrite(seconds, TimeUnit.SECONDS).build();}/*** 创建本地缓存* @param seconds 过期时间:秒* @param loader 缓存方法*/private Cache<Object, Object> createLoadingCache(long seconds, CacheLoader<Object, Object> loader) {return Caffeine.newBuilder().expireAfterWrite(seconds, TimeUnit.SECONDS).build(loader);}/*** 获取一个缓存组* @param seconds 缓存过期时间*/private static Cache<Object, Object> getAndLoad(long seconds) {if (cacheMap.containsKey(seconds)) {return cacheMap.get(seconds);}Cache<Object, Object> cache = createCache(seconds);cacheMap.put(seconds, cache);return cache;}/*** 缓存数据,过期时间默认10分钟* @param key key* @param supplier 数据来源的方法*/public static Object cacheData(Object key, Supplier<Object> supplier) {return cacheData(key, supplier, 600);}/*** 缓存数据* @param key key* @param supplier 数据来源的方法* @param seconds 过期时间:秒*/public static Object cacheData(Object key, Supplier<Object> supplier, long seconds) {Assert.state(seconds > 0, "过期时间必须大于0秒");Cache<Object, Object> cache = getAndLoad(seconds);return cache.get(key, k -> supplier.get());}
}

三、测试

    @LocalCacheable@GetMapping("test1")public String test1() {System.out.println("执行了");return "success";}@LocalCacheable@GetMapping("test2")public String test2(String a) {System.out.println("执行了" + a);return "success";}@LocalCacheable@GetMapping("test3")public String test3(String a, int b, String c) {System.out.println("执行了" + a + b + c);return "success";}@LocalCacheable@GetMapping("test4")public String test4(UserInfo user) {System.out.println("执行了" + user);return "success";}@LocalCacheable@GetMapping("test5")public String test5(UserInfo[] users) {System.out.println("执行了" + users);return "success";}@LocalCacheable@GetMapping("test6")public String test6(List<UserInfo> users) {System.out.println("执行了" + users);return "success";}@LocalCacheable@GetMapping("test7")public String test7(UserInfo user) {System.out.println("执行了" + user.getMap());return "success";}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/771314.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【LAMMPS学习】五、LAMMPS命令(3) 输入脚本结构

5. 命令 本部分描述了 LAMMPS 输入脚本的格式以及其中的命令如何用于定义 LAMMPS 模拟。主要包括以下内容。 5.1. LAMMPS 输入脚本 5.2.输入脚本的解析规则 5.3.输入脚本结构 本部分描述了典型的 LAMMPS 输入脚本的结构。 LAMMPS 发行版中的示例目录包含许多示例输入脚本…

2024年大模型面试准备(三):聊一聊大模型的幻觉问题

节前&#xff0c;我们组织了一场算法岗技术&面试讨论会&#xff0c;邀请了一些互联网大厂朋友、参加社招和校招面试的同学&#xff0c;针对大模型技术趋势、大模型落地项目经验分享、新手如何入门算法岗、该如何备战、面试常考点分享等热门话题进行了深入的讨论。 合集在这…

羊大师羊奶靠谱么?信誉与持续见证,共筑信赖之选

羊大师羊奶靠谱么&#xff1f;信誉与持续见证&#xff0c;共筑信赖之选 在如今注重健康饮食的时代&#xff0c;羊奶以其丰富的营养价值和独特的风味&#xff0c;逐渐受到了消费者的青睐。在众多羊奶品牌中&#xff0c;羊大师羊奶以其出色的品质、良好的信誉和持续的创新精神&a…

关于「技术开发技能」课程

本课程分为三个部分&#xff0c;带您了解如何使用大模型平台、如何训练与部署大模型及生成式AI产品应用与开发&#xff0c;您将能了解各类服务的优势、功能、典型使用案例、技术概念和成本。 学习任选的两个课程模块&#xff0c;并通过测验者&#xff0c;将授予「技术开发技能…

隆道分享AI技术应用实践 以AI赋能采购业务管理

2024年3月21日-22日&#xff0c;以“面向务实的数字化”为主题的“第12届医药健康行业数字化高峰论坛”在上海举办。本届大会聚焦项目建设、技术创新与应用、新业务模式及收效等话题&#xff0c;探讨AI制药与大模型应用&#xff0c;分享智能化技术在多领域的落地案例。隆道公司…

情感视频素材从哪里找?推荐情感视频素材分享

随着时代变化短视频的兴起&#xff0c;人们越来越喜欢用视频来表达自己的情感和经历。为了满足创作者对于情感视频素材的需求&#xff0c;以下列出了几个素材分享网站&#xff0c;帮助你更好地创作和传达情感&#xff0c;引起大家的共鸣。 蛙学网 作为一家国内知名的素材分享…

python能做什么

python能做什么 Web开发&#xff1a;Python具有许多流行的Web框架&#xff0c;如Django和Flask&#xff0c;使得它成为Web开发的首选语言。它简洁、易于学习、且拥有丰富的生态系统&#xff0c;能够快速构建高性能的Web应用。 数据科学和机器学习&#xff1a;Python在数据科学…

Webpack部署本地服务器

Webpack部署本地服务器 目录 Webpack部署本地服务器目的认识模块热替换&#xff08;HMR&#xff09;什么是 HMRHMR 通过如下几种方式, 来提高开发的速度如何使用 HMRhost 配置 目的 完成自动编译 常用方式: webpack-dev-server webpack-dev-server 是一个用于开发环境的 Web 服…

动态规划,二维DP

文章目录 1、摆花2、异或选数3、数字三角形 1、摆花 分析&#xff1a; 输入2 4 3 2 的情况下&#xff0c;只有 (2,2) , (3,1) 这两种方案。 所以&#xff0c;设置状态 dp[i][j] 表示到第 i 种花&#xff08;共 n 种花&#xff09;、第 j 个位置&#xff08;共 m 个位置&#xf…

python开发——Python函数中的函数传参

前言 在编写函数时&#xff0c;经常希望函数接口更加灵活&#xff0c;可以支持默认参数、可变参数、关键字参数等特性。下面将详细介绍这些函数传参的使用方法。 1. 常规参数 在 Python 中&#xff0c;函数的传参是一种简单直接的过程&#xff0c;例如&#xff1a; def tes…

Leetcode算法题笔记(2)

目录 图论51. 岛屿数量解法一 52. 腐烂的橘子解法一 53. 课程表解法一 54. 实现 Trie (前缀树)解法一 回溯55. 全排列解法一 56. 子集解法一解法二 57. 电话号码的字母组合解法一 58. 组合总和解法一解法二 59. 括号生成解法一解法二 60. 单词搜索解法一 61. 分割回文串解法一 …

能否把 Redis 当做消息队列来用呢?

这个问题并不是面试中经常会问到的问题&#xff0c;而是我在平时看一些大牛写的技术文章的时候看到的一个问题&#xff0c;这个问题引发了我强烈的思考&#xff0c;我感觉我想通了这个问题之后&#xff0c;对redis和kafka都有了一个全新的认识&#xff0c;感觉像发现了新大陆这…

简明 Python 教程(第6章 模块)

模块是Python中组织代码的一种方式&#xff0c;它允许开发者将代码分解为可重用的单元&#xff0c;便于管理和维护。开发者可以有效地利用Python的模块系统来构建复杂的应用程序。模块是一个包含Python定义和声明的文件&#xff0c;文件名就是模块名加上.py扩展名。模块可以包含…

python的数据容器通用操作

常用方法 len统计个数 max最大元素 min最小元素 my_list[1,2,3,4,5] my_tuple(1,2,3,4,5) my_str"abcdefg" my_set{1,2,3,4,5} my_dict{"key1":1,"kye2":2,"key3":3,"key4":4,"key5":5}print(f"列表 元素个…

[Netty实践] 请求响应同步实现

目录 一、介绍 二、依赖引入 三、公共部分实现 四、server端实现 五、client端实现 六、测试 一、介绍 本片文章将实现请求响应同步&#xff0c;什么是请求响应同步呢&#xff1f;就是当我们发起一个请求时&#xff0c;希望能够在一定时间内同步&#xff08;线程阻塞&am…

FPGA高端项目:解码索尼IMX327 MIPI相机转HDMI输出,提供FPGA开发板+2套工程源码+技术支持

目录 1、前言2、相关方案推荐本博主所有FPGA工程项目-->汇总目录我这里已有的 MIPI 编解码方案 3、本 MIPI CSI-RX IP 介绍4、个人 FPGA高端图像处理开发板简介5、详细设计方案设计原理框图IMX327 及其配置MIPI CSI RX图像 ISP 处理图像缓存HDMI输出工程源码架构 6、工程源码…

Java中SPI机制简单演示

Java中SPI机制简单演示 写一个SpiService接口 public interface SpiService {void run();}写两个实现类&#xff0c;注意&#xff1a;实现类可以跨包 Slf4j public class SpiServiceImpl1 implements SpiService {Overridepublic void run() {log.warn("SpiServiceImpl…

简单破除github的2FA验证

简单破除github的2FA验证 文章目录 简单破除github的2FA验证&#x1f468;‍&#x1f3eb;Authenticator工具 &#x1f468;‍&#x1f3eb;Authenticator工具 最近使用github的时候发现要搞一个2FA的验证才可以 验证的途径有两种&#xff1a;一种是用手机电话验证&#xff0c;…

使用easyYapi生成文档

easyYapi生成文档 背景1.安装配置1.1 介绍1.2 安装1.3 配置1.3.1 Export Postman1.3.2 Export Yapi1.3.3 Export Markdown1.3.4 Export Api1.3.6 常见问题补充 2. java注释规范2.1 接口注释规范2.2 出入参注释规范 3. 特定化支持3.1 必填校验3.2 忽略导出3.3 返回不一致3.4 设置…

关于JavaScript常用命令

JS&#xff08;JavaScript&#xff09;是一种用于构建交互式网页的脚本语言&#xff0c;常用于前端开发。以下是一些常用的JS命令及其简要说明&#xff0c;希望能够帮助您更好地了解JS的基础知识。 1. **变量声明与赋值** - var, let, const: 用于声明变量&#xff0c;var在…