用aspectJ 做了一次日志

1、

Java代码  

1. <aspectj.version>1.7.4.RELEASE</aspectj.version>
2. <dependency>
3. <groupId>org.aspectj</groupId>
4. <artifactId>aspectjweaver</artifactId>
5. <version>${aspectj.version}</version>
6. </dependency>
7. <dependency>
8. <groupId>org.aspectj</groupId>
9. <artifactId>aspectjrt</artifactId>
10. <version>${aspectj.version}</version>
11. </dependency>

注意：如果JDK1.7的 必须这里也是1.7+

2、

Java代码  

1. <aop:config proxy-target-class="true"></aop:config>
2. <bean class="org.apache.shiro.spring.security.interceptor.AuthorizationAttributeSourceAdvisor">
3. <property name="securityManager" ref="securityManager"/>
4. </bean>
5. <aop:aspectj-autoproxy proxy-target-class="true"/>

注意：下载 必须在spring-mvc.xml里面，且有两个aop配置，下面那个是必须的，上面那个可能不是必须的（上面那个应该是spring aop的，如果有aspectJ了，可以不需要）

3、AOP类

Java代码  

1. package com.kingen.aop;
2. import java.lang.reflect.Method;
3. import javax.servlet.http.HttpServletRequest;
4. import javax.transaction.Transactional;
5. import org.aspectj.lang.JoinPoint;
6. import org.aspectj.lang.annotation.AfterReturning;
7. import org.aspectj.lang.annotation.AfterThrowing;
8. import org.aspectj.lang.annotation.Aspect;
9. import org.aspectj.lang.annotation.Pointcut;
10. import org.slf4j.Logger;
11. import org.slf4j.LoggerFactory;
12. import org.springframework.stereotype.Component;
13. import org.springframework.util.Assert;
14. import org.springframework.web.context.request.RequestContextHolder;
15. import org.springframework.web.context.request.ServletRequestAttributes;
16. import com.kingen.bean.Log;
17. import com.kingen.bean.User;
18. import com.kingen.service.log.LogService;
19. import com.kingen.util.Constants;
20. import com.kingen.util.DateUtils;
21. import com.kingen.util.SpringContextHolder;
22. import com.kingen.util.StringUtils;
23. import com.kingen.util.UserUtils;
24. /**
25. * 日志AOP
26. *
27. * @author wj
28. * @date 2016-11-16
29. *
30. */
31. @Aspect
32. @Component
33. public class LogAOP {
34. private static LogService logService = SpringContextHolder.getBean(LogService.class);
35. 下载
36. // 本地异常日志记录对象
37. private Logger logger = LoggerFactory.getLogger(getClass());
38. /**
39. * 在所有标注@LogAnnotation的地方切入
40. *
41. * @param joinPoint
42. */
43. @Pointcut("@annotation(com.kingen.aop.LogAnnotation)")
44. public void logAspect() {
45. }
46. // @Around(value = "aApplogic() && @annotation(annotation) &&args(object,..)
47. // ", argNames = "annotation,object")
48. // public Object around(ProceedingJoinPoint pj,
49. // LogAnnotation annotation, Object object) throws Throwable {
50. // System.out.println("moduleName:"+annotation.moduleName());
51. // System.out.println("option:"+annotation.option());
52. // pj.proceed();
53. // return object;
54. // }
55. /**
56. * 前置通知 用于拦截Controller层记录用户的操作
57. *
58. * @param joinPoint
59. *            切点
60. * @throws Exception
61. */
62. //  @Around(value = "logAspect() && @annotation(annotation) &&args(object,..) ", argNames = "annotation,object")
63. //  public void doAround(ProceedingJoinPoint joinPoint, LogAnnotation annotation, Object object) {
64. //用@Around 会导致controller不执行，不返回页面
65. //   @After(value = "logAspect() && @annotation(annotation) &&args(object,..) ", argNames = "annotation,object")
66. //   public void doAfter(JoinPoint joinPoint, LogAnnotation annotation, Object object) {
67. @AfterReturning(value = "logAspect() && @annotation(annotation) &&args(object,..) ", argNames = "", returning = "retVal")
68. public void doAfterReturning(JoinPoint joinPoint, LogAnnotation annotation, Object object,  String retVal) {
69. HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes())
70. .getRequest();
71. try {
72. // String title = getAnnotationValue(joinPoint);
73. String title = getAnnotationValue(annotation);
74. saveLog(request, title);
75. } catch (Exception e) {
76. e.printStackTrace();
77. // 记录本地异常日志
78. logger.error("==异常通知异常==");
79. logger.error("异常信息:{}", e.getMessage());
80. }
81. }
82. /**
83. * 异常通知 用于拦截service层记录异常日志
84. *
85. * @param joinPoint
86. * @param e
87. */
88. // 方法  catch住异常的话，这里执行不到
89. //  @AfterThrowing(pointcut = "logAspect()", throwing = "e")
90. @AfterThrowing(value = "logAspect() && @annotation(annotation) &&args(..) " , throwing = "e")
91. public void doAfterThrowing(JoinPoint joinPoint,  LogAnnotation annotation, Exception e) {
92. HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes())
93. .getRequest();
94. try {
95. //          String title = getAnnotationValue(joinPoint);
96. String title = getAnnotationValue(annotation);
97. saveLog(request, title, e);
98. } catch (Exception ex) {
99. // 记录本地异常日志
100. logger.error("==异常通知异常==");
101. logger.error("异常信息:{}", ex.getMessage());
102. }
103. }
104. 下载
105. public static void saveLog(HttpServletRequest request, String title) {
106. saveLog(request, title, null);
107. }
108. /**
109. * 保存日志
110. */
111. @Transactional
112. public static void saveLog(HttpServletRequest request, String title, Exception ex) {
113. User user = UserUtils.getCurrentUser();
114. if (user != null && user.getUserId() != null) {
115. Log log = new Log();
116. log.setCreateDate(DateUtils.getDateTime());
117. log.setTitle(title);
118. log.setType(ex == null ? Log.TYPE_ACCESS : Log.TYPE_EXCEPTION);
119. log.setRemoteAddr(StringUtils.getRemoteAddr(request));
120. log.setUserAgent(user.getUsername());
121. // log.setUserAgent(request.getHeader("user-agent"));
122. log.setRequestUri(request.getRequestURI());
123. log.setParams(request.getParameterMap());
124. // 如果有异常，设置异常信息
125. log.setException(ex == null ? null : ex.getMessage());
126. //          log.setException(ex == null ? null : Exceptions.getStackTraceAsString(ex));
127. log.setStatus(ex == null ? Constants.StatusEnum.Success.getIndex() : Constants.StatusEnum.Fail.getIndex());
128. // log.setMethod(request.getMethod());
129. // 异步保存日志
130. // new SaveLogThread(log, handler, ex).start();
131. logService.saveLog(log);
132. }
133. }
134. /**
135. * 获取注解中对方法的描述信息 用于Controller层注解
136. *
137. * @param joinPoint
138. *            切点
139. * @return 方法描述
140. * @throws Exception
141. */
142. @Deprecated
143. public static String getAnnotationValue(JoinPoint joinPoint) throws Exception {
144. String targetName = joinPoint.getTarget().getClass().getName();
145. String methodName = joinPoint.getSignature().getName();
146. Object[] arguments = joinPoint.getArgs();
147. Class targetClass = Class.forName(targetName);
148. Method[] methods = targetClass.getMethods();
149. String description = "";
150. for (Method method : methods) {
151. if (method.getName().equals(methodName)) {
152. Class[] clazzs = method.getParameterTypes();
153. if (clazzs.length == arguments.length) {
154. String moduleName = method.getAnnotation(LogAnnotation.class).moduleName();
155. String option = method.getAnnotation(LogAnnotation.class).option();
156. Assert.hasText(moduleName, "模块名字不应为空");
157. Assert.hasText(option, "操作名字不应为空");
158. description = moduleName + "-" + option;
159. break;
160. }
161. }
162. }
163. return description;
164. }
165. public static String getAnnotationValue(LogAnnotation anno) throws Exception {
166. String moduleName = anno.moduleName();
167. String option = anno.option();
168. Assert.hasText(moduleName, "模块名字不应为空");
169. Assert.hasText(option, "操作名字不应为空");
170. String description = moduleName + "-" + option;
171. return description;
172. }
173. }

注意这里 @After和 @AfterReturning的区别，总的来说，就是 @After 是无论如何都会执行的，不管有没有异常抛出（这样会导致，在有异常的时候，记录两次日志，after一次、throwing一次）；@AfterReturning 在有异常的情况下，不会执行到，因为没有renturn，在retrun之前就throw了。