前言:
之前想在filter层直接过滤httpServerletRequest请求进行日志处理,但是之后再getWriter()的 时候报already been call异常。查了下,才发现原来流形式的只能读取一次。。就好像食物,吃了就没了。。 所以在filter和inteceptor里面是没法通过获取request的流来进行日志记录的。
于是还是准备用通用的方法:controller层aop进行切面记录日志。
使用Aop记录操作日志
第一步:添加Aop
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
/** * 统一日志处理Handler * @author Mingchenchen * */ public class LogAopHandler { @Autowired private AuditLogDao auditLogDao; /** * controller层面记录操作日志 * 注意此处是aop:around的 因为需要得到请求前的参数以及请求后接口返回的结果 * @throws Throwable */ public Object doSaveLog(ProceedingJoinPoint joinPoint) throws Throwable { MethodSignature method = (MethodSignature) joinPoint.getSignature(); String methodName = method.getName(); Object[] objects = joinPoint.getArgs(); String requestBody = null ; if (objects!= null && objects.length> 0 ) { for (Object object : objects) { if (object == null ) { requestBody = null ; //POST接口参数为空 比如删除XXX } else if (object instanceof String) { requestBody = (String) object; //有些接口直接把参数转换成对象了 } else { requestBody = JSONObject.toJSONString(object); } } } //只记录POST方法的日志 boolean isNeedSaveLog = false ; //此处不能用getAnnotationByType 是JAVA8的特性,因为注解能够重名,所以得到的是数组 RequestMapping annotation = method.getMethod().getAnnotation(RequestMapping. class ); for (RequestMethod requestMethod : annotation.method()) { if (requestMethod==RequestMethod.POST) { isNeedSaveLog = true ; } } JSONObject requestBodyJson = null ; try { requestBodyJson = JSONObject.parseObject(requestBody); } catch (Exception e) { //do nothing 即POST请求没传body } HttpServletRequest request = RequestContextUtil.getRequestByCurrentContext(); String userName = RequestContextUtil.getUserNameByCurrentContext(); if (StringUtil.isEmpty(userName)) { try { userName = DmsCache.get(requestBodyJson.getString( "userName" )).getName(); } catch (Exception e) { userName = RequestContextUtil.getAsynUserInfoByAutoDeploy().getName(); } } //得到request的参数后让方法执行它 //注意around的情况下需要返回result 否则将不会返回值给请求者 Object result = joinPoint.proceed(objects); try { JSONObject resultJson = JSONObject.parseObject(result.toString()); if (isNeedSaveLog) { //如果是POST请求 则记录日志 LogTypeEnum logTypeEnum = LogTypeEnum.getDesByMethodName(methodName); if (logTypeEnum != null ) { AuditLogEntity auditLogEntity = new AuditLogEntity(); auditLogEntity.setUuid(StringUtil.createRandomUuid()); auditLogEntity.setOperator(userName); auditLogEntity.setRequestIp(request.getRemoteAddr()); auditLogEntity.setRequestUrl(request.getRequestURI().replace( "/cloud-master" , "" )); auditLogEntity.setEventType(logTypeEnum.getKey()); auditLogEntity.setEventDesc(logTypeEnum.getDescription()); auditLogEntity.setRequest(requestBody); int isSuccess = "200" .equals(resultJson.getString( "code" )) ? 1 : 0 ; auditLogEntity.setSuccessFlag(isSuccess); auditLogEntity.setResponse(result.toString()); auditLogEntity.setCreateTime( new Date()); auditLogDao.insert(auditLogEntity); } } } catch (Exception e) { e.printStackTrace(); } return result; } } |
第二步:在spring的xml中声明
1
2
3
4
5
6
7
8
|
<!-- 记录操作日志 --> < bean id = "operationLogAop" class = "com.ming.learn.core.aop.LogAopHandler" /> < aop:config > < aop:aspect id = "logAOP" ref = "operationLogAop" > < aop:pointcut id = "target" expression = "execution(* com.ming.learn..*Controller.*(..))" /> < aop:around method = "doSaveLog" pointcut-ref = "target" /> </ aop:aspect > </ aop:config > |
如此一来,核心步骤就完成了,剩下的就是自己组装需要记录的东西了。
第三步:写Dao、Entity、Mapper
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
import java.util.Date; import javax.persistence.Column; import javax.persistence.Id; import javax.persistence.Table; /** * 日志审计 * @author Mingchenchen * */ @Table (name= "audit_log" ) public class AuditLogEntity { @Id private String uuid; @Column (name= "event_type" ) private String eventType; //事件类型 @Column (name= "event_desc" ) private String eventDesc; //事件中文描述 @Column (name= "operator" ) private String operator; //操作者 @Column (name= "request_ip" ) private String requestIp; //客户端地址 @Column (name= "request_url" ) private String requestUrl; //请求地址 @Column (name= "request" ) private String request; //请求body @Column (name= "response" ) private String response; //请求返回值 @Column (name= "create_time" ) private Date createTime; public String getUuid() { return uuid; } public void setUuid(String uuid) { this .uuid = uuid; } public String getEventType() { return eventType; } public void setEventType(String eventType) { this .eventType = eventType; } public String getEventDesc() { return eventDesc; } public void setEventDesc(String eventDesc) { this .eventDesc = eventDesc; } public String getOperator() { return operator; } public void setOperator(String operator) { this .operator = operator; } public String getRequestIp() { return requestIp; } public void setRequestIp(String requestIp) { this .requestIp = requestIp; } public String getRequestUrl() { return requestUrl; } public void setRequestUrl(String requestUrl) { this .requestUrl = requestUrl; } public String getRequest() { return request; } public void setRequest(String request) { this .request = request; } public String getResponse() { return response; } public void setResponse(String response) { this .response = response; } public Date getCreateTime() { return createTime; } public void setCreateTime(Date createTime) { this .createTime = createTime; } } |
第四步:根据Controller的方法名称定制响应的事件类型
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
import java.util.Map; import java.util.concurrent.ConcurrentHashMap; /** * 操作日志类型 * @author Mingchenchen * */ public enum LogTypeEnum { //用户 COMMON_LOGIN( "login" , "login" , "登录" ); //其他 private String methodName; //方法名称与controller一致 private String key; //保存到数据库的事件类型 private String description; //保存到数据库的描述 private LogTypeEnum(String methodName,String key,String description){ this .methodName = methodName; this .key = key; this .description = description; } public String getMethodName() { return methodName; } public void setMethodName(String methodName) { this .methodName = methodName; } public String getKey() { return key; } public void setKey(String key) { this .key = key; } public String getDescription() { return description; } public void setDescription(String description) { this .description = description; } /** * 根据方法名返回 * @param methodName * @return */ public static LogTypeEnum getDesByMethodName(String methodName){ return innerMap.map.get(methodName); } /** * 内部类 用户保存所有的enum 无须通过Enum.values()每次遍历 * @author Mingchenchen * */ private static class innerMap{ private static Map<String, LogTypeEnum> map = new ConcurrentHashMap<>( 128 ); static { //初始化整个枚举类到Map for (LogTypeEnum logTypeEnum : LogTypeEnum.values()) { map.put(logTypeEnum.getMethodName(), logTypeEnum); } } } } |
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:http://blog.csdn.net/jinzhencs/article/details/51882751