本文將介紹在Spring框架下如何利用攔截器做日誌記錄，簡化我們的日誌處理，

1 首先我們需要在Spring-mvc.xml中註冊這個攔截器，程式碼如下：

<mvc:interceptors>
		<mvc:interceptor>
			<mvc:mapping path="/*/*" /><!-- 需攔截的地址 -->
			<mvc:exclude-mapping path="/login/loginIn" /><!-- 登入不攔截 -->
			<bean class="com.zsq.cn.common.sys.interceptor.LogInterceptor" />
		</mvc:interceptor>
	</mvc:interceptors>
 

2 新建一個日誌類 (setter、getter方法就沒有拷貝了，但是重寫了setParams方法)

public class Log {
	private static final long serialVersionUID = 1L;
	private String type; 		// 日誌型別（1：操作日誌；2：錯誤日誌）
	private String title;		// 日誌標題
	private String remoteAddr; 	// 操作使用者的IP地址
	private String requestUri; 	// 操作的URI
	private String method; 		// 操作的方式
	private String params; 		// 操作提交的資料
	private String userAgent;	// 操作使用者代理資訊
	private String exception; 	// 異常資訊


	// 日誌型別（1：接入日誌；2：錯誤日誌）
	public static final String TYPE_ACCESS = "1";
	public static final String TYPE_EXCEPTION = "2";

	public void setParams(String params) {
		this.params = params;
	}

	/**
	 * 設定請求引數
	 * @param paramMap
	 */
	@SuppressWarnings({ "unchecked", "deprecation" })
	public void setParams(Map paramMap){
		if(paramMap == null){
			return;
		}

		StringBuilder sb = new StringBuilder();
		for(Map.Entry<String, String[]> para : (((Map<String, String[]>) paramMap).entrySet())){
			sb.append(para.getKey().endsWith("password") ?
					para.getKey()+"="+"...":para.getKey()+"="+Arrays.toString(para.getValue())+"::");
		}
		setParams(sb.toString());
	}

	@Override
	public String toString(){
		return ReflectionToStringBuilder.toString(this);
	}
}
 

3 新建一個攔截器類，即 1中bean的class類

這裡需要說明下，這個類的最後一個方法的程式段

String title = (String)request.getAttribute(Constant.LOG_TITLE);
if(title != null){
LogUtils.saveNormalLog(request, handler, ex);
}

因為有很多請求我們是不需要做日誌記錄的，所以我判斷了下 如果有日誌資訊，則進行日誌的持久化操作。這裡的Constant.LOG_TITLE一般寫在Controller的方法裡，我將會在第5個程式段中給出例項。

public class LogInterceptor implements HandlerInterceptor{

	private Logger logger = LoggerFactory.getLogger(LogInterceptor.class);
	
	//每次請求都會保留一個HttpServletRequest副本
	public static ThreadLocal<HttpServletRequest> curentHttpRequest = new ThreadLocal<>();

	public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)
			throws Exception {
		curentHttpRequest.set(request);//設定本次請求的HttpServletRequest
		return true;
	}

	public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
			ModelAndView modelAndView) throws Exception {
//		System.out.println(LocalDate.now()+"訪問檢視"+modelAndView.getViewName());
		if(modelAndView != null){
			logger.info(LocalDate.now()+"訪問檢視"+modelAndView.getViewName());
		}
	}

	public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex)
			throws Exception {
		String title = (String)request.getAttribute(Constant.LOG_TITLE);
		if(title != null){
			LogUtils.saveNormalLog(request, handler, ex);
		}
	}
}
 

4 新建一個日誌工具類來處理日誌

public class LogUtils {

	/**
	 * 儲存日誌
	 * @param request
	 * @param handler
	 * @param ex
	 * @param title
	 */
	public static void saveLog(HttpServletRequest request, Object handler, Exception ex,String title) {
		
		User user = SessionUtils.getSession(request, SessionNames.SESSION_USER);
		if (user != null){
			Log log = new Log();
			log.setTitle(title);
			log.setType(ex == null ? Log.TYPE_ACCESS : Log.TYPE_EXCEPTION);
			log.setRemoteAddr(request.getRemoteAddr());
			log.setUserAgent(request.getHeader("user-agent"));
			log.setRequestUri(request.getRequestURI());
			log.setParams(request.getParameterMap());
			log.setMethod(request.getMethod());
			// 非同步儲存日誌
			new Thread(new SaveLogThread(log)).start();
		}
		
	}
	
	
	/**儲存異常日誌
	 * @param exceptionMessage
	 */
	public static void  saveExceptionLog(String exceptionMessage,Exception ex){
		HttpServletRequest request = LogInterceptor.curentHttpRequest.get();
		String title = (String) request.getAttribute(Constant.LOG_TITLE);
		saveLog(request,null,ex,title+"--"+exceptionMessage);
	}


	/**
	 * 正常儲存日誌
	 * @param request
	 * @param handler
	 * @param ex
	 */
	public static void saveNormalLog(HttpServletRequest request, Object handler, Exception ex) {
		saveLog(request,handler,ex,(String)request.getAttribute(Constant.LOG_TITLE));
	}
	
	
	
	/**
	 * 單獨開啟一個執行緒持久化日誌
	 *
	 */
	static class SaveLogThread implements Runnable{
		private Log log;
		
		public SaveLogThread(Log log){
			this.log = log;
		}

		@Override
		public void run() {
			if(log != null){
				//這裡進行持久化操作
				System.out.println("-----------請進行日誌持久化操作,下面將輸出日誌資訊--------------");
				System.out.println(log.toString());
			}
		}
	}
}

5 新建一個測試請求類

@Controller
@RequestMapping("test")
public class TestController {
	
	@Autowired
	private TestService testService;
	
	@RequestMapping("test")
	public String test(HttpServletRequest request,User user,Model model){
		//注意只有這裡request設定日誌資訊後，該請求才會持久化操作，因為我在3中的最後一個方法判斷了如果沒有日誌資訊則不持久化
		request.setAttribute(Constant.LOG_TITLE, "測試");
		User user2 = testService.getUser();
		model.addAttribute("user", user2);
		return "index/test";
	}
}

但是需要說明的是，只要異常的地方，並且你想記錄異常日誌，呼叫saveExceptionLog(String exceptionMessage,Exception ex)方法即可，即使該請求的Controller沒有設定

request.setAttribute(Constant.LOG_TITLE, "測試");異常日誌也會持久化。

當然，如果每一次日誌記錄系統都開啟一個執行緒的話，那將會很耗費系統資源的，因為單個執行緒的開啟和銷燬都是需要時間的，在這裡我們需要對上面的實現方法進行改進，使用執行緒去做日誌持久化記錄。

2.1 首先在spring-context.xml中註冊一個執行緒池的bean 

<!-- 使用執行緒池管理執行緒 -->
	<bean id="taskExecutor"
		class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
		<property name="corePoolSize" value="5" /> <!-- 執行緒池維護執行緒的最少數量 -->
		<property name="keepAliveSeconds" value="300" /> <!-- 執行緒池維護執行緒所允許的空閒時間 -->
		<property name="maxPoolSize" value="10" /> <!-- 執行緒池維護執行緒的最大數量 -->
		<property name="queueCapacity" value="25" /> <!-- 執行緒池所使用的緩衝佇列大小，不設定的話 預設為Integer.MAX_VALUE -->
	</bean>

說明：你可以看到，註冊bean的class 是spring提供的ThreadPoolTaskExecutor，我看了下這個類的原始碼如下

原始碼中，預設為某些屬性賦了預設值，請注意上圖中劃紅線的一個屬性，ThreadPoolExecutor。這個類是jdk提供的java.util.concurrent.ThreadPoolExecutor，其實，spring的ThreadPoolTaskExecutor只是對ThreadPoolExecutor完成了一次封裝，其最終的實現仍然是ThreadPoolExecutor這個類。到底ThreadPoolTaskExecutor是怎樣封裝ThreadPoolExecutor的呢？，我們就拿corePoolSize為例，在xml檔案設定ThreadPoolTaskExecutor類的屬性 ：

<property name="corePoolSize" value="5" /> <!-- 執行緒池維護執行緒的最少數量 -->

在spring註冊這個bean的時候，將會執行下面程式碼。這段程式碼也是ThreadPoolTaskExecutor的原始碼，ThreadPoolTaskExecutor中的每個屬性都有這樣的一段設定屬性值得程式碼

public void setCorePoolSize(int corePoolSize) {
		synchronized (this.poolSizeMonitor) {
			this.corePoolSize = corePoolSize;
			if (this.threadPoolExecutor != null) {
				this.threadPoolExecutor.setCorePoolSize(corePoolSize);
			}
		}
	}

好了，迴歸主題。繼續講一下如何用執行緒池來做日誌服務

2.3 新建一個上下文工具，用於執行時獲取spring註冊的bean,這個類需要在spring-context.xml檔案中配置如下：

<bean id="ApplicationContextUtils" class="com.zsq.cn.common.sys.utils.ApplicationContextUtils" />

public class ApplicationContextUtils implements ApplicationContextAware,DisposableBean{

	private static ApplicationContext applicationContext;

	@Override
	public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
		this.applicationContext = applicationContext;		
	}

	@Override
	public void destroy() throws Exception {
		this.applicationContext = null;
	}

	/**
	 * 根據類獲取bean
	 * @param t 
	 * @return
	 */
	public static <T> T getBean(Class<T> t){
		if(null != applicationContext){
			T object = null;
			object = applicationContext.getBean(t);
			return object;
		}
		return null;
	}
	/**
	 * 根據bean的名字獲取bean
	 * @param beanName
	 * @return
	 */
	public static Object getBean(String beanName){
		if(null != applicationContext){
			return  applicationContext.getBean(beanName);
		}
		return null;
	}
}

2.2 新建一個執行緒池工具類,所有實現Runable介面的執行緒都可以用這個執行緒池

public class ThreadPoolUtils {
	
	/**
	 * 獲取執行緒池物件，其已經在 spring-context.xml中註冊。
	 */
	private static ThreadPoolTaskExecutor tpte = 
			(ThreadPoolTaskExecutor) ApplicationContextUtils.getBean(ThreadPoolTaskExecutor.class);
	
	
	public static void execute(Runnable task){
		tpte.execute(task);
	}
}

2.3 將 程式碼段 4 中的 

//非同步報錯日誌

new Thread(new SaveLog(log)).start()

這行程式碼改為

ThreadPoolUtils.execute(new LogTask(log));

這樣，所有的日誌服務都可以交給執行緒池去處理了。關於執行緒池這篇文章沒有太深入研究原理，還有一些特性並沒有提到。比如。任務快取佇列及排隊策略、任務拒絕策略、執行緒池的關閉、執行緒池容量的動態調整。感興趣的朋友可以參考下這篇博文，很詳細地闡述了執行緒池的原理。

http://www.importnew.com/19011.html