时隔1年，我终于弄懂了Java 中的 AOP操作

news2024/10/18 12:16:06

1. AOP概述

2. AOP快速入门 

依赖：

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
            <version>${spring-boot.version}</version>
        </dependency>

 示例:记录方法的执行耗时

创建一个aop类:（在执行com.etc.aoptest.service.impl.UserServiceImpl类下否方法时就会进行环绕通知）

package com.etc.aoptest.aop;

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@Aspect
public class TimeAspect {

    @Around("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..))")
    public Object recordTime(ProceedingJoinPoint joinPoint) throws Throwable{

        long begin = System.currentTimeMillis();

        Object result = joinPoint.proceed();

        long end = System.currentTimeMillis();
        log.info(joinPoint.getSignature() + "方法执行耗时: {}ms",end - begin);

        return result;
    }

}

3. AOP的核心概念

4. AOP通知类型

创建一个aop类用于测试AOP通知类型

package com.etc.aoptest.aop;

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@Aspect
public class AspectType {

    //环绕通知，目标方法前后都被执行
    @Around("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    public void around(ProceedingJoinPoint joinPoint) throws Throwable {
        log.info("方法执行前..................................");

        Object result = joinPoint.proceed();

        log.info("方法执行后..................................");
    }

    //环绕前通知
    @Before("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    public void before() {
        log.info("before通知..................................");
    }

    //环绕后通知
    @After("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    public void after() {
        log.info("after通知..................................");
    }

    //返回后通知
    @AfterReturning("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    public void afterReturning() {
        log.info("afterReturning通知..................................");
    }

    //异常后通知
    @AfterThrowing("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    public void afterThrowing(){
        log.info("afterThrowing通知..................................");
    }

}

可以通过@Pointcut简化冗余切面点表达式

修改后如下所示：

package com.etc.aoptest.aop;

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@Aspect
public class AspectType {

    @Pointcut("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    private void pt(){};

    //环绕通知，目标方法前后都被执行
    //@Around("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    @Around("pt()")
    public void around(ProceedingJoinPoint joinPoint) throws Throwable {
        log.info("方法执行前..................................");

        Object result = joinPoint.proceed();

        log.info("方法执行后..................................");
    }

    //环绕前通知
    //@Before("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    @Before("pt()")
    public void before() {
        log.info("before通知..................................");
    }

    //环绕后通知
    //@After("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    @After("pt()")
    public void after() {
        log.info("after通知..................................");
    }

    //返回后通知
    //@AfterReturning("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    @AfterReturning("pt()")
    public void afterReturning() {
        log.info("afterReturning通知..................................");
    }

    //异常后通知
    //@AfterThrowing("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..)) ")
    @AfterThrowing("pt()")
    public void afterThrowing(){
        log.info("afterThrowing通知..................................");
    }

}

其他aop类也可以引入当前aop类的切面点表达式

不过需要将private void pt()修改为public void pt();

示例：

package com.etc.aoptest.aop;

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@Aspect
public class TimeAspect {

    //@Around("execution(* com.etc.aoptest.service.impl.UserServiceImpl.*(..))")
    @Around("com.etc.aoptest.aop.AspectType.pt()")
    public Object recordTime(ProceedingJoinPoint joinPoint) throws Throwable{

        long begin = System.currentTimeMillis();

        Object result = joinPoint.proceed();

        long end = System.currentTimeMillis();
        log.info(joinPoint.getSignature() + "方法执行耗时: {}ms",end - begin);

        return result;
    }

}

5. AOP执行顺序

6. AOP切入点表达式

7.  AOP多个切入点表达式 @Annotation

 

这样就无需写表达式，只需要写在对应的方法上加上自定义的注解，这时Annotation就会通过对应的注解切入点表达式。 

示例：

步骤一

首先在一个log包内创建UserLog自定义注解

UserLog:

package com.etc.aoptest.log;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME) //运行时生效
@Target(ElementType.METHOD) //标识方法
public @interface UserLog {

}

步骤二

aop包下创建AnnoAspect 用于AOP注入时实现的环绕通知

package com.etc.aoptest.aop;

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@Aspect
public class AnnoAspect {

    @Pointcut("@annotation(com.etc.aoptest.log.UserLog)")
    private void pt(){}


    @Around("pt()")
    public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
        log.info("UserLog-方法执行前..................................");

        Object result = joinPoint.proceed();

        log.info("UserLog-方法执行后..................................");
        return result;
    }

}

步骤三 

在所注入AOP的方法上加上自定义注解名@UserLog

package com.etc.aoptest.controller;


import com.etc.aoptest.log.UserLog;
import com.etc.aoptest.pojo.User;
import com.etc.aoptest.service.IUserService;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;


@RestController
@RequestMapping("/user")
@RequiredArgsConstructor
public class UserController {

   private final IUserService userService;

   @UserLog
   @RequestMapping("/getList")
   public List<User> getList(){
       return userService.getList();
   }

   @UserLog
   @RequestMapping("/{id}")
    public User getById(@PathVariable Long id){
       return userService.getById(id);
   }

}

8. AOP连接点

通过JoinPoint来获取方法执行时的相关信息，只有环绕通知使用ProceedingJoinPoint来获取相关信息而另外四种AOP通知类型则通过JoinPoint来获取相关信息。

 9. AOP实战演练（操作日志表）

要求：实现操作日志表，记录对数据库的增删改查操作的日志。

步骤一

先创建一个记录日志表实体并创建该数据库

pojo.OperateLog：
package com.etc.aoptest.pojo;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.time.LocalDateTime;

@Data
@TableName("tb_operate_log")
public class OperateLog {

    @TableId(type = IdType.AUTO)
    private Long id;

    //操作者ID
    @TableField("operate_Id")
    private Long operateId;

    //类名
    @TableField("class_name")
    private String className;

    //方法名
    @TableField("method_name")
    private String methodName;

    //方法参数
    @TableField("method_params")
    private String methodParams;

    //返回结果
    @TableField("return_value")
    private String returnValue;

    //操作耗时
    @TableField("cost_time")
    private Long costTime;

    //操作时间
    @TableField("operate_time")
    private LocalDateTime operateTime;
}

anno.Log:

package com.etc.aoptest.log;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface Log {
}

 步骤二

编写AOP操作，用于在执行该方法时进行环绕通知操作，使用ProceedingJoinPoint获取执行方法的相关信息存入OperateLog数据库中

package com.etc.aoptest.aop;

import com.alibaba.fastjson.JSONObject;
import com.etc.aoptest.mapper.OperateLogMapper;
import com.etc.aoptest.pojo.OperateLog;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.Arrays;

@Component
@Aspect
@RequiredArgsConstructor
@Slf4j
public class LogAspect {

    private final OperateLogMapper operateLogMapper;

    @Around("@annotation(com.etc.aoptest.log.Log)")
    public Object recordLog(ProceedingJoinPoint joinPoint) throws Throwable{

        //TODO 1.通过HttpServletRequest获取token值通过JWT解析获取当前用户id 或者 2.通过ThreadLocal获取当前用户id
        Long operateId = 1L;

        //类名
        String className = joinPoint.getTarget().getClass().getName();

        //方法名
        String methodName = joinPoint.getSignature().getName();


        Object[] args = joinPoint.getArgs();
        //方法参数
        String methodParams = Arrays.toString(args);

        Long begin = System.currentTimeMillis();
        Object result = joinPoint.proceed();
        Long end = System.currentTimeMillis();

        //方法返回值
        String returnValue = JSONObject.toJSONString(result);

        //操作耗时
        Long costTime = end - begin;
        OperateLog operateLog = new OperateLog(null,operateId,className,methodName,methodParams,returnValue,costTime,LocalDateTime.now());
        operateLogMapper.insert(operateLog);

        log.info("AOP记录日志操作:{}",operateLog);

        return result;
    }
}

步骤三

 对于要进行AOP切入的方法前加上自定义的@Log注解

package com.etc.aoptest.controller;


import com.etc.aoptest.log.Log;
import com.etc.aoptest.pojo.User;
import com.etc.aoptest.service.IUserService;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;


@RestController
@RequestMapping("/user")
@RequiredArgsConstructor
public class UserController {

   private final IUserService userService;

   @Log
   @RequestMapping("/getList")
   public List<User> getList(){
       return userService.getList();
   }

   @Log
   @RequestMapping("/{id}")
    public User getById(@PathVariable Long id){
       return userService.getById(id);
   }

}

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【爬虫软件】2024最新短视频评论区抓取工具

【爬虫软件】2024最新短视频评论区抓取工具

一、背景说明 1.0 采集目标 采集DOU音评论数据对引流截流和获客有很多好处。首先&#xff0c;通过分析DOU音评论数据&#xff0c;我们可以更好地了解用户对于产品或内容的喜好和需求&#xff0c;从而调整营销策略&#xff0c;吸引更多用户关注和点击。其次&#xff0c;评论数据…
阅读更多...
C++学习/复习6---内存管理(数据的位置/大小)/new、delete/内存相关面试题(malloc与new/内存泄漏)

C++学习/复习6---内存管理(数据的位置/大小)/new、delete/内存相关面试题(malloc与new/内存泄漏)

一、内存中区域 1.不同数据的存储位置 2.数据占用内存大小 二、动态内存函数 三、new与delete 1.操作内置类型 2.操作自定义类型 四、operator new与operator delete 1.底层源码&#xff08;malloc/free&#xff09; 2.内置/自定义与构造和析构 3.举例 五、定位new表达式 1.举…
阅读更多...
【C++】多态：编程中的“一人千面”艺术

【C++】多态：编程中的“一人千面”艺术

目录 一、多态的概念二、多态的定义及实现1.多态的构成条件2.虚函数的重写2.1 什么是虚函数&#xff1f;2.2 虚函数的重写是什么&#xff1f;2.3 虚函数重写的两个例外2.4 C11 override 和 final2.5 重载、覆盖(重写)、隐藏(重定义)的对比 三、抽象类3.1 概念3.2 接口继承和实现…
阅读更多...
H3CNE-8-ARP工作原理

H3CNE-8-ARP工作原理

ARP&#xff1a;Address Resolution Protocol 通过目的IP地址请求对方的MAC地址的过程。 数据链路层在进行数据封装时&#xff0c;需要目的MAC地址。 arp -a 查看 arp -d * 清空 主机A发送一个数据包给主机C之前&#xff0c;首先要获取C的MAC地址 数据封装
阅读更多...
前后端项目部署和解决跨域

前后端项目部署和解决跨域

文章目录 一.前端项目部署1.1 上传前端文件1.2 项目部署1.3 解决跨域1.3.1 什么是跨域1.3.2 配置文件 二.后端项目部署2.1 上传后端文件2.2 项目部署2.3 解决跨域 一.前端项目部署 1.1 上传前端文件 站点创建好了&#xff0c;进入到站点的目录。 然后把它默认的文件删掉。 你…
阅读更多...
心电信号降噪方法（滤波器/移动平均/小波等，MATLAB环境）

心电信号降噪方法（滤波器/移动平均/小波等，MATLAB环境）

对于一个正常的、完整的心动周期&#xff0c;对应的心电图波形如下图所示&#xff0c;各个波形都对应着心脏兴奋活动的生理过程&#xff0c;包含P波&#xff0c;PR段&#xff0c;QRS波群&#xff0c;ST段&#xff0c;T波&#xff0c;U波。 &#xff08;1&#xff09;P波心电图中…
阅读更多...
PG实践｜PostgreSQL的安装和配置

PG实践｜PostgreSQL的安装和配置

&#x1f4eb; 作者简介&#xff1a;「六月暴雪飞梨花」&#xff0c;专注于研究Java&#xff0c;就职于科技型公司后端工程师 &#x1f3c6; 近期荣誉&#xff1a;华为云云享专家、阿里云专家博主、腾讯云优秀创作者、ACDU成员 &#x1f525; 三连支持&#xff1a;欢迎 ❤️关注…
阅读更多...
【Java面试】五、MySQL篇（下）

【Java面试】五、MySQL篇（下）

文章目录 1、事务的特性2、并发事务问题3、事务的隔离级别4、undo log 和 redo log4.1 底层结构4.2 redo log4.3 undo log 5、MVCC5.1 隐式字段5.2 undo log 版本链5.3 ReadView5.4 ReadView的匹配规则实现事务隔离 6、MySQL的主从同步原理7、分库分表7.1 垂直分库7.2 垂直分表…
阅读更多...
[NISACTF 2022]easyssrf、[NISACTF 2022]level-up

[NISACTF 2022]easyssrf、[NISACTF 2022]level-up

[NISACTF 2022]easyssrf 使用dirsearch扫描后没发现什么路径 尝试访问127.0.0.1&#xff0c;成功了 访问127.0.0.1/flag.php提示有文件/fl4g 使用file://协议读取文件/fl4g&#xff0c;提示除此页面外还有一个ha1x1ux1u.php页面。 file:///fl4g 直接访问&#xff0c;发现GET…
阅读更多...
C++240527

C++240527

定义自己的命名空间 my_sapce&#xff0c;在 my_sapce 中定义 string 类型的变量 s1&#xff0c;再 定义一个函数 完成 对字符串的逆置 。 #include <iostream>//导入 标准命名空间&#xff0c;cout 和 endl 标识符 存在于标准命名空间中 using namespace std;//定义了自…
阅读更多...
C++ 函数模板与模板函数

C++ 函数模板与模板函数

一 代码重用技术 函数 类与对象 继承与派生 多态&#xff08;函数重载、运算符重载、虚函数、纯虚函数与抽象类&#xff09; 泛型程序设计 通用的代码需要补受数据类型的影响&#xff0c;并且可以自动适应数据类型的变化&#xff0c;这种程序设计类型称为泛型程序设计。 二 模…
阅读更多...
特殊矩阵的压缩矩阵

特殊矩阵的压缩矩阵

目录 前提条件&#xff1a; 类型&#xff1a;对称矩阵&#xff0c;三角矩阵、三对角矩阵、稀疏矩阵 1&#xff1a;对称矩阵&#xff1a; 定义&#xff1a;n阶矩阵A 中任意一元素都有ai,jaj,i(1<i,j<n) 图像&#xff1a; 表达式&#xff1a; 计算过程&#xff1a; …
阅读更多...
类 和 对象（二）

类 和 对象（二）

构造方法 接上篇&#xff0c;若每次都想下面的setDate方法给对象初始化&#xff0c;未免比较麻烦&#xff0c;那有什么方法可以让初始化更加简便呢&#xff1f; public void setDate(int year, int month, int day){this.year year;this.month month;this.day day;}答&#…
阅读更多...
服务器端口号,如何避免与公共端口冲突

服务器端口号,如何避免与公共端口冲突

首先&#xff0c;我们需要明确什么是服务器端口号。服务器端口号是计算机操作系统分配给网络应用程序的一个数字标识&#xff0c;用于区分不同的网络服务。每个网络服务都需要一个唯一的端口号来进行标识&#xff0c;以便在通信过程中能够准确找到对应的服务。 为了避免与公共端…
阅读更多...
恒创科技：Linux 服务器和 Windows 服务器哪个更好？

恒创科技：Linux 服务器和 Windows 服务器哪个更好？

选择正确的服务器系统至关重要&#xff0c;目前广泛使用的选项是 Windows 服务器 和 Linux 服务器&#xff0c;它们各有优缺点。本文将比较 Linux 与 Windows 服务器&#xff0c;让我们来看看它们的主要区别&#xff0c;然后再决定哪种操作系统适合使用。 主要区别&#xff1a;…
阅读更多...
Windows下mingw32编译ffmpeg5.1.4实现rtsp拉流

Windows下mingw32编译ffmpeg5.1.4实现rtsp拉流

由于客户要求&#xff0c;要在Windows下使用mingw32编译&#xff0c;去ffmpeg.org下载需要编译的版本&#xff0c;使用msys2方法进行编译&#xff0c;使用QT5.10的编译器&#xff0c;基本上把网上的方法试了个遍&#xff0c;编译全部库总是报错出问题 查看了ffbuild文件夹中con…
阅读更多...
Mac 电脑给android手机传输文件提示 No android device found

Mac 电脑给android手机传输文件提示 No android device found

在开发过程中&#xff0c;我们有时候会有在电脑和手机之间传输文件的需求。 Mac电脑给android手机传输文件并不是很方便。 Google 官方提供了一个软件叫Android File Transfer&#xff0c;这个软件免费且好用。 Android File Transfer下载地址 但是使用过程中会遇到一些问题…
阅读更多...
Android：使用Kotlin搭建MVI架构模式

Android：使用Kotlin搭建MVI架构模式

一、简介MVI架构模式 M&#xff1a;Model 数据层&#xff0c;包含应用数据和业务逻辑V&#xff1a;View 界面层&#xff0c;在屏幕上显示应用数据&#xff0c;包含与界面相关的状态和界面逻辑&#xff0c;根据界面状态对象更新UI&#xff0c;界面状态定义是不可变的。这样的主要…
阅读更多...
完全背包+背包装满 总结

完全背包+背包装满 总结

目录 1.背包恰好装满 &#xff08;1&#xff09;问题是什么 &#xff08;2&#xff09;问题的有效状态和无效状态 &#xff08;3&#xff09;问题的常考形式&#xff0c;以及如何去处理 1.值的大小 2.组合个数 3.排列个数 2.例题 A. Cut Ribbon HDU1114 Piggy-Bank …
阅读更多...
OpenHarmony实战开发——网络组件axios可以在OpenHarmony上使用了

OpenHarmony实战开发——网络组件axios可以在OpenHarmony上使用了

什么是axios 上古浏览器页面在向服务器请求数据时&#xff0c;因为返回的是整个页面的数据&#xff0c;页面都会强制刷新一下&#xff0c;这对于用户来讲并不是很友好。并且我们只是需要修改页面的部分数据&#xff0c;但是从服务器端发送的却是整个页面的数据&#xff0c;十分…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023