元注解方式結(jié)合AOP施逾，靈活記錄操作日志
能夠記錄詳細(xì)錯(cuò)誤日志為運(yùn)維提供支持
日志記錄盡可能減少性能影響

1.定義日志記錄元注解

package com.myron.ims.annotation;

import java.lang.annotation.*;

/**
 * 自定義注解 攔截Controller
 * 
 * @author lin.r.x
 *
 */
@Target({ ElementType.PARAMETER, ElementType.METHOD })
@Retention(RetentionPolicy.RUNTIME)
public @interface SystemControllerLog {
    /**
     * 描述業(yè)務(wù)操作 例:Xxx管理-執(zhí)行Xxx操作
     * @return
     */
    String description() default "";
}

2.定義用于記錄日志的實(shí)體類

package com.myron.ims.bean;

import java.io.Serializable;
import com.myron.common.util.StringUtils;
import com.myron.common.util.UuidUtils;
import com.fasterxml.jackson.annotation.JsonFormat;
import java.util.Date;
import java.util.Map;

/**
 * 日志類-記錄用戶操作行為
 * @author lin.r.x
 *
 */
public class Log implements Serializable{
    private static final long serialVersionUID = 1L;

    private String logId;           //日志主鍵  
    private String type;            //日志類型  
    private String title;           //日志標(biāo)題  
    private String remoteAddr;          //請(qǐng)求地址  
    private String requestUri;          //URI   
    private String method;          //請(qǐng)求方式  
    private String params;          //提交參數(shù)  
    private String exception;           //異常    
    @JsonFormat(pattern="yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date operateDate;           //開始時(shí)間  
    private String timeout;         //結(jié)束時(shí)間  
    private String userId;          //用戶ID  

    public String getLogId() {
        return StringUtils.isBlank(logId) ? logId : logId.trim();
    }
    public void setLogId(String logId) {
        this.logId = logId;
    }


    public String getType() {
        return StringUtils.isBlank(type) ? type : type.trim();
    }
    public void setType(String type) {
        this.type = type;
    }


    public String getTitle() {
        return StringUtils.isBlank(title) ? title : title.trim();
    }
    public void setTitle(String title) {
        this.title = title;
    }


    public String getRemoteAddr() {
        return StringUtils.isBlank(remoteAddr) ? remoteAddr : remoteAddr.trim();
    }
    public void setRemoteAddr(String remoteAddr) {
        this.remoteAddr = remoteAddr;
    }


    public String getRequestUri() {
        return StringUtils.isBlank(requestUri) ? requestUri : requestUri.trim();
    }
    public void setRequestUri(String requestUri) {
        this.requestUri = requestUri;
    }


    public String getMethod() {
        return StringUtils.isBlank(method) ? method : method.trim();
    }
    public void setMethod(String method) {
        this.method = method;
    }


    public String getParams() {
        return StringUtils.isBlank(params) ? params : params.trim();
    }
    public void setParams(String params) {
        this.params = params;
    }

    /**
     * 設(shè)置請(qǐng)求參數(shù)
     * @param paramMap
     */
    public void setMapToParams(Map<String, String[]> paramMap) {
        if (paramMap == null){
            return;
        }
        StringBuilder params = new StringBuilder();
        for (Map.Entry<String, String[]> param : ((Map<String, String[]>)paramMap).entrySet()){
            params.append(("".equals(params.toString()) ? "" : "&") + param.getKey() + "=");
            String paramValue = (param.getValue() != null && param.getValue().length > 0 ? param.getValue()[0] : "");
            params.append(StringUtils.abbr(StringUtils.endsWithIgnoreCase(param.getKey(), "password") ? "" : paramValue, 100));
        }
        this.params = params.toString();
    }


    public String getException() {
        return StringUtils.isBlank(exception) ? exception : exception.trim();
    }
    public void setException(String exception) {
        this.exception = exception;
    }


    public Date getOperateDate() {
        return operateDate;
    }
    public void setOperateDate(Date operateDate) {
        this.operateDate = operateDate;
    }


    public String getTimeout() {
        return StringUtils.isBlank(timeout) ? timeout : timeout.trim();
    }
    public void setTimeout(String timeout) {
        this.timeout = timeout;
    }


    public String getUserId() {
        return StringUtils.isBlank(userId) ? userId : userId.trim();
    }
    public void setUserId(String userId) {
        this.userId = userId;
    }

}

3.定義日志AOP切面類

package com.myron.ims.aop;

import java.lang.reflect.Method;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.AfterThrowing;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.NamedThreadLocal;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;

import com.myron.common.util.DateUtils;
import com.myron.common.util.UuidUtils;
import com.myron.ims.annotation.SystemControllerLog;
import com.myron.ims.annotation.SystemServiceLog;
import com.myron.ims.bean.Log;
import com.myron.ims.bean.User;
import com.myron.ims.service.LogService;

/**
* 系統(tǒng)日志切面類
* @author lin.r.x
*
*/
@Aspect
@Component
public class SystemLogAspect {
   private  static  final Logger logger = LoggerFactory.getLogger(SystemLogAspect. class);

   private static final ThreadLocal<Date> beginTimeThreadLocal =
           new NamedThreadLocal<Date>("ThreadLocal beginTime");
   private static final ThreadLocal<Log> logThreadLocal = 
           new NamedThreadLocal<Log>("ThreadLocal log");

   private static final ThreadLocal<User> currentUser=new NamedThreadLocal<>("ThreadLocal user");

   @Autowired(required=false)
   private HttpServletRequest request;

   @Autowired
   private ThreadPoolTaskExecutor threadPoolTaskExecutor;

   @Autowired
   private LogService logService;

   /**
    * Controller層切點(diǎn) 注解攔截
    */
   @Pointcut("@annotation(com.myron.ims.annotation.SystemControllerLog)")
   public void controllerAspect(){}

   /**
    * 前置通知 用于攔截Controller層記錄用戶的操作的開始時(shí)間
    * @param joinPoint 切點(diǎn)
    * @throws InterruptedException 
    */
   @Before("controllerAspect()")
   public void doBefore(JoinPoint joinPoint) throws InterruptedException{
       Date beginTime=new Date();
       beginTimeThreadLocal.set(beginTime);//線程綁定變量（該數(shù)據(jù)只有當(dāng)前請(qǐng)求的線程可見）  
       if (logger.isDebugEnabled()){//這里日志級(jí)別為debug
           logger.debug("開始計(jì)時(shí): {}  URI: {}", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS")
               .format(beginTime), request.getRequestURI());
       }

       //讀取session中的用戶 
       HttpSession session = request.getSession();       
       User user = (User) session.getAttribute("ims_user");    
       currentUser.set(user);

   }

   /**
    * 后置通知 用于攔截Controller層記錄用戶的操作
    * @param joinPoint 切點(diǎn)
    */
   @SuppressWarnings("unchecked")
   @After("controllerAspect()")
   public void doAfter(JoinPoint joinPoint) {
       User user = currentUser.get();
       if(user !=null){
           String title="";
           String type="info";                       //日志類型(info:入庫,error:錯(cuò)誤)
           String remoteAddr=request.getRemoteAddr();//請(qǐng)求的IP
           String requestUri=request.getRequestURI();//請(qǐng)求的Uri
           String method=request.getMethod();        //請(qǐng)求的方法類型(post/get)
           Map<String,String[]> params=request.getParameterMap(); //請(qǐng)求提交的參數(shù)

           try {
               title=getControllerMethodDescription2(joinPoint);
           } catch (Exception e) {
               e.printStackTrace();
           }    
           // 打印JVM信息。
           long beginTime = beginTimeThreadLocal.get().getTime();//得到線程綁定的局部變量（開始時(shí)間）  
           long endTime = System.currentTimeMillis();  //2桐绒、結(jié)束時(shí)間  
           if (logger.isDebugEnabled()){
               logger.debug("計(jì)時(shí)結(jié)束：{}  URI: {}  耗時(shí)： {}   最大內(nèi)存: {}m  已分配內(nèi)存: {}m  已分配內(nèi)存中的剩余空間: {}m  最大可用內(nèi)存: {}m",
                       new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(endTime), 
                       request.getRequestURI(), 
                       DateUtils.formatDateTime(endTime - beginTime),
                       Runtime.getRuntime().maxMemory()/1024/1024, 
                       Runtime.getRuntime().totalMemory()/1024/1024, 
                       Runtime.getRuntime().freeMemory()/1024/1024, 
                       (Runtime.getRuntime().maxMemory()-Runtime.getRuntime().totalMemory()+Runtime.getRuntime().freeMemory())/1024/1024); 
           }

           Log log=new Log();
           log.setLogId(UuidUtils.creatUUID());
           log.setTitle(title);
           log.setType(type);
           log.setRemoteAddr(remoteAddr);
           log.setRequestUri(requestUri);
           log.setMethod(method);
           log.setMapToParams(params);
           log.setUserId(user.getId());
           Date operateDate=beginTimeThreadLocal.get();
           log.setOperateDate(operateDate);
           log.setTimeout(DateUtils.formatDateTime(endTime - beginTime));

           //1.直接執(zhí)行保存操作
           //this.logService.createSystemLog(log);

           //2.優(yōu)化:異步保存日志
           //new SaveLogThread(log, logService).start();

           //3.再優(yōu)化:通過線程池來執(zhí)行日志保存
           threadPoolTaskExecutor.execute(new SaveLogThread(log, logService));
           logThreadLocal.set(log);
       }

   }

   /**
    *  異常通知 記錄操作報(bào)錯(cuò)日志
    * @param joinPoint
    * @param e
    */
   @AfterThrowing(pointcut = "controllerAspect()", throwing = "e")  
   public  void doAfterThrowing(JoinPoint joinPoint, Throwable e) {
       Log log = logThreadLocal.get();
       log.setType("error");
       log.setException(e.toString());
       new UpdateLogThread(log, logService).start();
   }

   /**
    * 獲取注解中對(duì)方法的描述信息 用于service層注解
    * @param joinPoint切點(diǎn)
    * @return discription
    */
   public static String getServiceMthodDescription2(JoinPoint joinPoint) {
       MethodSignature signature = (MethodSignature) joinPoint.getSignature();
       Method method = signature.getMethod();
       SystemServiceLog serviceLog = method
               .getAnnotation(SystemServiceLog.class);
       String discription = serviceLog.description();
       return discription;
   }

   /**
    * 獲取注解中對(duì)方法的描述信息 用于Controller層注解
    * 
    * @param joinPoint 切點(diǎn)
    * @return discription
    */
   public static String getControllerMethodDescription2(JoinPoint joinPoint) {
       MethodSignature signature = (MethodSignature) joinPoint.getSignature();
       Method method = signature.getMethod();
       SystemControllerLog controllerLog = method
               .getAnnotation(SystemControllerLog.class);
       String discription = controllerLog.description();
       return discription;
   }

   /**
    * 保存日志線程
    */
   private static class SaveLogThread implements Runnable {
       private Log log;
       private LogService logService;

       public SaveLogThread(Log log, LogService logService) {
           this.log = log;
           this.logService = logService;
       }

       @Override
       public void run() {
           logService.createLog(log);
       }
   }

   /**
    * 日志更新線程
    */
   private static class UpdateLogThread extends Thread {
       private Log log;
       private LogService logService;

       public UpdateLogThread(Log log, LogService logService) {
           super(UpdateLogThread.class.getSimpleName());
           this.log = log;
           this.logService = logService;
       }

       @Override
       public void run() {
           this.logService.updateLog(log);
       }
   }
}

4.spring 配置掃描切面薯鼠，開啟@AspectJ注解的支持

···

<aop:aspectj-autoproxy/>

<context:component-scan base-package="com.myron.ims.aop" />
<context:component-scan base-package="com.myron.ims.service"/>

<bean id="taskExecutor"   class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">  
    <property name="corePoolSize" value="5" />  
    <property name="maxPoolSize" value="10" />  
    <property name="WaitForTasksToCompleteOnShutdown" value="true" />  
</bean>  

···

5.使用范例LoginController方法中添加日志注解

···
/**
*系統(tǒng)登入
*/
@RequestMapping("/login.do")
@SystemControllerLog(description="登入系統(tǒng)")
@ResponseBody
public Map<String, Object> login(String username, String password, Boolean rememberMe, HttpServletRequest req){
//業(yè)務(wù)代碼省略...
}

/**
 * 安全退出登入
 * @return
 */
@SystemControllerLog(description="安全退出系統(tǒng)")
@RequestMapping("logout.do")
public String logout(){
    Subject subject=SecurityUtils.getSubject();
    if(subject.isAuthenticated()){
        subject.logout(); // session 會(huì)銷毀糕再，在SessionListener監(jiān)聽session銷毀锨能，清理權(quán)限緩存
    }
    return "/login.jsp";
}

6.運(yùn)行效果

20170208164120917.jpg