Spring AOP 日志管理

首先感谢你们写的有关AOP的博客,本人参考了不少篇博客,走了一点小弯路,因此在此记录下配置的过程。 一、Mavan的相关依赖java

<!--配置aop切面编程须要引入的包 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>3.2.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aspects</artifactId>
            <version>3.2.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjrt</artifactId>
            <version>1.7.4</version>
        </dependency>

二、Spring 的配置文件spring

<!--Aop切面编程的配置-->
    <aop:aspectj-autoproxy proxy-target-class="true" />

三、Struts2 的配置文件数据库

<!-- Spring AOP -->
    <constant name="struts.objectFactory.spring.autoWire.alwaysRespect" value="true" />

四、日志实体(省略数据库的操做)apache

package com.gxuwz.entity;

import javax.persistence.*;
@Entity
@Table(name = "sys_log")
public class SysLog extends BaseEntity{

	private static final long serialVersionUID = -2894437117210657269L;
	
	@Column(name = "log_ip_add")
	private String ipAdd;		// IP地址
	@Column(name = "log_msg")
	private String msg;			// 消息
	@Column(name = "log_method")
	private String method;		// 方法
	@Column(name = "log_clazz")
	private String clazz; 		// 类名
	@Column(name = "log_username")
	private String username;	// 用户名
	@Column(name = "log_create_date")
	private String createDate;	//建立时间
        // 省略get、set的方法
}

五、自定义AOP的注解编程

package com.gxuwz.annotation;

import java.lang.annotation.*;

@Retention(RetentionPolicy.RUNTIME)	//注解会在class中存在,运行时可经过反射获取
@Target(ElementType.METHOD)			//目标是方法
@Documented							//文档生成时,该注解将被包含在javadoc中,可去掉
public @interface LogMsg
{
    String msg() default "";

}

六、切面session

package com.gxuwz.annotation;

import org.apache.log4j.Logger;
import org.apache.struts2.ServletActionContext;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.*;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;

import com.gxuwz.entity.SysLog;
import com.gxuwz.entity.SysUser;
import com.gxuwz.service.ILogService;
import com.gxuwz.util.DateUtils;
import com.opensymphony.xwork2.ActionContext;

import java.lang.reflect.Method;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

@Aspect
@Component
public class LogAspect {
	private static final Logger logger = Logger.getLogger(LogAspect.class);
	
	private SysLog log = new SysLog();	// 定义一个日志对象
	
	@Resource(name = "logService")
	private ILogService logService;

	/**
	 * 定义Pointcut,Pointcut的名称,此方法不能有返回值,该方法只是一个标示
	 */
	@Pointcut("@annotation(com.gxuwz.annotation.LogMsg)")
	public void controllerAspect() {
		System.out.println("我是一个切入点");
	}

	/**
	 * 前置通知(Before advice) :在某链接点(JoinPoint)以前执行的通知,但这个通知不能阻止链接点前的执行。
	 * 
	 * @param joinPoint
	 */
	@Before("controllerAspect()")
	public void doBefore(JoinPoint joinPoint) {
		System.out.println("=====LogAspect前置通知开始=====");
		// handleLog(joinPoint, null);
	}

	/**
	 * 后通知(After advice) :当某链接点退出的时候执行的通知(不管是正常返回仍是异常退出)。
	 * 
	 * @param joinPoint
	 */
	@AfterReturning(pointcut = "controllerAspect()")
	public void doAfter(JoinPoint joinPoint) {
		System.out.println("=====LogAspect后置通知开始=====");
		handleLog(joinPoint, null);	// 等执行完SQL语句以后再记录,避免获取不到Session
	}

	/**
	 * 抛出异常后通知(After throwing advice) : 在方法抛出异常退出时执行的通知。
	 * 
	 * @param joinPoint
	 * @param e
	 */
	@AfterThrowing(value = "controllerAspect()", throwing = "e")
	public void doAfter(JoinPoint joinPoint, Exception e) {
		System.out.println("=====LogAspect异常通知开始=====");
		// handleLog(joinPoint, e);
	}

	/**
	 * 环绕通知(Around advice)
	 * :包围一个链接点的通知,相似Web中Servlet规范中的Filter的doFilter方法。能够在方法的调用先后完成自定义的行为
	 * ,也能够选择不执行。
	 * 
	 * @param joinPoint
	 */
	@Around("controllerAspect()")
	public Object doAround(ProceedingJoinPoint joinPoint) throws Throwable {
		System.out.println("=====LogAspect 环绕通知开始=====");
		//handleLog(joinPoint, null);
		Object obj = joinPoint.proceed();
		System.out.println("=====LogAspect 环绕通知结束=====");
		return obj;
	}

	/**
	 * 日志处理
	 * 
	 * @param joinPoint
	 * @param e
	 */
	private void handleLog(JoinPoint joinPoint, Exception e) {
		try {
			HttpServletRequest request = (HttpServletRequest) ActionContext
					.getContext().get(ServletActionContext.HTTP_REQUEST);
			System.out.println("IP地址:" + request.getRemoteAddr());
			log.setIpAdd(request.getRemoteAddr());
			Map<String, Object> session = (Map<String, Object>) ActionContext
					.getContext().getSession();
			// 读取session中的用户
			SysUser user = (SysUser) session.get("user");
			System.out.println("用户名:" + user.getUserName());
			log.setUsername(user.getUserName());
			System.out.println("时间:"+DateUtils.getCurrentDate());
			log.setCreateDate(DateUtils.getCurrentDate());
			LogMsg logger = giveController(joinPoint);
			if (logger == null) {
				return;
			}
			System.out.println("用户操做:"+logger.msg());
			log.setMsg(logger.msg());
			String signature = joinPoint.getSignature().toString(); // 获取目标方法签名
			String methodName = signature.substring(
					signature.lastIndexOf(".") + 1, signature.indexOf("("));

			//String longTemp = joinPoint.getStaticPart().toLongString();
			String classType = joinPoint.getTarget().getClass().getName();

			Class<?> clazz = Class.forName(classType);

			Method[] methods = clazz.getDeclaredMethods();
			System.out.println("方法名:" + methodName);

			for (Method method : methods) {
				if (method.isAnnotationPresent(LogMsg.class)
						&& method.getName().equals(methodName)) {
					// OpLogger logger = method.getAnnotation(OpLogger.class);
					String clazzName = clazz.getName();
					log.setClazz(clazzName);
					log.setMethod(methodName);
					System.out.println("类名:" + clazzName + ", 方法名:"
							+ methodName);
				}
			}
			
			logService.save(log);	//保存日志对象

		} catch (Exception exp) {
			logger.error("异常信息:{}", exp);
			exp.printStackTrace();
		}
	}

	/**
	 * 得到注解
	 * 
	 * @param joinPoint
	 * @return
	 * @throws Exception
	 */
	private static LogMsg giveController(JoinPoint joinPoint)
			throws Exception {
		Signature signature = joinPoint.getSignature();
		MethodSignature methodSignature = (MethodSignature) signature;
		Method method = methodSignature.getMethod();

		if (method != null) {
			return method.getAnnotation(LogMsg.class);
		}
		return null;
	}

}

七、在Controller的方法上写注解、例如日志

/**
 * 用户控制器
 * @author 小胡  
 * @date 2017年5月28日
 */
public class UserController extends AbstractBaseController{
	@LogMsg(msg = "用户登录")
	public String doLogin(){
            ...
        }
}
相关文章
相关标签/搜索