2. 程式人生 > >通過ThreadLocal和HandlerInterceptor實現java後臺業務埋點日誌功能

通過ThreadLocal和HandlerInterceptor實現java後臺業務埋點日誌功能

阿新 • • 發佈：2019-02-05

目前公司的方案是用mdc來實現一個請求的業務資料埋點記錄，但是mdc是map方式，需要手動設定key，而且每次都要手動clear，一是不方便管理，再者如果忘記clear會造成業務埋點資料混亂。所以有了想要把埋點資料欄位統一封裝的想法，這樣方便維護，後面如果修改，也很容易找到所有修改點。於是我就想把封裝好的bean放到mdc裡，然後再用切面統一處理，但是，研究發現，mdc的value不支援object只能用String，很失望。我順手翻了一下mdc的原始碼，如下

MDC的put方法原始碼
private InheritableThreadLocal<Map<String, String
 
>> inheritableThreadLocal = new InheritableThreadLocal<Map<String, String>>() {
    protected Map<String, String> childValue(Map<String, String> parentValue) {
      return parentValue == null?null:new HashMap(parentValue);
    }
  };

  public BasicMDCAdapter() {
  }

  public
 
 void put(String key, String val) {
    if(key == null) {
      throw new IllegalArgumentException("key cannot be null");
    } else {
      Map<String, String> map = (Map)this.inheritableThreadLocal.get();
      if(map == null) {
        map = new HashMap();
        this.inheritableThreadLocal.
 
set(map);
      }

      ((Map)map).put(key, val);
    }
  }

發現是用ThreadLocal實現的，它直接把裡面的物件定義成map，我想，那我是不是可以定義成我自己的日誌實體，開始動手，寫了一個簡單的類，如下

public class BusinessLogUtil {

  private final static ThreadLocal<BusinessLog> threadLocal = new InheritableThreadLocal<>();

  public static BusinessLog getThreadLocalLog() {
    if (threadLocal.get() == null) {
      return new BusinessLog();
    }
    return threadLocal.get();
  }

  public static void setThreadLocalLog(final BusinessLog businessLog) {
    threadLocal.set(businessLog);
  }

  public static void remove() {
    threadLocal.remove();
  }
}

好了，操作類實現完了，來實現一下統一的前置和後置操作，剛開始用aspectj實現的，但是發現，不是在同一執行緒裡操作的，具體原理不細說。於是換成HandlerInterceptor，具體程式碼如下

@Slf4j
public class BusinessLogInterceptor implements HandlerInterceptor {

  @Override
  public boolean preHandle(final HttpServletRequest httpServletRequest,
      final HttpServletResponse httpServletResponse, final Object o) throws Exception {
    final BusinessLog businessLog = new BusinessLog();
    businessLog.setUserId(String.valueOf(Math.random()));
    BusinessLogUtil.setThreadLocalLog(businessLog);
    log.info("開始訪問：" + BusinessLogUtil.getThreadLocalLog().toString());
    return true;// 只有返回true才會繼續向下執行，返回false取消當前請求
  }

  @Override
  public void postHandle(final HttpServletRequest httpServletRequest,
      final HttpServletResponse httpServletResponse, final Object o,
      final ModelAndView modelAndView)
      throws Exception {

  }

  @Override
  public void afterCompletion(final HttpServletRequest httpServletRequest,
      final HttpServletResponse httpServletResponse, final Object o, final Exception e)
      throws Exception {
    log.info("訪問結束:" + BusinessLogUtil.getThreadLocalLog().toString());
    BusinessLogUtil.remove();
    log.info("清理結束:" + BusinessLogUtil.getThreadLocalLog().toString());
  }
}

測試結果如下


[2017-12-01T11:25:40,015] | INFO | com.aaa.interceptor.BusinessLogInterceptor.preHandle(BusinessLogInterceptor.java:23) | http-nio-8080-exec-1  開始訪問：BusinessLog(userId=0.1528058009781007, type=null, message=null, phone=null)
[2017-12-01T11:25:40,033] | INFO | com.aaa.api.rest.IntegrateController.getIntegrateList(IntegrateController.java:70) | http-nio-8080-exec-1訪問controller:BusinessLog(userId=0.1528058009781007, type=null, message=null, phone=null)
[2017-12-01T11:25:40,033] | INFO | com.aaa.api.rest.IntegrateController.getIntegrateList(IntegrateController.java:74) | http-nio-8080-exec-1 設定controller變數:BusinessLog(userId=0.1528058009781007, type=integrate, message=null, phone=null)
[2017-12-01T11:25:40,033] | INFO | com.aaa.service.impl.BaseServiceImpl.getBatchList(BaseServiceImpl.java:39) | http-nio-8080-exec-1  訪問service:BusinessLog(userId=0.1528058009781007, type=integrate, message=null, phone=null)
[2017-12-01T11:25:40,034] | INFO | com.aaa.service.impl.BaseServiceImpl.getBatchList(BaseServiceImpl.java:43) | http-nio-8080-exec-1 設定service變數:BusinessLog(userId=0.1528058009781007, type=integrate, message=null, phone=18600732726)
[2017-12-01T11:25:41,024] | INFO | com.aaa.oplog.OpLogAspect.logEvent(OpLogAspect.java:75) | http-nio-8080-exec-1  EventParameter{source='com.aaa.api.rest.IntegrateController', level='INFO', name='獲取整合請求列表', desc='', arguments='ListBatchRequest(batchId=null, batchNo=null, state=null, createPerson=null, updateTime=null, createTime=null, type=null, pageNum=1, pageSize=10)', message='', method='getIntegrateList', url='http://localhost:8080/api/online-tickets/v1/integrate'}
[2017-12-01T11:25:41,066] | INFO | com.aaa.interceptor.BusinessLogInterceptor.afterCompletion(BusinessLogInterceptor.java:39) | http-nio-8080-exec-1 訪問結束:BusinessLog(userId=0.1528058009781007, type=integrate, message=null, phone=18600732726)
[2017-12-01T11:25:41,067] | INFO | com.aaa.interceptor.BusinessLogInterceptor.afterCompletion(BusinessLogInterceptor.java:41) | http-nio-8080-exec-1 清理結束:BusinessLog(userId=null, type=null, message=null, phone=null)
[2017-12-01T11:33:18,880] | INFO | com.aaa.interceptor.BusinessLogInterceptor.preHandle(BusinessLogInterceptor.java:23) | http-nio-8080-exec-3 開始訪問：BusinessLog(userId=0.203277605749153, type=null, message=null, phone=null)
[2017-12-01T11:33:18,881] | INFO | com.aaa.api.rest.IntegrateController.getIntegrateList(IntegrateController.java:70) | http-nio-8080-exec-3 訪問controller:BusinessLog(userId=0.203277605749153, type=null, message=null, phone=null)
[2017-12-01T11:33:18,882] | INFO | com.aaa.api.rest.IntegrateController.getIntegrateList(IntegrateController.java:74) | http-nio-8080-exec-3 設定controller變數:BusinessLog(userId=0.203277605749153, type=integrate, message=null, phone=null)
[2017-12-01T11:33:18,882] | INFO | com.aaa.service.impl.BaseServiceImpl.getBatchList(BaseServiceImpl.java:39) | http-nio-8080-exec-3 訪問service:BusinessLog(userId=0.203277605749153, type=integrate, message=null, phone=null)
[2017-12-01T11:33:18,882] | INFO | com.aaa.service.impl.BaseServiceImpl.getBatchList(BaseServiceImpl.java:43) | http-nio-8080-exec-3 設定service變數:BusinessLog(userId=0.203277605749153, type=integrate, message=null, phone=18600732726)
[2017-12-01T11:33:18,925] | INFO | com.aaa.oplog.OpLogAspect.logEvent(OpLogAspect.java:75) | http-nio-8080-exec-3  EventParameter{source='com.aaa.api.rest.IntegrateController', level='INFO', name='獲取整合請求列表', desc='', arguments='ListBatchRequest(batchId=null, batchNo=null, state=null, createPerson=null, updateTime=null, createTime=null, type=null, pageNum=1, pageSize=10)', message='', method='getIntegrateList', url='http://localhost:8080/api/online-tickets/v1/integrate'}
[2017-12-01T11:33:18,931] | INFO | com.aaa.interceptor.BusinessLogInterceptor.afterCompletion(BusinessLogInterceptor.java:39) | http-nio-8080-exec-3 訪問結束:BusinessLog(userId=0.203277605749153, type=integrate, message=null, phone=18600732726)
[2017-12-01T11:33:18,931] | INFO | com.aaa.interceptor.BusinessLogInterceptor.afterCompletion(BusinessLogInterceptor.java:41) | http-nio-8080-exec-3  清理結束:BusinessLog(userId=null, type=null, message=null, phone=null)

發現沒有問題，每次訪問的資料可以在整個請求區間內儲存，在訪問結束後，被清理掉，不會影響其它請求。

相關推薦

通過ThreadLocal和HandlerInterceptor實現java後臺業務埋點日誌功能

目前公司的方案是用mdc來實現一個請求的業務資料埋點記錄，但是mdc是map方式，需要手動設定key，而且每次都要手動clear，一是不方便管理，再者如果忘記clear會造成業務埋點資料混亂。所以有了想要把埋點資料欄位統一封裝的想法，這樣方便維護，後面如果修改，

通過jna簡單實現java後臺監聽鍵盤觸發修改系統時間

      由於玩某網遊需要在出副本時等一分鐘，而修改系統時間+1分鐘可以提前出副本，避免麻煩寫了個java後臺監聽鍵盤觸發修改系統時間的指令碼，當按下設定好的鍵盤組合即呼叫修改函式。     修改時間的函式程式碼如下（呼叫CMD命令）：

JAVA通過Session和Cookie實現網站自動登入的技術

 本方案為我這個站點當前使用的，能用，但不保證是最先進的。 原文：http://www.java2000.net/p1010第一步，登陸的時候一旦選擇了[自動登入]的選項，則需要在登陸成功後，附加下面的程式碼 應為一般網站都提供儲存使用者名稱的功能，所以我把這個寫到了外面。

HttpURLConnection實現java後臺上傳檔案和其他引數

最近在對接某第三方視訊服務商的介面，使用java在後臺呼叫他們的介面。在對接設定封面時遇到一個問題，他們需要對個引數，且有一個引數的型別為file。苦尋半天，果。遂記錄如下。 import java.io.DataOutputStream; import j

java實現shell命令--小程式（通過Runtime和Process實現）

先上程式碼（功能是要列出目錄）： package testProcess; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.LineNumberReader; p

.NET 通過 Autofac 和 DynamicProxy 實現AOP

調用方法 console mage 技術分享 攔截器 抽象 select 攔截 bsp 　　什麽是AOP？引用百度百科：AOP為Aspect Oriented Programming的縮寫，意為：面向切面編程，通過預編譯方式和運行期動態代理實現程序功能的統一維護的一種技術。

通過MSTP和VRRP實現網關備份，以及負載均衡

TP 輸入 watermark ng- 創建 負載 ip add 網絡 現實生活 一、網絡拓撲圖：二、環境搭建：三層交換機、二層交換機、各兩臺，路由器一臺，PC機三臺。三、實驗原理：現實生活中，為了資源的充分利用，往往備份的交換機或者路由器，不只單單充當備份的角色。而是也要

通過pthread_mutex_lock和pthread_cond_wait實現生產消費模式,並且生產一次消費一次

#include <stdio.h> #include <pthread.h> /* 生產消費模式 1.生產pdoduct生產一次然後consumer消費一次 */ pthread_mu

通過FileReader和FileWriter實現複製檔案的方法。

p.p1 { margin: 0.0px 0.0px 0.0px 0.0px; font: 11.0px Monaco } p.p2 { margin: 0.0px 0.0px 0.0px 0.0px; font: 11.0px Monaco; min-height: 15.0px } p.p3 { marg

通過COM元件方式實現java呼叫C#寫的DLL檔案 轉

    最近一段時間單位在做一個Web專案，工程師用JAVA語言，需要公用人員資訊，統一使用者名稱和密碼，原有的平臺中是用C#語言開發的，在網上查詢解決方法，通過JAVA呼叫C#的DLL檔案實現。網上資料很多，自己整合總結了一下，做個備忘。 一、C#寫com元件 開發環境

通過transpose和flip實現影象旋轉90/180/270度

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！        

Lucene筆記37-Lucene如何通過NRTManager和SearchManager實現近實時搜尋

一、思路分析 如何實現近實時搜尋呢？每次更新完索引都commit？那恐怕太浪費資源了，當資料量非常龐大的時候，幾乎不可能。這裡有兩種方案。 使用SearchManager來管理IndexSearcher物件，當發現索引更新之後，searchManager會呼叫maybeReopen

springboot-通過註解和aop實現分散式鎖

一、原因 1、在分散式專案中，使用者觸發插入、更新等操作，我們只需要其中一個服務執行，如果不加分散式鎖，後果很嚴重 二、方法 1、分佈鎖一般通過redis實現，主要通過setnx函式向redis儲存一個key，value等於儲存時的時間戳，並設定過期時間，然後返回true； 2、

c語言通過cond和mutex實現一個高效能執行緒池

首先說明一下這篇文章其實和我另一篇文章很像，只是另一篇只有一個執行緒，只要講述的是cond和mutex的使用，上面是基於c++實現的，封裝的稍微好一些，路徑： https://blog.csdn.net/FlayHigherGT/article/details/83830956 而下面是

ajax跨域請求簡單實現Java後臺

因為官網有一個合作加盟的功能，需要一個表單錄入，但是官網除了這個功能，都是靜態頁面，所以就準備寫一個ajax跨域，儲存到之前公司專案的後臺管理系統去，第一次用ajax跨域，網上很多參考。這也是我的第一篇博文，準備以後養成這個習慣，以備後期參考。。。。。 通過自己N久找程式碼

通過nsis和duilib實現自定義安裝介面

nsis用於實現安裝邏輯，duilib用於實現UI介面 通過nsis呼叫duilib生成的dll庫來實現。現擷取部分duilib程式碼用於展示如何使用duilib編寫程式碼。 cpp檔案如下： #include <windows.h> #i

通用匯入工具類，通過poi和反射實現

將檔案從前端上傳到後端，就不說了，我的文章裡面有上傳的,剛開始寫，如果有問題歡迎批評指正首先，先說一下用法，因為之前每增加一個匯入模板就要單獨開發，比較浪費時間，所以單獨搞了個通用類，引數有待解析檔案，輸出的類，欄位陣列，開始行數，然後返回一個List1.我們已經獲取到這個檔

java後臺對微信支付功能的實現

第一次寫微信小程式後臺介面，卻發現微信小程式有太多太多坑了。所以這裡進行一個記錄，防止忘記。（現在補更一下，一定要和前端開發人員溝通好返回值啊！！最後一步給前端paySign值，結果前端老是報錯requestPayment:fail parameter error: para

django學習——通過HttpResponseRedirect 和 reverse實現重定向

用django開發web應用, 經常會遇到從一箇舊的url轉向一個新的url，也就是重定向。 HttpResponseRedirect：建構函式的第一個引數是必要的 — 用來重定向的地址。這些能夠是完全特定的URL地址（比如，’http://www.yahoo

通過WebSocket和STOMP實現瀏覽器和伺服器的訊息通訊

非同步訊息非同步訊息有兩個重要的概念，訊息代理（broker）和目的地（destination）。訊息代理：當一個應用傳送訊息時，需要制定傳送的目的地，然後將訊息交給訊息代理（類似郵局），訊息代理會確保訊息傳送到指定的目的地。目的地：不同的訊息系統有不同的訊息路由模式，但是有