基于AOP实现登录日志和操作日志
目录结构 代码 PostMan测试代码 控制台查看输出 解析成JSON 如果你觉得对你有帮助的话，请点赞收藏
package com. demo. mymaintest. constants ;
import java. lang. annotation. Documented ;
import java. lang. annotation. ElementType ;
import java. lang. annotation. Retention ;
import java. lang. annotation. RetentionPolicy ;
import java. lang. annotation. Target ;
@Retention ( RetentionPolicy . RUNTIME )
@Documented
@Target ( { ElementType . METHOD , ElementType . PARAMETER } )
public @interface SysLog {
String value ( ) default "" ;
}
package com. demo. mymaintest. aop ;
import com. alibaba. fastjson. JSONObject ;
import com. demo. mymaintest. constants. SysLog ;
import com. demo. mymaintest. entity. SysLogEntity ;
import javax. servlet. http. HttpServletRequest ;
import javax. servlet. http. HttpServletResponse ;
import org. aspectj. lang. ProceedingJoinPoint ;
import org. aspectj. lang. annotation. AfterThrowing ;
import org. aspectj. lang. annotation. Around ;
import org. aspectj. lang. annotation. Aspect ;
import org. aspectj. lang. annotation. Pointcut ;
import org. aspectj. lang. reflect. MethodSignature ;
import org. springframework. stereotype. Component ;
import org. springframework. web. context. request. RequestContextHolder ;
import org. springframework. web. context. request. ServletRequestAttributes ;
import java. lang. reflect. Method ;
import java. text. SimpleDateFormat ;
import java. time. LocalDateTime ;
import java. time. format. DateTimeFormatter ;
import java. util. * ;
import java. util. stream. Collectors ;
@Aspect
@Component
public class SysLogAspect {
@Pointcut ( "@annotation(com.demo.mymaintest.constants.SysLog)" )
public void logPointCut ( ) { }
@Around ( value = "logPointCut()" )
private Object Around ( ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
HttpServletRequest request = ( ( ServletRequestAttributes ) RequestContextHolder . getRequestAttributes ( ) ) . getRequest ( ) ;
String requestURI = request. getRequestURI ( ) ;
String requestMethod = request. getMethod ( ) ;
String remoteAddr = request. getRemoteAddr ( ) ;
SimpleDateFormat dateformat = new SimpleDateFormat ( "yyyy-MM-dd HH:mm:ss" ) ;
Long nowDate = System . currentTimeMillis ( ) ;
String startTime = dateformat. format ( nowDate) ;
MethodSignature method1 = ( MethodSignature ) proceedingJoinPoint. getSignature ( ) ;
Class < ? > = proceedingJoinPoint. getTarget ( ) . getClass ( ) ;
Object proceed = proceedingJoinPoint. proceed ( ) ;
List < Object > = Arrays . asList ( proceedingJoinPoint. getArgs ( ) ) ;
List < Object > =
allArgs. stream ( )
. map (
arg -> {
if ( ! ( arg instanceof HttpServletRequest )
&& ! ( arg instanceof HttpServletResponse ) ) {
return arg;
} else {
return null ;
}
} )
. filter ( arg -> arg != null )
. collect ( Collectors . toList ( ) ) ;
SysLogEntity sysLogEntity = new SysLogEntity ( ) ;
sysLogEntity. setUsername ( "登录人从request中获取" ) ;
MethodSignature signature = ( MethodSignature ) proceedingJoinPoint. getSignature ( ) ;
Method method = signature. getMethod ( ) ;
SysLog syslog = method. getAnnotation ( SysLog . class ) ;
if ( syslog != null ) {
sysLogEntity. setOperation ( syslog. value ( ) ) ;
}
sysLogEntity. setRequestPath ( requestURI) ;
sysLogEntity. setRequestMethod ( requestMethod) ;
sysLogEntity. setCurrentTimeMills ( startTime) ;
sysLogEntity. setArgsType ( getMethodArgumentTypeName ( method1) ) ;
sysLogEntity. setAllArgs ( args) ;
sysLogEntity. setResponseData ( proceed != null ? proceed. toString ( ) : "null" ) ;
sysLogEntity. setExecuteTimeMills ( ( System . currentTimeMillis ( ) - nowDate) + "ms" ) ;
sysLogEntity. setClassMethodLocation ( currentClass. getName ( ) + "." + method. getName ( ) ) ;
sysLogEntity. setRemoteAddr ( remoteAddr) ;
sysLogEntity. setNowTime ( LocalDateTime . now ( ) . format ( DateTimeFormatter . ofPattern ( "yyyy-MM-dd HH:mm:ss" ) ) ) ;
sysLogEntity. setResponseType ( method. getReturnType ( ) . getName ( ) ) ;
System . out. println ( JSONObject . toJSONString ( sysLogEntity) ) ;
return proceed;
}
@AfterThrowing ( value = "logPointCut()" )
private void AfterThrowing ( ) {
System . out. println ( "异常通知" ) ;
}
private Map < String , String > getMethodArgumentTypeName ( MethodSignature method) {
Map < String , String > = new HashMap < > ( ) ;
String [ ] argTypeNames = method. getParameterNames ( ) ;
Class [ ] parameterTypes = method. getParameterTypes ( ) ;
for ( int i = 0 ; i < parameterTypes. length; i++ ) {
map. put ( parameterTypes[ i] . getName ( ) , argTypeNames[ i] ) ;
}
return map;
}
}
package com. demo. mymaintest. controller ;
import com. demo. mymaintest. constants. SysLog ;
import com. demo. mymaintest. entity. BookEntity ;
import com. demo. mymaintest. entity. SysUser ;
import com. demo. mymaintest. utils. R ;
import lombok. extern. slf4j. Slf4j ;
import org. springframework. http. ResponseEntity ;
import org. springframework. web. bind. annotation. * ;
@RestController
@RequestMapping ( "/api" )
@Slf4j
public class TestApiController {
@PostMapping ( "/add" )
@SysLog ( value = "添加数据测试" )
public R test ( @RequestBody BookEntity bookEntity) {
bookEntity. setBookImg ( "testImg" ) ;
bookEntity. setBookIntro ( "书籍简介" ) ;
return R . ok ( 200 , "添加成功" , bookEntity) ;
}
@PostMapping ( "/login" )
@SysLog ( value = "用户登录" )
public ResponseEntity login ( @RequestBody SysUser sysUser) {
String ok = "恭喜你登录成功" ;
if ( sysUser. getUserName ( ) . equals ( "test" ) ) {
return ResponseEntity . ok ( ok) ;
}
return ResponseEntity . ok ( ) . body ( "登录失败" ) ;
}
@DeleteMapping ( "/delete" )
@SysLog ( "删除" )
public ResponseEntity < String > deleteById ( @PathVariable ( "id" ) Integer id) {
return ResponseEntity . ok ( "删除成功" ) ;
}
}
package com. demo. mymaintest. entity ;
import com. baomidou. mybatisplus. annotation. TableId ;
import com. baomidou. mybatisplus. annotation. TableName ;
import lombok. Data ;
import java. io. Serializable ;
@Data
public class BookEntity implements Serializable {
private static final long serialVersionUID = 1L ;
@TableId
private Integer bookId;
private String bookIsbn;
private String bookName;
private Float bookPrice;
private String bookImg;
private String bookIntro;
private int bookPurchasedNumber;
}
package com. demo. mymaintest. entity ;
import com. baomidou. mybatisplus. annotation. IdType ;
import com. baomidou. mybatisplus. annotation. TableId ;
import com. fasterxml. jackson. annotation. JsonFormat ;
import lombok. Data ;
import lombok. EqualsAndHashCode ;
import lombok. experimental. Accessors ;
import java. io. Serializable ;
import java. util. Date ;
@Data
@EqualsAndHashCode ( callSuper = false )
@Accessors ( chain = true )
public class SysUser implements Serializable {
private static final long serialVersionUID= 1L ;
@TableId ( value = "id" , type = IdType . AUTO )
private Long id;
private String userCode;
private String userName;
private String password;
private String realName;
private String mobile;
private String email;
private Long orgId;
private String orgName;
private Integer userType;
private String userDesc;
private String address;
private String fax;
private String postalcode;
private Integer status;
private String permissionType;
@JsonFormat ( pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8" )
private Date createTime;
private String createBy;
@JsonFormat ( pattern = "yyyy-MM-dd HH:mm:ss" , timezone = "GMT+8" )
private Date updateTime;
private String updateBy;
private Integer isDeleted;
private String orgAddress;
private String jobId;
private String jobName;
@JsonFormat ( pattern = "yyyyMM" , timezone = "GMT+8" )
private Date expire;
private String orgCode;
}
{
"allArgs" : [
{
"bookId" : 123 ,
"bookImg" : "testImg" ,
"bookIntro" : "书籍简介" ,
"bookIsbn" : "123213414" ,
"bookName" : "test" ,
"bookPrice" : 12.77 ,
"bookPurchasedNumber" : 0
}
] ,
"argsType" : {
"com.demo.mymaintest.entity.BookEntity" : "bookEntity"
} ,
"classMethodLocation" : "com.demo.mymaintest.controller.TestApiController.test" ,
"currentTimeMills" : "2023-07-21 16:30:49" ,
"executeTimeMills" : "9ms" ,
"nowTime" : "2023-07-21 16:30:49" ,
"operation" : "添加数据测试" ,
"remoteAddr" : "0:0:0:0:0:0:0:1" ,
"requestMethod" : "POST" ,
"requestPath" : "/api/add" ,
"responseData" : "{msg=添加成功, code=200, data=BookEntity(bookId=123, bookIsbn=123213414, bookName=test, bookPrice=12.77, bookImg=testImg, bookIntro=书籍简介, bookPurchasedNumber=0)}" ,
"responseType" : "com.demo.mymaintest.utils.R" ,
"username" : "登录人从request中获取"
}
