SpringBoot拦截器之如何解决java.io.IOException:Stream closed问题

 更新时间:2026年06月23日 08:35:58   作者:王者之路001  
SpringBoot拦截器与过滤器机制详解,AOP编程实现请求和响应统一拦截,解决Java.io.IOException:Streamclosed问题,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

1.SpringBoot拦截器是什么

SpringBoot拦截器和过滤器是Spring Boot的一种机制,用于对请求和响应进行操作的拦截,是AOP编程的一种体现。该方法可以在不改变代码基本业务和逻辑的前提下对SpringBoot的一些操作进行拦截、过滤和更改。

SpirngBoot拦截器(Interceptor)和过滤器(Filter)的操作的如下图所示。

如果不愿意仔细理解,也可以记住这个执行步骤就可以:过滤器(Filter)——>拦截器(Interceptor)——>Controller Adavice——>Controller。

2.AOP编程

SpringBoot是AOP编程的思想体现。AOP编程即面向切面编程,是函数式编程的一种思想体现。AOP编程和OOP编程没有冲突。

OOP编程的思路是封装、继承和多态,而AOP编程的思路是不改变原有接口和功能的基础上提供功能扩展。

一般来说,AOP编程的实现思路是提供代理,把一些常用功能如权限检查、日志、事务等,从每个业务方法中剥离出来,而提供代理统一实现。

SpringBoot拦截器、过滤器就是AOP编程的体现,即把部分功能统一剥离起来进行统一拦截、过滤和实现。

3.请求拦截和返回拦截

可以对请求和返回进行统一拦截。

一般来说,如果是非常简单的操作,可以用Controller Adavice进行拦截。代码如下:

@ControllerAdvice
public class TestResponseBodyAdvice implements ResponseBodyAdvice {
    @Override
    public boolean supports(MethodParameter returnType, Class converterType) {
        Class targetClass = returnType.getMethod().getDeclaringClass();
        return true;
    }

    @Override
    public Object beforeBodyWrite(Object body, MethodParameter returnType, MediaType selectedContentType, Class selectedConverterType, ServerHttpRequest request, ServerHttpResponse response) {
        //操作

        return body;
    }
}

如果是更复杂的操作,可以用拦截器(Interceptor)进行拦截,代码如下:

@Component
public class TokenInterceptor implements HandlerInterceptor {
    /**
     * 在访问Controller某个方法之前这个方法会被调用。
     *
     * @param request
     * @param response
     * @param handler
     * @return false则表示不执行postHandle方法, true 表示执行postHandle方法
     * @throws Exception
     */
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        //false则表示不执行postHandle方法,不执行下一步chain链,直接返回response
        if(/***相关操作***/) {
            return false;
        } else {
            return true;
        }
    }
}

该方法的要点是:

1)可以自己选择preHandel和psotHanle操作;

2)此拦截器需要在Bean里进行注册;

注册代码(Configuration注入下)如下:

@Autowired
TokenInterceptor tokenInterceptor;

/**
 * 添加拦截器
 * @param registry
 */
@Override
public void addInterceptors(InterceptorRegistry registry) {
	registry.addInterceptor(tokenInterceptor)
			.addPathPatterns("/api/**")//指定该类拦截的url
			.excludePathPatterns( "/static/**");//过滤静态资源
}

2)如果有对request操作,会造成java.io.IOException: Stream closed问题;

4.Java.io.IOException: Stream closed问题解决

Java.io.IOException: Stream closed出现的原因是HTTP的Stream只允许操作一次,如果操作多次就会失败。

该问题的解决思路是:提供一个复制流,让操作基于复制流。

解决代码如下(原有拦截器保持不变):

1)提供文件解析:

public class HttpHelper {
    public static String getBodyString(HttpServletRequest request) throws IOException {
        StringBuilder sb = new StringBuilder();
        InputStream inputStream = null;
        BufferedReader reader = null;
        try {
            inputStream = request.getInputStream();
            reader = new BufferedReader(new InputStreamReader(inputStream, Charset.forName("UTF-8")));
            String line = "";
            while ((line = reader.readLine()) != null) {
                sb.append(line);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (inputStream != null) {
                try {
                    inputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (reader != null) {
                try {
                    reader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return sb.toString();
    }
}

2)提供Filter过滤:

public class HttpServletRequestReplacedFilter implements Filter {
    @Override
    public void destroy() {
    }

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        ServletRequest requestWrapper = null;
        if(request instanceof HttpServletRequest) {
            requestWrapper = new RequestReaderHttpServletRequestWrapper((HttpServletRequest) request);
        }

        //获取请求中的流如何,将取出来的字符串,再次转换成流,然后把它放入到新request对象中。
        // 在chain.doFiler方法中传递新的request对象
        if(requestWrapper == null) {
            chain.doFilter(request, response);
        } else {
            chain.doFilter(requestWrapper, response);
        }
    }

    @Override
    public void init(FilterConfig arg0) throws ServletException {
    }
}

3)对请求的装饰,用于建立复制流。

public class RequestReaderHttpServletRequestWrapper extends HttpServletRequestWrapper {

    private final byte[] body;

    public RequestReaderHttpServletRequestWrapper(HttpServletRequest request) throws IOException {
        super(request);
        body = HttpHelper.getBodyString(request).getBytes(Charset.forName("UTF-8"));
    }

    @Override
    public BufferedReader getReader() throws IOException {
        return new BufferedReader(new InputStreamReader(getInputStream()));
    }

    @Override
    public ServletInputStream getInputStream() throws IOException {

        final ByteArrayInputStream bais = new ByteArrayInputStream(body);

        return new ServletInputStream() {

            @Override
            public int read() throws IOException {
                return bais.read();
            }

            @Override
            public boolean isFinished() {
                return false;
            }

            @Override
            public boolean isReady() {
                return false;
            }

            @Override
            public void setReadListener(ReadListener readListener) {

            }
        };
    }
}

4)在Bean操作(Configuration注入)中加入相关操作:

@Bean
public FilterRegistrationBean httpServletRequestReplacedRegistration() {
	FilterRegistrationBean registration = new FilterRegistrationBean();
	registration.setFilter(new HttpServletRequestReplacedFilter());
	registration.addUrlPatterns("/*");
	registration.addInitParameter("paramName", "paramValue");
	registration.setName("httpServletRequestReplacedFilter");
	registration.setOrder(1);
	return registration;
}

这个问题解决方案,最关键的部分其实是 HttpServletRequestReplacedFilter里的

if(requestWrapper == null) {
	chain.doFilter(request, response);
} else {
	chain.doFilter(requestWrapper, response);
}

这是让复制流起作用的操作,从而避免流被关闭。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Spring MVC数据响应处理详解

    Spring MVC数据响应处理详解

    这篇文章主要给大家介绍了关于Spring MVC数据响应处理的相关资料,本教程详细的讲解SpringMVC框架的使用,非常详细的案例讲解,一步一步带你走入springmvc框架的核心,需要的朋友可以参考下
    2022-05-05
  • Spring Bean生命周期之属性赋值阶段详解

    Spring Bean生命周期之属性赋值阶段详解

    这篇文章主要为大家详细介绍了Spring Bean生命周期之属性赋值阶段,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下,希望能够给你带来帮助
    2022-03-03
  • Java中获取子字符串的几种方法示例

    Java中获取子字符串的几种方法示例

    这篇文章主要主要给大家总结了Java中获取子字符串的几种方法,分别是采用split的方式、采用indexOf的方式、正则和采用replaceFirst的方式这四种方法,需要的朋友可以参考借鉴,下面来看看详细的介绍吧
    2017-01-01
  • JAVA中时间戳与LocalDateTime互相转换代码例子

    JAVA中时间戳与LocalDateTime互相转换代码例子

    最近在编码过程中遇到将时间戳转化为 LocalDateTime,所以这里给总结下,这篇文章主要给大家介绍了关于JAVA中时间戳与LocalDateTime互相转换的相关资料,需要的朋友可以参考下
    2023-11-11
  • SpringBoot整合Liquibase实现对数据库管理和迁移

    SpringBoot整合Liquibase实现对数据库管理和迁移

    Liquibase是一个用于用于跟踪、管理和应用数据库变化的开源工具,通过日志文件(changelog)的形式记录数据库的变更(changeset),然后执行日志文件中的修改,将数据库更新或回滚(rollback)到一致的状态,本文主要介绍SpringBoot与Liquibase的集成,需要的朋友可以参考下
    2024-11-11
  • VScode 打造完美java开发环境最新教程

    VScode 打造完美java开发环境最新教程

    这篇文章主要介绍了VScode 打造完美java开发环境最新教程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-12-12
  • Java面向对象之什么是异常

    Java面向对象之什么是异常

    Java 把异常当作对象来处理,并定义一个基类,java.lang.Throwable 作为所有异常的超类。今天通过本文给大家分享Java面向对象之什么是异常,感兴趣的朋友一起看看吧
    2021-07-07
  • java实现对对碰小游戏

    java实现对对碰小游戏

    这篇文章主要为大家详细介绍了java实现对对碰小游戏,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-12-12
  • Maven 配置文件 生命周期 常用命令详解

    Maven 配置文件 生命周期 常用命令详解

    Maven是围绕着构建生命周期的核心概念为原型,整个项目的创建和部署都是围绕着生命周期展开的,一个生命周期由若干个生命周期阶段组成。下面通过本文给大家介绍Maven 配置文件 生命周期 常用命令详解,一起看看吧
    2017-11-11
  • Java操作文件输出为字符串以及字符串输出为文件的方法

    Java操作文件输出为字符串以及字符串输出为文件的方法

    今天小编就为大家分享一篇Java操作文件输出为字符串以及字符串输出为文件的方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-07-07

最新评论