<mvc:annotation-driven /><!-- 激活組件掃描功能,在包com.gcx及其子包下面自動掃描通過注解配置的組件 --><context:component-scan base-package="com.gcx" />   <!-- 啟動對@AspectJ注解的支持 --> <!-- proxy-target-class等于true是強制使用cglib代理，proxy-target-class默認是false，如果你的類實現了接口 就走JDK代理，如果沒有，走cglib代理 --><!-- 注：對于單利模式建議使用cglib代理，雖然JDK動態代理比cglib代理速度快，但性能不如cglib --><!--如果不寫proxy-target-class="true"這句話也沒問題--><aop:aspectj-autoproxy proxy-target-class="true"/> <!--切面--><bean id="systemLogAspect" class="com.gcx.annotation.SystemLogAspect"></bean>

public class SystemLog {  private String id;  private String description;  private String method;  private Long logType;  private String requestIp;  private String exceptioncode;  private String exceptionDetail;  private String params;  private String createBy;  private Date createDate;  public String getId() {    return id;  }  public void setId(String id) {    this.id = id == null ? null : id.trim();  }  public String getDescription() {    return description;  }  public void setDescription(String description) {    this.description = description == null ? null : description.trim();  }  public String getMethod() {    return method;  }  public void setMethod(String method) {    this.method = method == null ? null : method.trim();  }  public Long getLogType() {    return logType;  }  public void setLogType(Long logType) {    this.logType = logType;  }  public String getRequestIp() {    return requestIp;  }  public void setRequestIp(String requestIp) {    this.requestIp = requestIp == null ? null : requestIp.trim();  }  public String getExceptioncode() {    return exceptioncode;  }  public void setExceptioncode(String exceptioncode) {    this.exceptioncode = exceptioncode == null ? null : exceptioncode.trim();  }  public String getExceptionDetail() {    return exceptionDetail;  }  public void setExceptionDetail(String exceptionDetail) {    this.exceptionDetail = exceptionDetail == null ? null : exceptionDetail.trim();  }  public String getParams() {    return params;  }  public void setParams(String params) {    this.params = params == null ? null : params.trim();  }  public String getCreateBy() {    return createBy;  }  public void setCreateBy(String createBy) {    this.createBy = createBy == null ? null : createBy.trim();  }  public Date getCreateDate() {    return createDate;  }  public void setCreateDate(Date createDate) {    this.createDate = createDate;  }}

package com.gcx.dao;import com.gcx.entity.SystemLog;public interface SystemLogMapper {  int deleteByPrimaryKey(String id);  int insert(SystemLog record);  int insertSelective(SystemLog record);  SystemLog selectByPrimaryKey(String id);  int updateByPrimaryKeySelective(SystemLog record);  int updateByPrimaryKey(SystemLog record);}

package com.gcx.service;import com.gcx.entity.SystemLog;public interface SystemLogService {  int deleteSystemLog(String id);  int insert(SystemLog record);    int insertTest(SystemLog record);  SystemLog selectSystemLog(String id);    int updateSystemLog(SystemLog record);}

package com.gcx.service.impl;import javax.annotation.Resource;import org.springframework.stereotype.Service;import com.gcx.annotation.Log;import com.gcx.dao.SystemLogMapper;import com.gcx.entity.SystemLog;import com.gcx.service.SystemLogService;@Service("systemLogService")public class SystemLogServiceImpl implements SystemLogService {  @Resource  private SystemLogMapper systemLogMapper;    @Override  public int deleteSystemLog(String id) {        return systemLogMapper.deleteByPrimaryKey(id);  }  @Override    public int insert(SystemLog record) {        return systemLogMapper.insertSelective(record);  }  @Override  public SystemLog selectSystemLog(String id) {        return systemLogMapper.selectByPrimaryKey(id);  }  @Override  public int updateSystemLog(SystemLog record) {        return systemLogMapper.updateByPrimaryKeySelective(record);  }  @Override  public int insertTest(SystemLog record) {        return systemLogMapper.insert(record);  }}

package com.gcx.annotation;import java.lang.annotation.*;@Target({ElementType.PARAMETER, ElementType.METHOD}) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface Log {  /** 要執行的操作類型比如：add操作 **/   public String operationType() default "";      /** 要執行的具體操作比如：添加用戶 **/   public String operationName() default "";}

package com.gcx.annotation;import java.lang.reflect.Method;import java.util.Date;import java.util.UUID;import javax.annotation.Resource;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpSession;import org.aspectj.lang.JoinPoint;import org.aspectj.lang.ProceedingJoinPoint;import org.aspectj.lang.annotation.After;import org.aspectj.lang.annotation.AfterReturning;import org.aspectj.lang.annotation.AfterThrowing;import org.aspectj.lang.annotation.Around;import org.aspectj.lang.annotation.Aspect;import org.aspectj.lang.annotation.Before;import org.aspectj.lang.annotation.Pointcut;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.stereotype.Component;import com.gcx.entity.SystemLog;import com.gcx.entity.User;import com.gcx.service.SystemLogService;import com.gcx.util.JsonUtil;/** * @author 楊建  * @E-mail: email * @version 創建時間：2015-10-19 下午4:29:05 * @desc 切點類  */@Aspect@Componentpublic class SystemLogAspect {  //注入Service用于把日志保存數據庫   @Resource //這里我用resource注解，一般用的是@Autowired，他們的區別如有時間我會在后面的博客中來寫  private SystemLogService systemLogService;     private static final Logger logger = LoggerFactory.getLogger(SystemLogAspect. class);     //Controller層切點   @Pointcut("execution (* com.gcx.controller..*.*(..))")   public void controllerAspect() {   }     /**    * 前置通知 用于攔截Controller層記錄用戶的操作    *    * @param joinPoint 切點    */   @Before("controllerAspect()")  public void doBefore(JoinPoint joinPoint) {    System.out.println("==========執行controller前置通知===============");    if(logger.isInfoEnabled()){      logger.info("before " + joinPoint);    }  }      //配置controller環繞通知,使用在方法aspect()上注冊的切入點   @Around("controllerAspect()")   public void around(JoinPoint joinPoint){     System.out.println("==========開始執行controller環繞通知===============");     long start = System.currentTimeMillis();     try {       ((ProceedingJoinPoint) joinPoint).proceed();       long end = System.currentTimeMillis();       if(logger.isInfoEnabled()){         logger.info("around " + joinPoint + "/tUse time : " + (end - start) + " ms!");       }       System.out.println("==========結束執行controller環繞通知===============");     } catch (Throwable e) {       long end = System.currentTimeMillis();       if(logger.isInfoEnabled()){         logger.info("around " + joinPoint + "/tUse time : " + (end - start) + " ms with exception : " + e.getMessage());       }     }   }    /**    * 后置通知 用于攔截Controller層記錄用戶的操作    *    * @param joinPoint 切點    */   @After("controllerAspect()")   public void after(JoinPoint joinPoint) {      /* HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();     HttpSession session = request.getSession(); */    //讀取session中的用戶     // User user = (User) session.getAttribute("user");     //請求的IP     //String ip = request.getRemoteAddr();    User user = new User();    user.setId(1);    user.setName("張三");    String ip = "127.0.0.1";     try {             String targetName = joinPoint.getTarget().getClass().getName();       String methodName = joinPoint.getSignature().getName();       Object[] arguments = joinPoint.getArgs();       Class targetClass = Class.forName(targetName);       Method[] methods = targetClass.getMethods();      String operationType = "";      String operationName = "";       for (Method method : methods) {          if (method.getName().equals(methodName)) {           Class[] clazzs = method.getParameterTypes();            if (clazzs.length == arguments.length) {              operationType = method.getAnnotation(Log.class).operationType();             operationName = method.getAnnotation(Log.class).operationName();             break;           }         }       }      //*========控制臺輸出=========*//       System.out.println("=====controller后置通知開始=====");       System.out.println("請求方法:" + (joinPoint.getTarget().getClass().getName() + "." + joinPoint.getSignature().getName() + "()")+"."+operationType);       System.out.println("方法描述:" + operationName);       System.out.println("請求人:" + user.getName());       System.out.println("請求IP:" + ip);       //*========數據庫日志=========*//       SystemLog log = new SystemLog();       log.setId(UUID.randomUUID().toString());      log.setDescription(operationName);       log.setMethod((joinPoint.getTarget().getClass().getName() + "." + joinPoint.getSignature().getName() + "()")+"."+operationType);       log.setLogType((long)0);       log.setRequestIp(ip);       log.setExceptioncode( null);       log.setExceptionDetail( null);       log.setParams( null);       log.setCreateBy(user.getName());       log.setCreateDate(new Date());       //保存數據庫       systemLogService.insert(log);       System.out.println("=====controller后置通知結束=====");     } catch (Exception e) {       //記錄本地異常日志       logger.error("==后置通知異常==");       logger.error("異常信息:{}", e.getMessage());     }   }     //配置后置返回通知,使用在方法aspect()上注冊的切入點   @AfterReturning("controllerAspect()")   public void afterReturn(JoinPoint joinPoint){     System.out.println("=====執行controller后置返回通知=====");        if(logger.isInfoEnabled()){         logger.info("afterReturn " + joinPoint);       }   }    /**    * 異常通知 用于攔截記錄異常日志    *    * @param joinPoint    * @param e    */    @AfterThrowing(pointcut = "controllerAspect()", throwing="e")    public void doAfterThrowing(JoinPoint joinPoint, Throwable e) {     /*HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();     HttpSession session = request.getSession();     //讀取session中的用戶     User user = (User) session.getAttribute(WebConstants.CURRENT_USER);     //獲取請求ip     String ip = request.getRemoteAddr(); */     //獲取用戶請求方法的參數并序列化為JSON格式字符串         User user = new User();    user.setId(1);    user.setName("張三");    String ip = "127.0.0.1";        String params = "";      if (joinPoint.getArgs() != null && joinPoint.getArgs().length > 0) {        for ( int i = 0; i < joinPoint.getArgs().length; i++) {         params += JsonUtil.getJsonStr(joinPoint.getArgs()[i]) + ";";       }     }      try {               String targetName = joinPoint.getTarget().getClass().getName();        String methodName = joinPoint.getSignature().getName();        Object[] arguments = joinPoint.getArgs();        Class targetClass = Class.forName(targetName);        Method[] methods = targetClass.getMethods();       String operationType = "";       String operationName = "";       for (Method method : methods) {          if (method.getName().equals(methodName)) {            Class[] clazzs = method.getParameterTypes();            if (clazzs.length == arguments.length) {              operationType = method.getAnnotation(Log.class).operationType();             operationName = method.getAnnotation(Log.class).operationName();             break;            }          }        }       /*========控制臺輸出=========*/       System.out.println("=====異常通知開始=====");       System.out.println("異常代碼:" + e.getClass().getName());       System.out.println("異常信息:" + e.getMessage());       System.out.println("異常方法:" + (joinPoint.getTarget().getClass().getName() + "." + joinPoint.getSignature().getName() + "()")+"."+operationType);       System.out.println("方法描述:" + operationName);       System.out.println("請求人:" + user.getName());       System.out.println("請求IP:" + ip);       System.out.println("請求參數:" + params);         /*==========數據庫日志=========*/       SystemLog log = new SystemLog();      log.setId(UUID.randomUUID().toString());      log.setDescription(operationName);       log.setExceptioncode(e.getClass().getName());       log.setLogType((long)1);       log.setExceptionDetail(e.getMessage());       log.setMethod((joinPoint.getTarget().getClass().getName() + "." + joinPoint.getSignature().getName() + "()"));       log.setParams(params);       log.setCreateBy(user.getName());       log.setCreateDate(new Date());       log.setRequestIp(ip);       //保存數據庫       systemLogService.insert(log);       System.out.println("=====異常通知結束=====");     } catch (Exception ex) {       //記錄本地異常日志       logger.error("==異常通知異常==");       logger.error("異常信息:{}", ex.getMessage());     }      /*==========記錄本地異常日志==========*/     logger.error("異常方法:{}異常代碼:{}異常信息:{}參數:{}", joinPoint.getTarget().getClass().getName() + joinPoint.getSignature().getName(), e.getClass().getName(), e.getMessage(), params);    }   }

package com.gcx.controller;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Controller;import org.springframework.web.bind.annotation.RequestMapping;import com.gcx.annotation.Log;import com.gcx.service.UserService;@Controller@RequestMapping("userController")public class UserController {  @Autowired  private UserService userService;    @RequestMapping("testAOP")  @Log(operationType="add操作:",operationName="添加用戶")   public void testAOP(String userName,String password){        userService.addUser(userName, password);  }}

@Test  public void testAOP1(){    //啟動Spring容器        ApplicationContext ctx = new ClassPathXmlApplicationContext(new String[]{"classpath:applicationContext-mvc.xml","classpath:applicationContext-dataSource.xml"});    //獲取service或controller組件    UserController userController = (UserController) ctx.getBean("userController");    userController.testAOP("zhangsan", "123456");  }