springboot filter實現(xiàn)請求響應全鏈路攔截

更新時間：2025年04月09日 15:29:39 作者：浪浪山老周

這篇文章主要為大家詳細介紹了SpringBoot如何結(jié)合Filter同時攔截請求和響應,從而實現(xiàn)??日志采集自動化,感興趣的小伙伴可以跟隨小編一起學習一下

一、為什么你需要這個過濾器？?

日志痛點：

請求參數(shù)散落在各處？
響應數(shù)據(jù)無法統(tǒng)一記錄？
日志與業(yè)務代碼嚴重耦合？

??解決方案??：一個Filter同時攔截請求和響應，實現(xiàn)??日志采集自動化??！

??二、核心實現(xiàn)：一個Filter搞定雙向數(shù)據(jù)流??

過濾器設計亮點??

請求參數(shù)捕獲??：GET/POST參數(shù)統(tǒng)一解析
響應結(jié)果截取??：支持JSON/XML等文本響應
零代碼侵入??：不修改業(yè)務代碼即可植入監(jiān)控
??JDK1.8完美兼容??：無任何新特性依賴

??三、完整代碼實現(xiàn)??

??1. 過濾器核心代碼（可直接復制）??

import org.springframework.web.filter.OncePerRequestFilter;
import javax.servlet.FilterChain;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

public class RequestResponseLogFilter extends OncePerRequestFilter {

    @Override
    protected void doFilterInternal(HttpServletRequest request, 
                                    HttpServletResponse response, 
                                    FilterChain filterChain)
            throws ServletException, IOException {
        
        // 包裝請求響應對象
        ContentCachingRequestWrapper wrappedRequest = 
            new ContentCachingRequestWrapper(request);
        ContentCachingResponseWrapper wrappedResponse = 
            new ContentCachingResponseWrapper(response);

        try {
            // 執(zhí)行后續(xù)過濾器鏈
            filterChain.doFilter(wrappedRequest, wrappedResponse);
            
            // 記錄日志（核心邏輯）
            logRequest(wrappedRequest);
            logResponse(wrappedResponse);
            
        } finally {
            // 必須執(zhí)行響應回寫
            wrappedResponse.copyBodyToResponse();
        }
    }

    // 請求日志方法
    private void logRequest(ContentCachingRequestWrapper request) {
        String method = request.getMethod();
        String url = request.getRequestURL().toString();
        String params = getRequestParams(request);
        
        System.out.printf("[請求] %s %s | 參數(shù)=%s%n", method, url, params);
    }

    // 響應日志方法
    private void logResponse(ContentCachingResponseWrapper response) throws IOException {
        int status = response.getStatus();
        String body = getResponseBody(response);
        
        System.out.printf("[響應] 狀態(tài)碼=%d | 內(nèi)容=%s%n", status, body);
    }

    
    // 獲取請求參數(shù)工具方法
    private String getRequestParams(ContentCachingRequestWrapper request) {
        try {
            if ("GET".equalsIgnoreCase(request.getMethod())) {
                return request.getQueryString();
            } else {
                byte[] body = request.getContentAsByteArray();
                return new String(body, request.getCharacterEncoding());
            }
        } catch (Exception e) {
            return "[參數(shù)解析失敗]";
        }
    }

    // 獲取響應內(nèi)容工具方法
    private String getResponseBody(ContentCachingResponseWrapper response) throws IOException {
        byte[] content = response.getContentAsByteArray();
        return new String(content, response.getCharacterEncoding());
    }

    @Override
    public void init(FilterConfig filterConfig) {}

    @Override
    public void destroy() {}
}

四、過濾器添加三步走??

??1. 添加依賴（Maven配置）??

<!-- 核心包裝類 -->
<dependency>
    <groupId>org.apache.tomcat</groupId>
    <artifactId>tomcat-catalina</artifactId>
    <version>9.0.65</version>
</dependency>

??2. web.xml配置??（傳統(tǒng)項目）

<filter>
    <filter-name>RequestResponseLogFilter</filter-name>
    <filter-class>com.example.RequestResponseLogFilter</filter-class>
</filter>

<filter-mapping>
    <filter-name>RequestResponseLogFilter</filter-name>
    <url-pattern>/*</url-pattern> <!-- 攔截所有請求 -->
    <dispatcher>REQUEST</dispatcher>
</filter-mapping>

????3. Spring Boot集成??（新項目推薦）

@Bean
public FilterRegistrationBean<RequestResponseLogFilter> logFilter(){
    FilterRegistrationBean<RequestResponseLogFilter> registrationBean = new FilterRegistrationBean<>();
    registrationBean.setFilter(new RequestResponseLogFilter());
    registrationBean.addUrlPatterns("/*");
    return registrationBean;
}

五、運行效果演示??

[REQUEST] POST http://api/user/login | 參數(shù)=username=admin&password=123456 | 時間=Wed Oct 05 14:30:00 CST 2023
[RESPONSE] 狀態(tài)碼=200 | 響應內(nèi)容={"code":0,"msg":"登錄成功"} | 耗時=120ms

六、必須注意的6大事項??

1.內(nèi)存溢出風險??

攔截大文件上傳時（>1MB）會占用大量內(nèi)存

解決方案：限制緩存大小

// 在構(gòu)造方法中設置最大緩存
new ContentCachingRequestWrapper(request, 1024 * 1024); // 1MB

2.??編碼兼容性問題??

請求參數(shù)亂碼常因缺少編碼設置導致

強制設置編碼（在Filter頭部添加）

request.setCharacterEncoding("UTF-8");
response.setCharacterEncoding("UTF-8");

3.??響應流二次讀取??

原始響應流只能讀取一次，必須使用包裝類

錯誤寫法：直接使用原始response.getWriter()

4.敏感信息泄露??

密碼等字段需過濾（正則替換示例）

params.replaceAll("password=\\w+", "password=?**?*");

5.性能損耗控制??

高并發(fā)場景建議異步記錄日志

CompletableFuture.runAsync(() -> log.info(logContent));

6.HTTPS支持??

確保Tomcat配置正確：

<Connector port="8443" protocol="org.apache.coyote.http11.Http11NioProtocol"
           SSLEnabled="true" scheme="https" secure="true"/>

七、進階玩法??

組合使用??：

搭配Spring AOP實現(xiàn)方法級日志

結(jié)合Redis實現(xiàn)請求限流

數(shù)據(jù)分析??：

-- 日志分析SQL示例
SELECT 
    request_uri, 
    COUNT(*) as total,
    AVG(response_time) as avg_time 
FROM access_log 
WHERE status >= 500 
GROUP BY request_uri;

總結(jié)??

一個優(yōu)秀的Filter就像「數(shù)字監(jiān)控攝像頭」，默默記錄系統(tǒng)運行軌跡。通過本文的方案，你可以：