springboot filter实现请求响应全链路拦截

 更新时间:2025年04月09日 15:29:39   作者:浪浪山老周  
这篇文章主要为大家详细介绍了SpringBoot如何结合Filter同时拦截请求和响应,从而实现​​日志采集自动化,感兴趣的小伙伴可以跟随小编一起学习一下

一、为什么你需要这个过滤器?​

日志痛点:

  • 请求参数散落在各处?
  • 响应数据无法统一记录?
  • 日志与业务代码严重耦合?

​​解决方案​​: 一个Filter同时拦截请求和响应,实现​​日志采集自动化​​!

​​二、核心实现:一个Filter搞定双向数据流​​

过滤器设计亮点​​

  • 请求参数捕获​​:GET/POST参数统一解析
  • 响应结果截取​​:支持JSON/XML等文本响应
  • 零代码侵入​​:不修改业务代码即可植入监控
  • ​​JDK1.8完美兼容​​:无任何新特性依赖

​​三、完整代码实现​​

​​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 {
            // 执行后续过滤器链
            filterChain.doFilter(wrappedRequest, wrappedResponse);
            
            // 记录日志(核心逻辑)
            logRequest(wrappedRequest);
            logResponse(wrappedResponse);
            
        } finally {
            // 必须执行响应回写
            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 | 参数=%s%n", method, url, params);
    }

    // 响应日志方法
    private void logResponse(ContentCachingResponseWrapper response) throws IOException {
        int status = response.getStatus();
        String body = getResponseBody(response);
        
        System.out.printf("[响应] 状态码=%d | 内容=%s%n", status, body);
    }

    
    // 获取请求参数工具方法
    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 "[参数解析失败]";
        }
    }

    // 获取响应内容工具方法
    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配置​​(传统项目)

<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 | 参数=username=admin&password=123456 | 时间=Wed Oct 05 14:30:00 CST 2023
[RESPONSE] 状态码=200 | 响应内容={"code":0,"msg":"登录成功"} | 耗时=120ms

六、必须注意的6大事项​​

1.内存溢出风险​​

拦截大文件上传时(>1MB)会占用大量内存

解决方案:限制缓存大小

// 在构造方法中设置最大缓存
new ContentCachingRequestWrapper(request, 1024 * 1024); // 1MB

2.​​编码兼容性问题​​

请求参数乱码常因缺少编码设置导致

强制设置编码(在Filter头部添加)

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

3.​​响应流二次读取​​

原始响应流只能读取一次,必须使用包装类

错误写法:直接使用原始response.getWriter()

4.敏感信息泄露​​

密码等字段需过滤(正则替换示例)

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

5.性能损耗控制​​

高并发场景建议异步记录日志

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实现方法级日志

结合Redis实现请求限流

数据分析​​:

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

总结​​

一个优秀的Filter就像「数字监控摄像头」,默默记录系统运行轨迹。通过本文的方案,你可以:

  • 统一管理所有请求响应日志
  • 零成本实现全链路追踪
  • 灵活扩展监控维度

到此这篇关于springboot filter实现请求响应全链路拦截的文章就介绍到这了,更多相关springboot filter请求拦截内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java简单统计字符串中汉字,英文字母及数字数量的方法

    Java简单统计字符串中汉字,英文字母及数字数量的方法

    这篇文章主要介绍了Java简单统计字符串中汉字,英文字母及数字数量的方法,涉及java针对字符串的遍历、编码转换、判断等相关操作技巧,需要的朋友可以参考下
    2017-06-06
  • Java循环队列原理与用法详解

    Java循环队列原理与用法详解

    这篇文章主要介绍了Java循环队列原理与用法,结合实例形式详细分析了Java循环队列基本概念、原理、用法及操作注意事项,需要的朋友可以参考下
    2020-03-03
  • Java实现线程按序交替执行的方法详解

    Java实现线程按序交替执行的方法详解

    这篇文章主要为大家详细介绍了Java如何实现线程按序交替执行,文中的示例代码讲解详细,对我们了解线程有一定帮助,需要的可以参考一下
    2022-10-10
  • Java并发读写锁ReentrantReadWriteLock 使用场景

    Java并发读写锁ReentrantReadWriteLock 使用场景

    ReentrantReadWriteLock是Java中一种高效的读写锁,适用于读多写少的并发场景,它通过允许多个线程同时读取,但在写入时限制为单线程访问,从而提高了程序的并发性和性能,本文给大家介绍Java并发读写锁ReentrantReadWriteLock 使用场景,感兴趣的朋友跟随小编一起看看吧
    2024-10-10
  • 一文带你了解Spring中存入Bean和获取Bean的方式

    一文带你了解Spring中存入Bean和获取Bean的方式

    这篇文章主要带大家了解Spring中存入Bean和获取Bean的方式,文中的代码示例讲解的非常详细,对我们的学习或工作有一定的帮助,需要的朋友可以参考下
    2023-07-07
  • 基于Java方式实现数据同步

    基于Java方式实现数据同步

    这篇文章主要为大家详细介绍了基于Java方式实现数据同步,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-08-08
  • Java无界阻塞队列DelayQueue详细解析

    Java无界阻塞队列DelayQueue详细解析

    这篇文章主要介绍了Java无界阻塞队列DelayQueue详细解析,DelayQueue是一个支持时延获取元素的无界阻塞队列,队列使用PriorityQueue来实现,队列中的元素必须实现Delayed接口,在创建元素时可以指定多久才能从队列中获取当前元素,需要的朋友可以参考下
    2023-12-12
  • 深入探究SpringBoot可以同时处理多少请求

    深入探究SpringBoot可以同时处理多少请求

    SpringBoot是一款非常流行的Java后端框架,它可以帮助开发人员快速构建高效的Web应用程序,但是,许多人对于SpringBoot能够同时处理多少请求的疑问仍然存在,在本篇文章中,我们将深入探讨这个问题,需要的朋友可以参考下
    2023-07-07
  • Mybatis中一条SQL使用两个foreach的问题及解决

    Mybatis中一条SQL使用两个foreach的问题及解决

    这篇文章主要介绍了Mybatis中一条SQL使用两个foreach的问题及解决,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-02-02
  • java调用外部程序的方法及代码演示

    java调用外部程序的方法及代码演示

    这篇文章主要介绍了java调用外部程序的方法及代码演示的相关资料,需要的朋友可以参考下
    2023-03-03

最新评论