Spring如何基于aop实现操作日志功能

  org.springframework.bootspring-boot-starter-web org.springframework.bootspring-boot-starter-aop org.mybatis.spring.bootmybatis-spring-boot-starter2.1.3 mysqlmysql-connector-java8.0.19runtime org.projectlomboklomboktrue

 import lombok.Data; import java.io.Serializable; @Data public class AdminLog implements Serializable { private static final long serialVersionUID = -291495801959706565L; private Integer id; //日志记录id private Integer userId;//操作人id private String userName;//操作人name private String loginip;//登录ip private int type; private String url; private String operation; private String createtime; private String remark; }

 import java.lang.annotation.*; /** * 自定义日志注解 */ @Target(ElementType.METHOD) //注解防止位置 @Retention(RetentionPolicy.RUNTIME)//运行时可见 @Documented //生成文档 public @interface MyLog { String operation() default ""; int type(); }

 import cn.***.springaopdemo.anno.MyLog; import cn.***.springaopdemo.dao.MyLogMapper; import cn.***.springaopdemo.pojo.Admin; import cn.***.springaopdemo.pojo.AdminLog; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.aspectj.lang.JoinPoint; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.annotation.Before; import org.aspectj.lang.annotation.Pointcut; import org.aspectj.lang.reflect.MethodSignature; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import javax.servlet.http.HttpServletRequest; import java.lang.reflect.Method; /** * 切面处理类 */ @Aspect @Component public class SysLogAspect { /** * 使用log4j2把一些信息打印在控制台上面 */ private static final Logger log = LogManager.getLogger(SysLogAspect.class); @Autowired private MyLogMapper myLogMapper; //定义切点 @Pointcut //在注解的位置切入代码 @Pointcut("@annotation(cn.***.springaopdemo.anno.MyLog)") public void logPointCut() { } //切面 配置为前置通知 @Before("logPointCut()") public void saveOperation(JoinPoint joinPoint) { log.info("---------------接口日志记录---------------"); //创建一个日志对象 AdminLog adminLog = new AdminLog(); //获取切面织处入点的方法 MethodSignature signature = (MethodSignature) joinPoint.getSignature(); //获取切入点所在的方法 Method method = signature.getMethod(); //获取操作日志的属性值 MyLog myLog = method.getAnnotation(MyLog.class); if (myLog != null) { //操作事件 String operation = myLog.operation(); adminLog.setOperation(operation); //日志类型 int type = myLog.type(); adminLog.setType(type); log.info("operation=" + operation + ",type=" + type); } //获取url HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); String requestURL = request.getRequestURI().toString(); adminLog.setUrl(requestURL); //获取客户端ip String ip = request.getRemoteAddr(); adminLog.setLoginip(ip); //获取操作人账号、姓名(需要提前将用户信息保存到Session) Admin admin = (Admin) request.getSession().getAttribute("admin"); if (admin != null) { Integer id = admin.getId(); String name = admin.getName(); adminLog.setUserId(id); adminLog.setUserName(name); } log.info("url=" + requestURL + ",ip=" + ip); //调用service保存Operation实体类到数据库 //可以在这设置id，因为是测试，这里就使用的是数据库的自增id myLogMapper.insertLog(adminLog); } }

 import cn.***.springaopdemo.pojo.AdminLog; import java.util.List; public interface MyLogMapper { void insertLog(AdminLog adminLog); }

    INSERT INTO admin_log (user_id,user_name,loginip,type,url,operation,createtime,remark) VALUES (#{userId},#{userName},#{loginip},#{type},#{url},#{operation},now(),#{remark}) 

 import cn.***.springaopdemo.pojo.Admin; import cn.***.springaopdemo.service.IAdminService; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.servlet.http.HttpServletRequest; import java.util.List; @RestController @RequestMapping("/admin") public class AdminController { private static final Logger log = LogManager.getLogger(AdminController.class); //中间service层可以省略，直接通过mapper接口操作数据即可 @Autowired private IAdminService adminService; @RequestMapping("/login") public Admin login(HttpServletRequest request) { List adminList = adminService.findAllAdmin(); Admin admin = adminList.get(0); request.getSession().setAttribute("admin",admin ); return admin; } }

 import cn.***.springaopdemo.anno.MyLog; import cn.***.springaopdemo.pojo.Type; import cn.***.springaopdemo.service.ITypeService; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.util.ArrayList; import java.util.List; @RestController @RequestMapping("/type") public class TypeController { private static final Logger log = LogManager.getLogger(TypeController.class); @Autowired private ITypeService typeService; @MyLog(operation = "增加书籍类型", type = 2) @RequestMapping("/add") public void insertType() { List typeList = new ArrayList<>(); Type type = new Type(); type.setName("自然科学"); typeList.add(type); typeService.addTypeList(typeList); log.info("添加书籍类型" + type.getName()); } @MyLog(operation = "查询所有书籍类型", type = 1) @RequestMapping("/findAll") public List findAllType() { List typeList = typeService.findAllType(); log.info("查询所有书籍类型"); return typeList; } }