SpringBoot中使用AOP实现日志记录功能

 更新时间:2024年05月19日 09:33:08   作者:哈__  
AOP的全称是Aspect-Oriented Programming,即面向切面编程(也称面向方面编程),它是面向对象编程(OOP)的一种补充,目前已成为一种比较成熟的编程方式,本文给大家介绍了SpringBoot中使用AOP实现日志记录功能,需要的朋友可以参考下

AOP简介

AOP的全称是Aspect-Oriented Programming,即面向切面编程(也称面向方面编程)。它是面向对象编程(OOP)的一种补充,目前已成为一种比较成熟的编程方式。

在传统的业务处理代码中,通常都会进行事务处理、日志记录等操作。虽然使用OOP可以通过组合或者继承的方式来达到代码的重用,但如果要实现某个功能(如日志记录),同样的代码仍然会分散到各个方法中。这样,如果想要关闭某个功能,或者对其进行修改,就必须要修改所有的相关方法。这不但增加了开发人员的工作量,而且提高了代码的出错率。

为了解决这一问题,AOP思想随之产生。AOP采取横向抽取机制,将分散在各个方法中的重复代码提取出来,然后在程序编译或运行时,再将这些提取出来的代码应用到需要执行的地方。这种采用横向抽取机制的方式,采用传统的OOP思想显然是无法办到的,因为OOP只能实现父子关系的纵向的重用。虽然AOP是一种新的编程思想,但却不是OOP的替代品,它只是OOP的延伸和补充。

创建日志数据库 

创建日志记录表

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;
 
-- ----------------------------
-- Table structure for sys_oper_log
-- ----------------------------
DROP TABLE IF EXISTS `sys_oper_log`;
CREATE TABLE `sys_oper_log`  (
  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '日志主键',
  `operation` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT '' COMMENT '操作',
  `business_type` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '0' COMMENT '业务类型',
  `method` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT '' COMMENT '方法名称',
  `create_time` datetime(0) NULL DEFAULT NULL COMMENT '操作时间',
  `oper_name` varchar(80) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '操作用户',
  `params` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT '参数',
  `ip` varchar(80) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '请求的ip地址',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 2058 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '操作日志记录' ROW_FORMAT = Dynamic;
 
SET FOREIGN_KEY_CHECKS = 1;

创建用户表 

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;
 
-- ----------------------------
-- Table structure for user
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user`  (
  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键ID',
  `name` varchar(30) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '姓名 ',
  `age` int(11) NULL DEFAULT NULL COMMENT '年龄 ',
  `email` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '邮箱 ',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 9 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;
 
-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO `user` VALUES (2, 'Jack', 20, 'test2@baomidou.com');
INSERT INTO `user` VALUES (3, 'Tom', 28, 'test3@baomidou.com');
INSERT INTO `user` VALUES (4, 'Sandy', 21, 'test4@baomidou.com');
INSERT INTO `user` VALUES (5, 'Billie', 24, 'test5@baomidou.com');
INSERT INTO `user` VALUES (6, 'sss', 18, '123@qq.com');
INSERT INTO `user` VALUES (8, 'sss', 18, '123@qq.com');
 
SET FOREIGN_KEY_CHECKS = 1;

简单看一下表格的结构,我这里的数据就不给大家展示了。

SpringBoot使用AOP

一、导入依赖

下边的三个依赖是我们的核心依赖。

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
        </dependency>
         <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.29</version>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.4.3</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

二、创建我们的项目结构

  • 创建UserMapper
@Mapper
public interface UserMapper extends BaseMapper<User> {
}
  • 创建UserService
public interface UserService extends IService<User> {
}
  • 创建UserServiceImpl
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}
  • 创建UserController
@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;
    @Log(operation = "查找用户",businessType = BusinessType.LIST)
    @RequestMapping("/find-user")
    public String findUser(){
        return userService.list().toString();
    }
}

创建两个实体

  • 创建User
@Data
public class User {
    @TableId(type = IdType.ASSIGN_ID)
    private Long id;
    private String name;
    private Integer age;
    private String email;
    
}
  • 创建SysOperLog
@Data
@TableName("sys_oper_log")
public class SysOperLog {
 
        @TableId(type = IdType.AUTO)
        private Long id;
 
        private String operation;
 
        private String businessType;
 
        private String method;
 
        @TableField(fill = FieldFill.INSERT)
        private LocalDateTime createTime;
 
        private String operName;
 
        private String params;
 
        private String ip;
}

三、使用AOP

1.创建枚举类

这个枚举类的作用就是记录我们调用的接口是什么样的一个类型的,是查找、删除还是其他。

public enum BusinessType {
    /**
     * 其它
     */
    OTHER,
 
    /**
     * 新增
     */
    INSERT,
 
    /**
     * 修改
     */
    UPDATE,
 
    /**
     * 删除
     */
    DELETE,
    
    /**
     * 浏览
     */
    LIST
}

2..创建Log注解

默认的操作为空,默认的操作类型是OTHER。

@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Log {
    /**
     * 操作名称
     * @return
     */
    String operation() default "";
 
    /**
     * 操作的类型
     * @return
     */
    BusinessType businessType() default BusinessType.OTHER;
}

3.创建切面类

@Aspect
@Component
public class LogAspect {
    @Pointcut("@annotation(com.qcby.annotation.Log)")
    public void pointCut(){}
 
    @Autowired
    HttpServletRequest request;
    @Autowired
    SysOperLogMapper sysOperLogMapper;
 
    @After(value = "pointCut()")
    public void afterLogWrite(JoinPoint joinPoint){
        // 创建日志对象
        SysOperLog sysOperLog = new SysOperLog();
        // 获取我们调用的方法
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
 
        // 获取方法上的Log注解,因为我们要获取注解中的一些信息
        Log log = method.getAnnotation(Log.class);
 
        // 获取我们调用的类的名称
        String className = joinPoint.getTarget().getClass().getName();
        // 获取调用的方法的名称
        String methodName = method.getName();
        // 重新修改一下我们调用的方法 是全路径的
        methodName = className + methodName;
 
        // 获取方法的参数
        Object[] args = joinPoint.getArgs();
        ObjectMapper objectMapper = new ObjectMapper();
        String params = "";
        try {
            params =  objectMapper.writeValueAsString(args);
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }
 
        // 获取注解中的操作名称
        String operation = log.operation();
        // 获取注解中的操作类型
        String businessType = log.businessType().toString();
 
        // 这里的操作人员仅靠后端是写不了的  需要前端的token认证  我直接把操作人员改为admin
        String username = "admin";
 
        // 获取ip地址
        String ipAddress = IpUtil.getIpAddr(request);
 
        sysOperLog.setBusinessType(businessType);
        sysOperLog.setOperation(operation);
        sysOperLog.setMethod(methodName);
        sysOperLog.setParams(params);
        sysOperLog.setIp(ipAddress);
        sysOperLog.setOperName(username);
        sysOperLog.setCreateTime(LocalDateTime.now());
        
        sysOperLogMapper.insert(sysOperLog);
        
    }
}

4.IpUtil

public class IpUtil {
    private static final String UNKNOWN = "unknown";
    private static final String LOCALHOST = "127.0.0.1";
    private static final String SEPARATOR = ",";
 
    public static String getIpAddr(HttpServletRequest request) {
        System.out.println(request);
        String ipAddress;
        try {
            ipAddress = request.getHeader("x-forwarded-for");
            if (ipAddress == null || ipAddress.length() == 0 || UNKNOWN.equalsIgnoreCase(ipAddress)) {
                ipAddress = request.getHeader("Proxy-Client-IP");
            }
            if (ipAddress == null || ipAddress.length() == 0 || UNKNOWN.equalsIgnoreCase(ipAddress)) {
                ipAddress = request.getHeader("WL-Proxy-Client-IP");
            }
            if (ipAddress == null || ipAddress.length() == 0 || UNKNOWN.equalsIgnoreCase(ipAddress)) {
                ipAddress = request.getRemoteAddr();
                if (LOCALHOST.equals(ipAddress)) {
                    InetAddress inet = null;
                    try {
                        inet = InetAddress.getLocalHost();
                    } catch (UnknownHostException e) {
                        e.printStackTrace();
                    }
                    ipAddress = inet.getHostAddress();
                }
            }
            // 对于通过多个代理的情况,第一个IP为客户端真实IP,多个IP按照','分割
            // "***.***.***.***".length()
            if (ipAddress != null && ipAddress.length() > 15) {
                if (ipAddress.indexOf(SEPARATOR) > 0) {
                    ipAddress = ipAddress.substring(0, ipAddress.indexOf(","));
                }
            }
        } catch (Exception e) {
            ipAddress = "";
        }
        return ipAddress;
    }
}

5.进行测试

我们在浏览器上输入网址:

127.0.0.1:8080/user/find-user

数据是没问题的,接下来我们只需要查看数据的日志文件是否插入了日志就好了。 

这里我查找了两次,一次使用的localhost,另一次使用的127.0.0.1。日志可以成功记录。 

以上就是SpringBoot中使用AOP实现日志记录功能的详细内容,更多关于SpringBoot AOP日志记录的资料请关注脚本之家其它相关文章!

相关文章

  • Java 循环队列/环形队列的实现流程

    Java 循环队列/环形队列的实现流程

    循环队列又叫环形队列,是一种特殊的队列。循环队列解决了队列出队时需要将所有数据前移一位的问题。本文将带大家详细了解循环队列如何实现,需要的朋友可以参考一下
    2022-02-02
  • IDEA设置Tab选项卡快速的操作

    IDEA设置Tab选项卡快速的操作

    这篇文章主要介绍了IDEA设置Tab选项卡快速的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2021-02-02
  • 浅谈Timer和TimerTask与线程的关系

    浅谈Timer和TimerTask与线程的关系

    下面小编就为大家带来一篇浅谈Timer和TimerTask与线程的关系。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-03-03
  • spring mvc 实现获取后端传递的值操作示例

    spring mvc 实现获取后端传递的值操作示例

    这篇文章主要介绍了spring mvc 实现获取后端传递的值操作,结合实例形式详细分析了spring mvc使用JSTL 方法获取后端传递的值相关操作技巧
    2019-11-11
  • java的http请求工具对比分析

    java的http请求工具对比分析

    本文对比了Java中五种流行的HTTP客户端库:HttpURLConnection、ApacheHttpClient、OkHttp、Feign和SpringRestTemplate,涵盖了它们的特性、优势、劣势以及适用场景,感兴趣的朋友一起看看吧
    2025-03-03
  • Struts 2 配置Action详解

    Struts 2 配置Action详解

    本篇文章主要介绍了Struts 2 配置Action详解,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-10-10
  • 解决SpringBoot ClassPathResource的大坑(FileNotFoundException)

    解决SpringBoot ClassPathResource的大坑(FileNotFoundException)

    这篇文章主要介绍了解决SpringBoot ClassPathResource的大坑(FileNotFoundException),具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • 使用springboot制作博客管理系统

    使用springboot制作博客管理系统

    这篇文章主要介绍了使用springboot制作博客管理系统,文中有非常详细的代码示例,对正在学习springboot的小伙伴有很大的帮助,感兴趣的小伙伴可以参考一下
    2021-08-08
  • mybatis 返回Map类型key默认为大写问题

    mybatis 返回Map类型key默认为大写问题

    这篇文章主要介绍了mybatis 返回Map类型key默认为大写问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-11-11
  • Java硬币翻转倍数递增试算实例

    Java硬币翻转倍数递增试算实例

    这篇文章主要介绍了Java硬币翻转倍数递增试算实例,有需要的朋友可以参考一下
    2013-12-12

最新评论