日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Spring Boot 記錄請求響應(yīng)日志的常用手段

某些業(yè)務(wù)需求需要追蹤我們的接口訪問情況，也就是把請求和響應(yīng)記錄下來?；镜挠涗浘S度包含了請求入?yún)?路徑query參數(shù)，請求體)、請求路徑(uri)、請求方法(method)、請求頭(headers)以及響應(yīng)狀態(tài)、響應(yīng)頭、甚至包含了敏感的響應(yīng)體等等。今天總結(jié)了幾種方法，你可以按需選擇。

成都創(chuàng)新互聯(lián)電話聯(lián)系：18982081108，為您提供成都網(wǎng)站建設(shè)網(wǎng)頁設(shè)計及定制高端網(wǎng)站建設(shè)服務(wù)，成都創(chuàng)新互聯(lián)網(wǎng)頁制作領(lǐng)域10多年，包括成都PE包裝袋等多個方面擁有多年的網(wǎng)站營銷經(jīng)驗(yàn)，選擇成都創(chuàng)新互聯(lián)，為網(wǎng)站錦上添花。

請求追蹤的實(shí)現(xiàn)方式

網(wǎng)關(guān)層

很多網(wǎng)關(guān)設(shè)施都具有httptrace的功能，可以幫助我們集中記錄請求流量的情況。Orange、Kong、Apache Apisix這些基于Nginx的網(wǎng)關(guān)都具有該能力，就連Nginx本身也提供了記錄httptrace日志的能力。

優(yōu)點(diǎn)是可以集中的管理httptrace日志，免開發(fā);缺點(diǎn)是技術(shù)要求高，需要配套的分發(fā)、存儲、查詢的設(shè)施。

Spring Boot Actuator

在Spring Boot中，其實(shí)提供了簡單的追蹤功能。你只需要集成：

 
 
 
 
      
  
  
  
  1.  
    2.   
  
  
  
  2.     org.springframework.boot 
    3.   
  
  
  
  3.     spring-boot-starter-actuator 
    4.   
  
  
  
  4.  
    5.

開啟/actuator/httptrace：

 
 
 
 
      
  
  
  
  1. management: 
    2.   
  
  
  
  2.   endpoints: 
    3.   
  
  
  
  3.     web: 
    4.   
  
  
  
  4.       exposure: 
    5.   
  
  
  
  5.         include: 'httptrace' 
    6.

就可以通過http://server:port/actuator/httptrace獲取最近的Http請求信息了。

不過在最新的版本中可能需要顯式的聲明這些追蹤信息的存儲方式，也就是實(shí)現(xiàn)HttpTraceRepository接口并注入Spring IoC。

例如放在內(nèi)存中并限制為最近的100條(不推薦生產(chǎn)使用)：

 
 
 
 
      
  
  
  
  1. @Bean 
    2.   
  
  
  
  2. public HttpTraceRepository httpTraceRepository(){ 
    3.   
  
  
  
  3.     return new InMemoryHttpTraceRepository(); 
    4.   
  
  
  
  4. } 
    5.

追蹤日志以json格式呈現(xiàn)：

Spring Boot Actuator記錄的httptrace

記錄的維度不多，當(dāng)然如果夠用的話可以試試。

優(yōu)點(diǎn)在于集成起來簡單，幾乎免除開發(fā);缺點(diǎn)在于記錄的維度不多，而且需要搭建緩沖消費(fèi)這些日志信息的設(shè)施。

CommonsRequestLoggingFilter

Spring Web模塊還提供了一個過濾器CommonsRequestLoggingFilter，它可以對請求的細(xì)節(jié)進(jìn)行日志輸出。配置起來也比較簡單：

 
 
 
 
      
  
  
  
  1. @Bean 
    2.   
  
  
  
  2. CommonsRequestLoggingFilter  loggingFilter(){ 
    3.   
  
  
  
  3.     CommonsRequestLoggingFilter loggingFilter = new CommonsRequestLoggingFilter(); 
    4.   
  
  
  
  4.     // 記錄 客戶端 IP信息 
    5.   
  
  
  
  5.     loggingFilter.setIncludeClientInfo(true); 
    6.   
  
  
  
  6.     // 記錄請求頭 
    7.   
  
  
  
  7.     loggingFilter.setIncludeHeaders(true); 
    8.   
  
  
  
  8.     // 如果記錄請求頭的話，可以指定哪些記錄，哪些不記錄 
    9.   
  
  
  
  9.     // loggingFilter.setHeaderPredicate(); 
    10.   
  
  
  
  10.     // 記錄 請求體  特別是POST請求的body參數(shù) 
    11.   
  
  
  
  11.     loggingFilter.setIncludePayload(true); 
    12.   
  
  
  
  12.     // 請求體的大小限制 默認(rèn)50 
    13.   
  
  
  
  13.     loggingFilter.setMaxPayloadLength(10000); 
    14.   
  
  
  
  14.     //記錄請求路徑中的query參數(shù)  
    15.   
  
  
  
  15.     loggingFilter.setIncludeQueryString(true); 
    16.   
  
  
  
  16.     return loggingFilter; 
    17.   
  
  
  
  17. } 
    18.

而且必須開啟對CommonsRequestLoggingFilter的debug日志：

 
 
 
 
      
  
  
  
  1. logging: 
    2.   
  
  
  
  2.   level: 
    3.   
  
  
  
  3.     org: 
    4.   
  
  
  
  4.       springframework: 
    5.   
  
  
  
  5.         web: 
    6.   
  
  
  
  6.           filter: 
    7.   
  
  
  
  7.             CommonsRequestLoggingFilter: debug 
    8.

一次請求會輸出兩次日志，一次是在第一次經(jīng)過過濾器前;一次是完成過濾器鏈后。

CommonsRequestLoggingFilter記錄請求日志

這里多說一句其實(shí)可以改造成輸出json格式的。

優(yōu)點(diǎn)是靈活配置、而且對請求追蹤的維度全面，缺點(diǎn)是只記錄請求而不記錄響應(yīng)。

ResponseBodyAdvice

Spring Boot統(tǒng)一返回體其實(shí)也能記錄，需要自行實(shí)現(xiàn)。這里借鑒了CommonsRequestLoggingFilter解析請求的方法。響應(yīng)體也可以獲取了，不過響應(yīng)頭和狀態(tài)因?yàn)樯芷谶€不清楚，這里獲取還不清楚是否合適，不過這是一個思路。

 
 
 
 
      
  
  
  
  1. /** 
    2.   
  
  
  
  2.  * @author felord.cn 
    3.   
  
  
  
  3.  * @since 1.0.8.RELEASE 
    4.   
  
  
  
  4.  */ 
    5.   
  
  
  
  5. @Slf4j 
    6.   
  
  
  
  6. @RestControllerAdvice(basePackages = {"cn.felord.logging"}) 
    7.   
  
  
  
  7. public class RestBodyAdvice implements ResponseBodyAdvice {   
  
  
  
  8.     private static final int DEFAULT_MAX_PAYLOAD_LENGTH = 10000; 
    9.   
  
  
  
  9.     public static final String REQUEST_MESSAGE_PREFIX = "Request ["; 
    10.   
  
  
  
  10.     public static final String REQUEST_MESSAGE_SUFFIX = "]"; 
    11.   
  
  
  
  11.     private ObjectMapper objectMapper = new ObjectMapper(); 
    12.   
  
  
  
  12.  
    13.   
  
  
  
  13.     @Override 
    14.   
  
  
  
  14.     public boolean supports(MethodParameter returnType, Class> converterType) { 
    15.   
  
  
  
  15.         return true; 
    16.   
  
  
  
  16.     } 
    17.   
  
  
  
  17.  
    18.   
  
  
  
  18.     @SneakyThrows 
    19.   
  
  
  
  19.     @Override 
    20.   
  
  
  
  20.     public Object beforeBodyWrite(Object body, 
    21.   
  
  
  
  21.                                   MethodParameter returnType, 
    22.   
  
  
  
  22.                                   MediaType selectedContentType, 
    23.   
  
  
  
  23.                                   Class> selectedConverterType, 
    24.   
  
  
  
  24.                                   ServerHttpRequest request, 
    25.   
  
  
  
  25.                                   ServerHttpResponse response) { 
    26.   
  
  
  
  26.  
    27.   
  
  
  
  27.         ServletServerHttpRequest servletServerHttpRequest = (ServletServerHttpRequest) request; 
    28.   
  
  
  
  28.  
    29.   
  
  
  
  29.         log.debug(createRequestMessage(servletServerHttpRequest.getServletRequest(), REQUEST_MESSAGE_PREFIX, REQUEST_MESSAGE_SUFFIX)); 
    30.   
  
  
  
  30.         Rest objectRest;   
  
  
  
  31.         if (body == null) { 
    32.   
  
  
  
  32.             objectRest = RestBody.okData(Collections.emptyMap()); 
    33.   
  
  
  
  33.         } else if (Rest.class.isAssignableFrom(body.getClass())) { 
    34.   
  
  
  
  34.             objectRest = (Rest) body;   
  
  
  
  35.         } 
    36.   
  
  
  
  36.         else if (checkPrimitive(body)) { 
    37.   
  
  
  
  37.             return RestBody.okData(Collections.singletonMap("result", body)); 
    38.   
  
  
  
  38.         }else { 
    39.   
  
  
  
  39.             objectRest = RestBody.okData(body); 
    40.   
  
  
  
  40.         } 
    41.   
  
  
  
  41.         log.debug("Response Body ["+ objectMapper.writeValueAsString(objectRest) +"]"); 
    42.   
  
  
  
  42.         return objectRest; 
    43.   
  
  
  
  43.     } 
    44.   
  
  
  
  44.  
    45.   
  
  
  
  45.  
    46.   
  
  
  
  46.     private boolean checkPrimitive(Object body) { 
    47.   
  
  
  
  47.         Class clazz = body.getClass(); 
    48.   
  
  
  
  48.         return clazz.isPrimitive() 
    49.   
  
  
  
  49.                 || clazz.isArray() 
    50.   
  
  
  
  50.                 || Collection.class.isAssignableFrom(clazz) 
    51.   
  
  
  
  51.                 || body instanceof Number 
    52.   
  
  
  
  52.                 || body instanceof Boolean 
    53.   
  
  
  
  53.                 || body instanceof Character 
    54.   
  
  
  
  54.                 || body instanceof String; 
    55.   
  
  
  
  55.     } 
    56.   
  
  
  
  56.  
    57.   
  
  
  
  57.  
    58.   
  
  
  
  58.     protected String createRequestMessage(HttpServletRequest request, String prefix, String suffix) { 
    59.   
  
  
  
  59.         StringBuilder msg = new StringBuilder(); 
    60.   
  
  
  
  60.         msg.append(prefix); 
    61.   
  
  
  
  61.         msg.append(request.getMethod()).append(" "); 
    62.   
  
  
  
  62.         msg.append(request.getRequestURI()); 
    63.   
  
  
  
  63.  
    64.   
  
  
  
  64.  
    65.   
  
  
  
  65.         String queryString = request.getQueryString(); 
    66.   
  
  
  
  66.         if (queryString != null) { 
    67.   
  
  
  
  67.             msg.append('?').append(queryString); 
    68.   
  
  
  
  68.         } 
    69.   
  
  
  
  69.  
    70.   
  
  
  
  70.  
    71.   
  
  
  
  71.         String client = request.getRemoteAddr(); 
    72.   
  
  
  
  72.         if (StringUtils.hasLength(client)) { 
    73.   
  
  
  
  73.             msg.append(", client=").append(client); 
    74.   
  
  
  
  74.         } 
    75.   
  
  
  
  75.         HttpSession session = request.getSession(false); 
    76.   
  
  
  
  76.         if (session != null) { 
    77.   
  
  
  
  77.             msg.append(", session=").append(session.getId()); 
    78.   
  
  
  
  78.         } 
    79.   
  
  
  
  79.         String user = request.getRemoteUser(); 
    80.   
  
  
  
  80.         if (user != null) { 
    81.   
  
  
  
  81.             msg.append(", user=").append(user); 
    82.   
  
  
  
  82.         } 
    83.   
  
  
  
  83.  
    84.   
  
  
  
  84.         HttpHeaders headers = new ServletServerHttpRequest(request).getHeaders(); 
    85.   
  
  
  
  85.         msg.append(", headers=").append(headers); 
    86.   
  
  
  
  86.  
    87.   
  
  
  
  87.         String payload = getMessagePayload(request); 
    88.   
  
  
  
  88.         if (payload != null) { 
    89.   
  
  
  
  89.             msg.append(", payload=").append(payload); 
    90.   
  
  
  
  90.         } 
    91.   
  
  
  
  91.  
    92.   
  
  
  
  92.         msg.append(suffix); 
    93.   
  
  
  
  93.         return msg.toString(); 
    94.   
  
  
  
  94.     } 
    95.   
  
  
  
  95.  
    96.   
  
  
  
  96.     protected String getMessagePayload(HttpServletRequest request) { 
    97.   
  
  
  
  97.         ContentCachingRequestWrapper wrapper = 
    98.   
  
  
  
  98.                 WebUtils.getNativeRequest(request, ContentCachingRequestWrapper.class); 
    99.   
  
  
  
  99.         if (wrapper != null) { 
    100.   
  
  
  
  100.             byte[] buf = wrapper.getContentAsByteArray(); 
    101.   
  
  
  
  101.             if (buf.length > 0) { 
    102.   
  
  
  
  102.                 int length = Math.min(buf.length, DEFAULT_MAX_PAYLOAD_LENGTH); 
    103.   
  
  
  
  103.                 try { 
    104.   
  
  
  
  104.                     return new String(buf, 0, length, wrapper.getCharacterEncoding()); 
    105.   
  
  
  
  105.                 } catch (UnsupportedEncodingException ex) { 
    106.   
  
  
  
  106.                     return "[unknown]"; 
    107.   
  
  
  
  107.                 } 
    108.   
  
  
  
  108.             } 
    109.   
  
  
  
  109.         } 
    110.   
  
  
  
  110.         return null; 
    111.   
  
  
  
  111.     } 
    112.   
  
  
  
  112. } 
    113.  
 
 

    別忘記配置ResponseBodyAdvice的logging級別為DEBUG。
    logstash-logback-encoder
    這個是logstash的logback編碼器，可以結(jié)構(gòu)化輸出httptrace為json。引入：
     
 
 
 
        
  
  
  
    1.  
      2.   
  
  
  
    2.     net.logstash.logback 
      3.   
  
  
  
    3.     logstash-logback-encoder 
      4.   
  
  
  
    4.     6.6 
      5.   
  
  
  
    5.  
      6.  
 
 

    配置logback的ConsoleAppender為LogstashEncoder:
     
 
 
 
        
  
  
  
    1.  
      2.   
  
  
  
    2.      
      3.   
  
  
  
    3.          
      4.   
  
  
  
    4.      
      5.   
  
  
  
    5.      
      6.   
  
  
  
    6.          
      7.   
  
  
  
    7.      
      8.   
  
  
  
    8.  
      9.  
 
 

    然后同樣實(shí)現(xiàn)一個解析的Filter:
     
 
 
 
        
  
  
  
    1. import org.slf4j.Logger; 
      2.   
  
  
  
    2. import org.slf4j.LoggerFactory; 
      3.   
  
  
  
    3. import org.slf4j.MDC; 
      4.   
  
  
  
    4. import org.springframework.core.annotation.Order; 
      5.   
  
  
  
    5. import org.springframework.stereotype.Component; 
      6.   
  
  
  
    6.  
      7.   
  
  
  
    7. import javax.servlet.*; 
      8.   
  
  
  
    8. import javax.servlet.http.HttpServletRequest; 
      9.   
  
  
  
    9. import javax.servlet.http.HttpServletResponse; 
      10.   
  
  
  
    10. import java.io.IOException; 
      11.   
  
  
  
    11. import java.util.UUID; 
      12.   
  
  
  
    12.  
      13.   
  
  
  
    13. /** 
      14.   
  
  
  
    14.  * @author felord.cn 
      15.   
  
  
  
    15.  * @since 1.0.8.RELEASE 
      16.   
  
  
  
    16.  */ 
      17.   
  
  
  
    17. @Order(1) 
      18.   
  
  
  
    18. @Component 
      19.   
  
  
  
    19. public class MDCFilter implements Filter { 
      20.   
  
  
  
    20.  
      21.   
  
  
  
    21.     private final Logger LOGGER = LoggerFactory.getLogger(MDCFilter.class); 
      22.   
  
  
  
    22.     private final String X_REQUEST_ID = "X-Request-ID"; 
      23.   
  
  
  
    23.  
      24.   
  
  
  
    24.     @Override 
      25.   
  
  
  
    25.     public void doFilter(ServletRequest request, 
      26.   
  
  
  
    26.                          ServletResponse response, 
      27.   
  
  
  
    27.                          FilterChain chain) throws IOException, ServletException { 
      28.   
  
  
  
    28.         HttpServletRequest req = (HttpServletRequest) request; 
      29.   
  
  
  
    29.         HttpServletResponse res = (HttpServletResponse) response; 
      30.   
  
  
  
    30.         try { 
      31.   
  
  
  
    31.             addXRequestId(req); 
      32.   
  
  
  
    32.             LOGGER.info("path: {}, method: {}, query {}", 
      33.   
  
  
  
    33.                     req.getRequestURI(), req.getMethod(), req.getQueryString()); 
      34.   
  
  
  
    34.             res.setHeader(X_REQUEST_ID, MDC.get(X_REQUEST_ID)); 
      35.   
  
  
  
    35.             chain.doFilter(request, response); 
      36.   
  
  
  
    36.         } finally { 
      37.   
  
  
  
    37.             LOGGER.info("statusCode {}, path: {}, method: {}, query {}", 
      38.   
  
  
  
    38.                     res.getStatus(), req.getRequestURI(), req.getMethod(), req.getQueryString()); 
      39.   
  
  
  
    39.             MDC.clear(); 
      40.   
  
  
  
    40.         } 
      41.   
  
  
  
    41.     } 
      42.   
  
  
  
    42.  
      43.   
  
  
  
    43.     private void addXRequestId(HttpServletRequest request) { 
      44.   
  
  
  
    44.         String xRequestId = request.getHeader(X_REQUEST_ID); 
      45.   
  
  
  
    45.         if (xRequestId == null) { 
      46.   
  
  
  
    46.             MDC.put(X_REQUEST_ID, UUID.randomUUID().toString()); 
      47.   
  
  
  
    47.         } else { 
      48.   
  
  
  
    48.             MDC.put(X_REQUEST_ID, xRequestId); 
      49.   
  
  
  
    49.         } 
      50.   
  
  
  
    50.     } 
      51.   
  
  
  
    51.  
      52.   
  
  
  
    52. } 
      53.  
 
 

    這里解析方式其實(shí)還可以更加精細(xì)一些。
    然后所有的日志都可以結(jié)構(gòu)化為json了：
     
 
 
 
        
  
  
  
    1. {"@timestamp":"2021-08-10T23:48:51.322+08:00","@version":"1","message":"statusCode 200, path: /log/get, method: GET, query foo=xxx&bar=ooo","logger_name":"cn.felord.logging.MDCFilter","thread_name":"http-nio-8080-exec-1","level":"INFO","level_value":20000,"X-Request-ID":"7c0db56c-b1f2-4d85-ad9a-7ead67660f96"} 
      2.  
 
 

    總結(jié)
    今天介紹了不少記錄追蹤接口請求響應(yīng)的方法，總有一款適合你。
    本文轉(zhuǎn)載自微信公眾號「碼農(nóng)小胖哥」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請聯(lián)系碼農(nóng)小胖哥公眾號。
                                                    
    
                                                網(wǎng)頁名稱：Spring Boot 記錄請求響應(yīng)日志的常用手段                                                
    
                                                瀏覽地址：http://www.5511xx.com/article/dpossip.html