springboot filter實(shí)現(xiàn)請(qǐng)求響應(yīng)全鏈路攔截
一、為什么你需要這個(gè)過(guò)濾器??
日志痛點(diǎn):
- 請(qǐng)求參數(shù)散落在各處?
- 響應(yīng)數(shù)據(jù)無(wú)法統(tǒng)一記錄?
- 日志與業(yè)務(wù)代碼嚴(yán)重耦合?
??解決方案??: 一個(gè)Filter同時(shí)攔截請(qǐng)求和響應(yīng),實(shí)現(xiàn)??日志采集自動(dòng)化??!
??二、核心實(shí)現(xiàn):一個(gè)Filter搞定雙向數(shù)據(jù)流??
過(guò)濾器設(shè)計(jì)亮點(diǎn)??
- 請(qǐng)求參數(shù)捕獲??:GET/POST參數(shù)統(tǒng)一解析
- 響應(yīng)結(jié)果截取??:支持JSON/XML等文本響應(yīng)
- 零代碼侵入??:不修改業(yè)務(wù)代碼即可植入監(jiān)控
- ??JDK1.8完美兼容??:無(wú)任何新特性依賴(lài)
??三、完整代碼實(shí)現(xiàn)??
??1. 過(guò)濾器核心代碼(可直接復(fù)制)??
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 { // 包裝請(qǐng)求響應(yīng)對(duì)象 ContentCachingRequestWrapper wrappedRequest = new ContentCachingRequestWrapper(request); ContentCachingResponseWrapper wrappedResponse = new ContentCachingResponseWrapper(response); try { // 執(zhí)行后續(xù)過(guò)濾器鏈 filterChain.doFilter(wrappedRequest, wrappedResponse); // 記錄日志(核心邏輯) logRequest(wrappedRequest); logResponse(wrappedResponse); } finally { // 必須執(zhí)行響應(yīng)回寫(xiě) wrappedResponse.copyBodyToResponse(); } } // 請(qǐng)求日志方法 private void logRequest(ContentCachingRequestWrapper request) { String method = request.getMethod(); String url = request.getRequestURL().toString(); String params = getRequestParams(request); System.out.printf("[請(qǐng)求] %s %s | 參數(shù)=%s%n", method, url, params); } // 響應(yīng)日志方法 private void logResponse(ContentCachingResponseWrapper response) throws IOException { int status = response.getStatus(); String body = getResponseBody(response); System.out.printf("[響應(yīng)] 狀態(tài)碼=%d | 內(nèi)容=%s%n", status, body); } // 獲取請(qǐng)求參數(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ù)解析失敗]"; } } // 獲取響應(yīng)內(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() {} }
四、過(guò)濾器添加三步走??
??1. 添加依賴(lài)(Maven配置)??
<!-- 核心包裝類(lèi) --> <dependency> <groupId>org.apache.tomcat</groupId> <artifactId>tomcat-catalina</artifactId> <version>9.0.65</version> </dependency>
??2. web.xml配置??(傳統(tǒng)項(xià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> <!-- 攔截所有請(qǐng)求 --> <dispatcher>REQUEST</dispatcher> </filter-mapping>
????3. Spring Boot集成??(新項(xiàng)目推薦)
@Bean public FilterRegistrationBean<RequestResponseLogFilter> logFilter(){ FilterRegistrationBean<RequestResponseLogFilter> registrationBean = new FilterRegistrationBean<>(); registrationBean.setFilter(new RequestResponseLogFilter()); registrationBean.addUrlPatterns("/*"); return registrationBean; }
五、運(yùn)行效果演示??
[REQUEST] POST http://api/user/login | 參數(shù)=username=admin&password=123456 | 時(shí)間=Wed Oct 05 14:30:00 CST 2023
[RESPONSE] 狀態(tài)碼=200 | 響應(yīng)內(nèi)容={"code":0,"msg":"登錄成功"} | 耗時(shí)=120ms
六、必須注意的6大事項(xiàng)??
1.內(nèi)存溢出風(fēng)險(xiǎn)??
攔截大文件上傳時(shí)(>1MB)會(huì)占用大量?jī)?nèi)存
解決方案:限制緩存大小
// 在構(gòu)造方法中設(shè)置最大緩存 new ContentCachingRequestWrapper(request, 1024 * 1024); // 1MB
2.??編碼兼容性問(wèn)題??
請(qǐng)求參數(shù)亂碼常因缺少編碼設(shè)置導(dǎo)致
強(qiáng)制設(shè)置編碼(在Filter頭部添加)
request.setCharacterEncoding("UTF-8"); response.setCharacterEncoding("UTF-8");
3.??響應(yīng)流二次讀取??
原始響應(yīng)流只能讀取一次,必須使用包裝類(lèi)
錯(cuò)誤寫(xiě)法:直接使用原始response.getWriter()
4.敏感信息泄露??
密碼等字段需過(guò)濾(正則替換示例)
params.replaceAll("password=\\w+", "password=?**?*");
5.性能損耗控制??
高并發(fā)場(chǎng)景建議異步記錄日志
CompletableFuture.runAsync(() -> log.info(logContent));
6.HTTPS支持??
確保Tomcat配置正確:
<Connector port="8443" protocol="org.apache.coyote.http11.Http11NioProtocol" SSLEnabled="true" scheme="https" secure="true"/>
七、進(jìn)階玩法??
組合使用??:
搭配Spring AOP實(shí)現(xiàn)方法級(jí)日志
結(jié)合Redis實(shí)現(xiàn)請(qǐng)求限流
數(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é)??
一個(gè)優(yōu)秀的Filter就像「數(shù)字監(jiān)控?cái)z像頭」,默默記錄系統(tǒng)運(yùn)行軌跡。通過(guò)本文的方案,你可以:
- 統(tǒng)一管理所有請(qǐng)求響應(yīng)日志
- 零成本實(shí)現(xiàn)全鏈路追蹤
- 靈活擴(kuò)展監(jiān)控維度
到此這篇關(guān)于springboot filter實(shí)現(xiàn)請(qǐng)求響應(yīng)全鏈路攔截的文章就介紹到這了,更多相關(guān)springboot filter請(qǐng)求攔截內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java簡(jiǎn)單統(tǒng)計(jì)字符串中漢字,英文字母及數(shù)字?jǐn)?shù)量的方法
這篇文章主要介紹了Java簡(jiǎn)單統(tǒng)計(jì)字符串中漢字,英文字母及數(shù)字?jǐn)?shù)量的方法,涉及java針對(duì)字符串的遍歷、編碼轉(zhuǎn)換、判斷等相關(guān)操作技巧,需要的朋友可以參考下2017-06-06Java實(shí)現(xiàn)線程按序交替執(zhí)行的方法詳解
這篇文章主要為大家詳細(xì)介紹了Java如何實(shí)現(xiàn)線程按序交替執(zhí)行,文中的示例代碼講解詳細(xì),對(duì)我們了解線程有一定幫助,需要的可以參考一下2022-10-10Java并發(fā)讀寫(xiě)鎖ReentrantReadWriteLock 使用場(chǎng)景
ReentrantReadWriteLock是Java中一種高效的讀寫(xiě)鎖,適用于讀多寫(xiě)少的并發(fā)場(chǎng)景,它通過(guò)允許多個(gè)線程同時(shí)讀取,但在寫(xiě)入時(shí)限制為單線程訪問(wèn),從而提高了程序的并發(fā)性和性能,本文給大家介紹Java并發(fā)讀寫(xiě)鎖ReentrantReadWriteLock 使用場(chǎng)景,感興趣的朋友跟隨小編一起看看吧2024-10-10基于Java方式實(shí)現(xiàn)數(shù)據(jù)同步
這篇文章主要為大家詳細(xì)介紹了基于Java方式實(shí)現(xiàn)數(shù)據(jù)同步,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-08-08Java無(wú)界阻塞隊(duì)列DelayQueue詳細(xì)解析
這篇文章主要介紹了Java無(wú)界阻塞隊(duì)列DelayQueue詳細(xì)解析,DelayQueue是一個(gè)支持時(shí)延獲取元素的無(wú)界阻塞隊(duì)列,隊(duì)列使用PriorityQueue來(lái)實(shí)現(xiàn),隊(duì)列中的元素必須實(shí)現(xiàn)Delayed接口,在創(chuàng)建元素時(shí)可以指定多久才能從隊(duì)列中獲取當(dāng)前元素,需要的朋友可以參考下2023-12-12深入探究SpringBoot可以同時(shí)處理多少請(qǐng)求
SpringBoot是一款非常流行的Java后端框架,它可以幫助開(kāi)發(fā)人員快速構(gòu)建高效的Web應(yīng)用程序,但是,許多人對(duì)于SpringBoot能夠同時(shí)處理多少請(qǐng)求的疑問(wèn)仍然存在,在本篇文章中,我們將深入探討這個(gè)問(wèn)題,需要的朋友可以參考下2023-07-07Mybatis中一條SQL使用兩個(gè)foreach的問(wèn)題及解決
這篇文章主要介紹了Mybatis中一條SQL使用兩個(gè)foreach的問(wèn)題及解決,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-02-02