aop 可以做什么?
- 1. 日志记录
- 自动记录方法的调用、参数、返回值和异常等信息,减少了在每个方法中添加日志代码的需要。
- 2. 管理事务
- 在方法执行前后自动处理事务的开启、提交和回滚,确保数据的一致性和完整性。
- 3. 权限控制
- 实现方法的访问控制,检查用户权限,确保只有授权用户才能执行特定操作。
- 4. 性能监控
- 自动收集方法的执行时间、调用次数等性能指标,帮助开发者进行性能分析和优化。
- 5. 缓存管理
- 实现方法结果的缓存,减少重复计算,提高系统性能。
- 6. 异常处理
- 统一处理方法执行中的异常,简化异常捕获和处理逻辑。
- 7. 输入验证
- 在方法执行前对输入参数进行验证,保证数据的有效性和完整性。
- 8. 动态代理
- 创建代理对象,在不修改原有类的情况下添加额外的行为。
应用场景
- web开发:用于请求处理、事务管理、安全控制等。
- 企业应用:在服务层实现统一的日志和异常处理。
- 微服务:在服务之间进行统一的监控和熔断处理。
日志记录
1.准备工作
首先需要导入aop依赖
pom.xml
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-aop</artifactid>
</dependency>
<dependency>
<groupid>com.alibaba.fastjson2</groupid>
<artifactid>fastjson2</artifactid>
<version>2.0.50</version>
</dependency>
<dependency>
<groupid>io.jsonwebtoken</groupid>
<artifactid>jjwt</artifactid>
<version>0.9.1</version>
</dependency>然后需要创建日志记录数据库和实体类还有在mapper层实现插入数据方法
- 实体类
//操作日志实体类
@data
@noargsconstructor
@allargsconstructor
public class operatelog {
private integer id; //主键id
private integer operateuser; //操作人id
private localdatetime operatetime; //操作时间
private string classname; //操作类名
private string methodname; //操作方法名
private string methodparams; //操作方法参数
private string returnvalue; //操作方法返回值
private long costtime; //操作耗时
}- mapper接口
@mapper
public interface operatelogmapper {
//插入日志数据
@insert("insert into operate_log (operate_user, operate_time, class_name, method_name, method_params, return_value, cost_time) " +
"values (#{operateuser}, #{operatetime}, #{classname}, #{methodname}, #{methodparams}, #{returnvalue}, #{costtime});")
public void insert(operatelog log);
}2.创建自定义注解和切面类
因为我们要记录的操作日志是对于数据的增,删,改所以采用@annotation来指定要为连接点的方法。
而且在涉及到消耗时间的字段,所以需要采用@around通知类型
- 自定义注解类
@retention(retentionpolicy.runtime)//运行时有效
@target(elementtype.method)//作用在方法上
public @interface log {
}3.实现日志记录(around)
首先需要需要记录的操作接口方法前加上@log注解
接下来在切面类中实现操作日志记录:
@aspect
@component
public class logasper {
@autowired
private operatelogmapper operatelogmapper;
@autowired
private httpservletrequest request;
@around("@annotation(com.ly.springbootdemotlias.anno.log)")//匹配加了log注解的方法
public object recordlog(proceedingjoinpoint joinpoint) throws throwable {
operatelog operatelog = new operatelog();
//获取操作人id,通过获取并解析jwt令牌
string jwt = request.getheader("token");
claims claims = jwtutils.parsejwt((jwt));
integer operateuser =(integer) claims.get("id");
operatelog.setoperateuser(operateuser);
//获取操作时间
operatelog.setoperatetime(localdatetime.now());
//获取操作类名
operatelog.setclassname(joinpoint.gettarget().getclass().getname());
//获取操作方法名
operatelog.setmethodname(joinpoint.getsignature().getname());
//获取操作方法参数
operatelog.setmethodparams(arrays.tostring(joinpoint.getargs()));
//获取开始时间
long begin = system.currenttimemillis();
//获取操作方法返回值
object result = joinpoint.proceed();
string returnvalue = jsonobject.tojsonstring(result);
operatelog.setreturnvalue(returnvalue.tostring());
//获取操作结束时间
long end = system.currenttimemillis();
//获取操作耗时
operatelog.setcosttime((end-begin));
operatelogmapper.insert(operatelog);
return result;
}
}管理事务
1. 添加依赖
在 pom.xml 中添加 mybatis-plus 和 aop 的依赖
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-aop</artifactid>
</dependency>
<dependency>
<groupid>com.baomidou</groupid>
<artifactid>mybatis-plus-boot-starter</artifactid>
<version>3.5.0</version> <!-- 根据需要选择版本 -->
</dependency>
<dependency>
<groupid>mysql</groupid>
<artifactid>mysql-connector-java</artifactid>
<scope>runtime</scope>
</dependency>2. 配置 mybatis-plus
在 application.yml 中配置 mybatis-plus 和数据源:
spring:
datasource:
url: jdbc:mysql://localhost:3306/your_database
username: your_username
password: your_password
driver-class-name: com.mysql.cj.jdbc.driver
mybatis-plus:
mapper-locations: classpath*:/mappers/**/*.xml3. 创建事务切面
创建一个事务切面类:
import org.aspectj.lang.proceedingjoinpoint;
import org.aspectj.lang.annotation.around;
import org.aspectj.lang.annotation.aspect;
import org.springframework.stereotype.component;
import org.springframework.transaction.annotation.transactional;
@aspect
@component
public class transactionaspect {
@transactional
@around("execution(* com.yourpackage.service..*(..))") // 指定需要事务的业务逻辑包
public object managetransaction(proceedingjoinpoint joinpoint) throws throwable {
object result;
try {
result = joinpoint.proceed(); // 执行目标方法
return result;
} catch (exception e) {
throw e; // 抛出异常以触发回滚
}
}
}4. 示例业务逻辑类
创建一个服务类,使用 mybatis-plus 进行数据库操作:
import com.baomidou.mybatisplus.extension.service.impl.serviceimpl;
import org.springframework.stereotype.service;
@service
public class userservice extends serviceimpl<usermapper, user> {
public void createuser(user user) {
this.save(user); // 调用 mybatis-plus 的 save 方法
}
}5. 用户实体和 mapper
- 定义用户实体:
import com.baomidou.mybatisplus.annotation.tableid;
import com.baomidou.mybatisplus.annotation.tablename;
@tablename("users") // 数据库表名
public class user {
@tableid
private long id;
private string name;
// getters and setters
}- mapper 接口:
import com.baomidou.mybatisplus.core.mapper.basemapper;
public interface usermapper extends basemapper<user> {
// 可以自定义额外的方法
}6. 创建控制器
在控制器中调用 userservice 的 createuser 方法:
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.web.bind.annotation.*;
@restcontroller
@requestmapping("/users")
public class usercontroller {
@autowired
private userservice userservice;
@postmapping
public string createuser(@requestbody user user) {
userservice.createuser(user); // 调用 userservice 的 createuser 方法
return "user created successfully"; // 返回成功消息
}
}7. 启动类
import org.springframework.boot.springapplication;
import org.springframework.boot.autoconfigure.springbootapplication;
@springbootapplication
public class application {
public static void main(string[] args) {
springapplication.run(application.class, args);
}
}心得
- 通过以上步骤,你可以在 spring boot 项目中整合 aop 和 mybatis-plus,实现简单而有效的事务管理。
- 这样,无论是在正常情况下提交事务,还是在出现异常时回滚事务,都能得到很好的支持。
为什么做事务,做事务有啥用
- 事务确保一组操作要么全部成功,要么全部失败,从而保持数据的一致性和完整性。
- 它们在处理银行转账、订单处理等场景时尤其重要,可以防止数据不一致、部分更新或系统故障导致的数据丢失。
- 通过事务,确保即使在异常情况下,数据状态依然可靠。
那为什么要结合aop去做事务
- 结合 aop(面向切面编程)可以将事务管理的逻辑与业务逻辑分离,提高代码的可维护性和可读性。
- 通过 aop,可以在不修改业务代码的情况下,集中管理事务,简化代码结构,并实现事务的自动化管理,减少重复代码,提高开发效率。
权限控制
1. 添加依赖
在 pom.xml 中添加 aop 相关依赖:
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-aop</artifactid>
</dependency>2. 创建权限注解
定义一个自定义注解 @requirespermission:
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 requirespermission {
string value();
}3. 创建切面类
创建切面类,使用 @aspect 注解来定义切面,处理权限控制逻辑:
import org.aspectj.lang.proceedingjoinpoint;
import org.aspectj.lang.annotation.around;
import org.aspectj.lang.annotation.aspect;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.stereotype.component;
@component
@aspect
public class permissionaspect {
@autowired
private userservice userservice; // 获取用户服务
@around("@annotation(requirespermission)") // 拦截使用 @requirespermission 注解的方法
public object checkpermission(proceedingjoinpoint joinpoint, requirespermission requirespermission) throws throwable {
string requiredpermission = requirespermission.value(); // 获取所需权限
// 权限检查逻辑
if (!haspermission(requiredpermission)) {
throw new securityexception("permission denied: " + requiredpermission);
}
return joinpoint.proceed(); // 执行目标方法
}
private boolean haspermission(string permission) {
user currentuser = userservice.getcurrentuser(); // 获取当前用户
if (currentuser == null) {
return false; // 用户未登录
}
return currentuser.getpermissions().contains(permission); // 检查权限
}
}在使用 aop 时,@requirespermission 注解是一个标记,它本身并不直接传递参数。spring aop 在拦截带有该注解的方法时,会自动创建该注解的实例,并将其作为参数传递给
checkpermission 方法。这是通过 aop 框架的代理机制实现的,而不是通过显式调用。具体来说,当被注解的方法被调用时,aop 会拦截这个调用并注入相应的注解信息。
permission 参数来源于 @requirespermission 注解的 value() 方法。在 checkpermission 方法中,当该方法拦截到一个使用 @requirespermission 注解的方法时,spring aop 会将该注解的实例作为第二个参数传递给 checkpermission 方法。因此,你可以通过调用 requirespermission.value() 来获取注解中定义的权限字符串。
4. 使用权限注解
在需要进行权限控制的方法上使用自定义注解
import org.springframework.web.bind.annotation.getmapping;
import org.springframework.web.bind.annotation.restcontroller;
@restcontroller
public class mycontroller {
@getmapping("/admin")
@requirespermission("admin_access")
public string adminaccess() {
return "welcome, admin!";
}
}5. 配置 spring boot
确保 spring boot 应用程序能够扫描到切面和自定义注解。通常情况下,只需在主类中添加 @enableaspectjautoproxy 注解:
import org.springframework.boot.springapplication;
import org.springframework.boot.autoconfigure.springbootapplication;
import org.springframework.context.annotation.enableaspectjautoproxy;
@springbootapplication
@enableaspectjautoproxy
public class myapplication {
public static void main(string[] args) {
springapplication.run(myapplication.class, args);
}
}@enableaspectjautoproxy 注解的作用是启用 spring 的 aop(面向切面编程)支持,允许使用 aspectj 的代理机制来实现切面。具体来说,它有以下几个功能:
1.启用代理
它告诉 spring 创建代理对象,这些代理对象可以拦截方法调用并执行切面逻辑。
2.支持注解
当你在代码中使用注解(如 @around、@before 等)时,@enableaspectjautoproxy 会使这些注解生效,从而实现方法拦截和切面逻辑的执行。
3.简化配置
通过添加这个注解,开发者不需要额外的 xml 配置,只需通过注解来定义切面和增强,减少了配置的复杂性。
在主类中添加这个注解后,spring boot 应用会自动扫描到切面类并将其注册到应用上下文中,从而实现所需的 aop 功能。
aop的五种通知类型包括
- 前置通知(@before)
- 后置通知(@after)
- 返回通知(@afterreturning)
- 异常通知(@afterthrowing)
- 环绕通知(@around)
每种通知类型都有其特定的用途和场景,可以根据实际需求选择使用。
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持代码网。
发表评论