SpringBoot如何使用AOP实现统计全局接口访问次数
AOP是什么AOP（AspectOrientedProgramming），也就是面向切面编程，是通过预编译方式和运行期间动态代理实现程序功能的传统已维护的一种技术。AOP的作用和优势作用：在程序运行期间，在不修改源代码的情况下对某些方法进行功能增强优势：减少重复代码，提高开发效率，并且便于维护常见的动态代理技术jdk代理：基于接口的动态代理技术cglib代理：基于父类的动态代理技术AOP相关概念Listitem-Target（目标对象）：代理的目标对象Proxy（代理）：一个类被AOP织入增强后，就产生一
AOP是什么
AOP（Aspect Oriented Programming），也就是面向切面编程，是通过预编译方式和运行期间动态代理实现程序功能的传统已维护的一种技术。
AOP的作用和优势
作用：在程序运行期间，在不修改源代码的情况下对某些方法进行功能增强
优势：减少重复代码，提高开发效率，并且便于维护
常见的动态代理技术
jdk代理：基于接口的动态代理技术
cglib代理：基于父类的动态代理技术
AOP相关概念
List item- Target（目标对象）：代理的目标对象
Proxy（代理）：一个类被AOP织入增强后，就产生一个结果代理类
Joinpoint（连接点）：连接点是指那些被拦截到的点。在Spring中，这些点指的是方法，因为Spring只支持方法类型的连接点（可以被增强的方法叫连接点）
PointCut（切入点）：切入点是指我们要对哪些Joinpoint进行拦截的定义
Advice（通知/增强）：通知是指拦截到Joinpoint之后所要做的事情就是通知
Aspect（切面）：是切入点和通知的结合
Weaving（织入）：把增强应用到目标对象来创建新的代理对象的过程。Spring采用动态代理织入，而AspectJ采用编译器织入和类装载器织入
实现
我在这里采用基于注解形式的的AOP开发。
开发步骤
加入依赖
org.springframework.boot spring-boot-starter-aop org.aspectj aspectjrt 1.9.4 org.aspectj aspectjweaver 1.9.4 cglib cglib 3.2.12
创建目标接口和目标类（内部有切点）
创建切面类（内部有增强方法）
将目标类和切面类的对象创建权交给Spirng
在切面类中使用注解配置织入关系
在配置文件中开启组件扫描和AOP自动代理
因为我的项目是SpringBoot Web项目，在这里开启注解就好了。
下面的代码为使用到的原子计数类。
import java.util.concurrent.atomic.AtomicInteger;
public class AtomicCounter {
private static final AtomicCounter atomicCounter = new AtomicCounter();
/**
* 单例，不允许外界主动实例化
*/
private AtomicCounter() {
}
public static AtomicCounter getInstance() {
return atomicCounter;
}
private static AtomicInteger counter = new AtomicInteger();
public int getValue() {
return counter.get();
}
public int increase() {
return counter.incrementAndGet();
}
public int decrease() {
return counter.decrementAndGet();
}
// 清零
public void toZero(){
counter.set(0);
}
}下面的代码为实现的全局接口监控。
我在项目中简单使用了Redis作缓存，所有你可以看到有Redis相关的操作。
使用 @Before 用于配置前置通知。指定增强的方法在切入点方法之前执行。
使用@ @AfterReturning 用于配置后置通知。指定增强的方法在切入点方法之后执行。
使用@ @AfterThrowing 用于配置异常抛出通知。指定增强的方法在出现异常时执行。
@Component
@Aspect
public class GlobalActuator {
private static final Logger log = LoggerFactory.getLogger(GlobalActuator.class);
@Resource
private StringRedisTemplate stringRedisTemplate;
ThreadLocal startTime = new ThreadLocal<>();
ConcurrentHashMap countMap = new ConcurrentHashMap();
/**
* 匹配控制层层通知 这里监控controller下的所有接口
*/
@Pointcut("execution(* com.sf.controller.*Controller.*(..))")
private void controllerPt() {
}
/**
* 在接口原有的方法执行前，将会首先执行此处的代码
*/
@Before("com.sf.actuator.GlobalActuator.controllerPt()")
public void doBefore(JoinPoint joinPoint) throws Throwable {
startTime.set(System.currentTimeMillis());
//获取传入目标方法的参数
Object[] args = joinPoint.getArgs();
}
/**
* 只有正常返回才会执行此方法
* 如果程序执行失败，则不执行此方法
*/
@AfterReturning(returning = "returnVal", pointcut = "com.sf.actuator.GlobalActuator.controllerPt()")
public void doAfterReturning(JoinPoint joinPoint, Object returnVal) throws Throwable {
Signature signature = joinPoint.getSignature();
String declaringName = signature.getDeclaringTypeName();
String methodName = signature.getName();
String mapKey = declaringName + methodName;
// 执行成功则计数加一
int increase = AtomicCounter.getInstance().increase();
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
synchronized (this) {
//在项目启动时，需要在Redis中读取原有的接口请求次数
if (countMap.size() == 0) {
JSONObject jsonObject = RedisUtils.objFromRedis(StringConst.INTERFACE_ACTUATOR);
if (jsonObject != null) {
Set strings = jsonObject.keySet();
for (String string : strings) {
Object o = jsonObject.get(string);
countMap.putIfAbsent(string, o);
}
}
}
}
// 如果此次访问的接口不在countMap，放入countMap
countMap.putIfAbsent(mapKey, 0);
countMap.compute(mapKey, (key, value) -> (Integer) value + 1);
synchronized (this) {
// 内存计数达到30 更新redis
if (increase == 30) {
RedisUtils.objToRedis(StringConst.INTERFACE_ACTUATOR, countMap, Constants.AVA_REDIS_TIMEOUT);
//删除过期时间
stringRedisTemplate.persist(StringConst.INTERFACE_ACTUATOR);
//计数器置为0
AtomicCounter.getInstance().toZero();
}
}
//log.info("方法执行次数:" + mapKey + "------>" + countMap.get(mapKey));
//log.info("URI:[{}], 耗费时间:[{}] ms", request.getRequestURI(), System.currentTimeMillis() - startTime.get());
}
/**
* 当接口报错时执行此方法
*/
@AfterThrowing(pointcut = "com.sf.actuator.GlobalActuator.controllerPt()")
public void doAfterThrowing(JoinPoint joinPoint) {
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
log.info("接口访问失败，URI:[{}], 耗费时间:[{}] ms", request.getRequestURI(), System.currentTimeMillis() - startTime.get());
}
} 这里再给出Controller层代码。
@GetMapping("/interface/{intCount}")
@ApiOperation(value = "查找接口成功访问次数（默认倒序）")
public Result> findInterfaceCount(
@ApiParam(name = "intCount", value = "需要的接口数") @PathVariable Integer intCount
) {
HashMap hashMap = new HashMap<>();
JSONObject jsonObject = RedisUtils.objFromRedis(StringConst.INTERFACE_ACTUATOR);
if (jsonObject != null) {
Set strings = jsonObject.keySet();
for (String string : strings) {
Integer o = (Integer) jsonObject.get(string);
hashMap.putIfAbsent(string, o);
}
}
//根据value倒序
Map sortedMap = hashMap.entrySet().stream().sorted(Collections.reverseOrder(Map.Entry.comparingByValue()))
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue, (e1, e2) -> e1, LinkedHashMap::new));
//返回列表
List resultList = new ArrayList<>();
//排序后中的map中所有的key
Object[] objects = sortedMap.keySet().toArray();
for (int i = 0; i < intCount; i++) {
InterfaceDto interfaceDto = new InterfaceDto();
interfaceDto.setName((String) objects[i]);
interfaceDto.setCount(sortedMap.get((String) objects[i]));
resultList.add(interfaceDto);
}
return Result.success(resultList);
} 项目运行一段时间后，在Redis中可以看到接口的请求次数。
Web最终效果图如下：
正软商城本月促销专区，汇集办公、设计、安全、影音、系统工具及AI软件等正版软件优惠活动，提供限时折扣、特价授权和优惠购买信息，活动库存及价格以页面实时展示为准。
正软商城装机必备专区，精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件，帮助用户快速完成新电脑软件配置。
正软商城Windows软件专区，汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件，提供软件介绍、系统要求、正版授权及购买下载服务。
正软商城macOS软件专区，精选适用于Mac电脑的办公、设计、影音、效率、开发和系统工具，提供软件功能介绍、macOS兼容版本、正版授权及购买下载服务。
正软商城iOS软件专区，精选适用于iPhone和iPad的办公、学习、影音、设计、效率及AI应用，提供功能介绍、适用设备、系统要求和正版获取方式等信息。
正软商城AI软件专区，汇集AI写作、AI绘画、AI视频、AI办公、AI编程、AI翻译、智能客服和数据分析等人工智能工具，提供功能介绍、适用平台、收费方式及正版购买信息。
正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法，同时介绍常用PDF软件和工具的使用技巧。
赤友清理大师是一款为 Mac 设计的智能清理优化工具，可精准扫描垃圾、大文件、重复文件等，释放磁盘空间。做扫描整理、文字提取和表格转换时，它能把识别后的处理步骤接得更顺，资料录入这类场景会省下不少时间。
极度公式是一款跨平台专业LaTeX公式识别编辑软件，支持OCR公式识别和多平台编辑。和使用说明，避免使用，享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时，它能把识别后的处理步骤接得更顺，资料录入这类场景会省下不少时间。
一款文字处理软件，一种订阅式的跨平台办公软件，基于云平台提供多种服务，通过将 Excel 和 Outlook 等应用与 OneDrive 和 Microsoft Teams 等强大的云服务相结合，Office 365 可让任何人使用任何设备随时随地创建和共享内容。
CodeExpander 是一款快捷短语输入增强工具，通过键入缩写自动展开为自定义文段，提升工作效率。任务管理和过程控制会更完整，持续下载、批量同步或需要稳定传输流程的场景会更适合它。
Mountain Duck 是一款能将多个网盘挂载到本地的工具，像本地磁盘一样使用网盘。清理链路的完整性会更好一些，做应用卸载、残留处理和空间整理时，通常能少走很多手动排查步骤。
极度公式是一款跨平台专业LaTeX公式识别编辑软件，支持OCR公式识别和多平台编辑。和使用说明，避免使用，享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时，它能把识别后的处理步骤接得更顺，资料录入这类场景会省下不少时间。
一款文字处理软件，一种订阅式的跨平台办公软件，基于云平台提供多种服务，通过将 Excel 和 Outlook 等应用与 OneDrive 和 Microsoft Teams 等强大的云服务相结合，Office 365 可让任何人使用任何设备随时随地创建和共享内容。
Wise Folder Hider Pro 是一款专业级文件和文件夹隐藏加密软件，为私密数据添加多重保护。高频操作更强调就近处理，浏览、整理和跨目录移动文件时，来回切换和重复点击都会少很多。
CodeExpander 是一款快捷短语输入增强工具，通过键入缩写自动展开为自定义文段，提升工作效率。任务管理和过程控制会更完整，持续下载、批量同步或需要稳定传输流程的场景会更适合它。
Mountain Duck 是一款能将多个网盘挂载到本地的工具，像本地磁盘一样使用网盘。清理链路的完整性会更好一些，做应用卸载、残留处理和空间整理时，通常能少走很多手动排查步骤。
