脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → HttpServletRequest.getInputStream()多次读取

如何解决HttpServletRequest.getInputStream()多次读取问题

 更新时间：2023年07月31日 09:16:53   作者：yxl_num  
这篇文章主要介绍了如何解决HttpServletRequest.getInputStream()多次读取问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

HttpServletRequest.getInputStream()多次读取问题

使用POST方法发送数据时，我们习惯于把数据包装成json格式。

有些情况下，我们会在Filter中读取body数据进行数据校验，GET方法获取参数比较简单。

对于POST方法，可使用如下方法从request中获取body参数：

 private String getBody(HttpServletRequest request) throws IOException {
    InputStream in = request.getInputStream();
    BufferedReader br = new BufferedReader(new InputStreamReader(in, Charset.forName("UTF-8")));
    StringBuffer sb = new StringBuffer("");
    String temp;
    while ((temp = br.readLine()) != null) {
        sb.append(temp);
    }
    if (in != null) {
        in.close();
    }
    if (br != null) {
        br.close();
    }
    return sb.toString();
}

注意，这里有了一次request.getInputStream()调用。

但是在测试时，一直报JSON格式不正确的错误。经调查发现，项目中使用了公司基础组件中的Filter，而该Filter中也解析了body。

同时，不出所料，也是通过调用getInputStream()方法获取的。

原来：

  • 一个InputStream对象在被读取完成后，将无法被再次读取，始终返回-1；
  • InputStream并没有实现reset方法（可以重置首次读取的位置），无法实现重置操作；

因此，当自己写的Filter中调用了一次getInputStream()后，后面再调用getInputStream()读取的数据都为空，所以才报JSON格式不正确的错误。

解决方法

  • 缓存数据
  • 使用HttpServletRequestWrapper进行包装

缓存数据

所谓缓存数据，其实就是调用ServletRequest的setAttribute(String s, Object o)来存储数据。

1.获取到body后，直接缓存

String body = getBody(request);
request.setAttribute("body", body);

优点：

方便

缺点：

不能控制第三方Filter

1.其他地方需要使用body时，只需调用getAttribute方法就能获取数据了：

request.getAttribute("body");

HttpServletRequestWrapper包装

public class RequestWrapper extends HttpServletRequestWrapper {
    private final byte[] body;
    public RequestWrapper(HttpServletRequest request) throws IOException {
        super(request);
        body = getBodyStringFromReq(request).getBytes(Charset.forName("UTF-8"));
    }
    public String getBodyString() {
        try {
            return new String(body, "UTF-8");
        } catch (UnsupportedEncodingException ex) {
            return new String(body);
        }
    }
    private String getBodyStringFromReq(ServletRequest request) {
        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();
    }
}

在Filter中使用时，FilterChain.doFilter()传入Wrapper对象：

public class TestFilter implements Filter {
    @Override
    public void destroy() {
    }
    @Override
    public void doFilter(ServletRequest request, ServletResponse response,
            FilterChain chain) throws IOException, ServletException {
        RequestWrapper requestWrapper = new RequestWrapper((HttpServletRequest)request);
        String body = requestWrapper.getBodyString();
        chain.doFilter(requestWrapper, response);  //传入Wrapper对象
    }
    @Override
    public void init(FilterConfig arg0) throws ServletException {
    }
}

这样，位于后面的Filter就可以拥有唯一一次调用HttpServletRequest.getInputStream()的机会了。

优点：

不影响第三方Filter

缺点：

多写了这么多代码，麻烦了一些

总结

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

您可能感兴趣的文章:

相关文章

  • 分布式调度XXL-Job整合Springboot2.X实战操作过程(推荐)

    分布式调度XXL-Job整合Springboot2.X实战操作过程(推荐)

    这篇文章主要介绍了分布式调度XXL-Job整合Springboot2.X实战操作,包括定时任务的使用场景和常见的定时任务，通过本文学习帮助大家该选择哪个分布式任务调度平台，对此文感兴趣的朋友一起看看吧
    2022-04-04
  • java反射机制给实体类相同字段自动赋值实例

    java反射机制给实体类相同字段自动赋值实例

    这篇文章主要介绍了java反射机制给实体类相同字段自动赋值实例，具有
    2020-08-08
  • springboot配置请求超时时间(Http会话和接口访问)

    springboot配置请求超时时间(Http会话和接口访问)

    本文主要介绍了springboot配置请求超时时间,包含Http会话和接口访问两种,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2024-07-07
  • Java中的Phaser并发阶段器详解

    Java中的Phaser并发阶段器详解

    这篇文章主要介绍了Java中的Phaser并发阶段器详解,Phaser由JDK1.7提出,是一个复杂强大的同步辅助类,是对同步工具类CountDownLatch和CyclicBarrier的综合升级,能够支持分阶段实现等待的业务场景,需要的朋友可以参考下
    2023-12-12
  • SpringBoot整合Netty的流程步骤

    SpringBoot整合Netty的流程步骤

    Netty是一个基于Java的开源网络应用框架,它提供了高性能、异步事件驱动的网络编程能力,Netty旨在帮助开发者构建高性能、高可靠性的网络应用程序,本文给大家详细介绍了SpringBoot整合Netty的流程步骤,需要的朋友可以参考下
    2023-09-09
  • 深入理解Java线程池从设计思想到源码解读

    深入理解Java线程池从设计思想到源码解读

    这篇文章主要介绍了深入理解Java线程池从设计思想到源码解读,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2021-03-03
  • IDEA查看所有的断点(Breakpoints)并关闭的方式

    IDEA查看所有的断点(Breakpoints)并关闭的方式

    我们在使用IDEA开发Java应用时,基本上都需要进行打断点的操作,这方便我们排查BUG,也方便我们查看设计的是否正确,不过有时候,我们不希望进入断点,所以我们需要快速关闭所有断点,故本文给大家介绍了IDEA查看所有的断点(Breakpoints)并关闭的方式
    2024-10-10
  • 解决IDEA无法读取maven镜像,jar包下载失败的问题

    解决IDEA无法读取maven镜像,jar包下载失败的问题

    这篇文章主要介绍了解决IDEA无法读取maven镜像,jar包下载失败的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-10-10
  • Java线程间通信不同步问题原理与模拟实例

    Java线程间通信不同步问题原理与模拟实例

    这篇文章主要介绍了Java线程间通信不同步问题,结合实例形式分析了java线程间通信不同步问题的原理并模拟实现了线程间通信不同步情况下的异常输出,需要的朋友可以参考下
    2019-10-10
  • Java类的初始化顺序知识点总结

    Java类的初始化顺序知识点总结

    在本篇文章里小编给大家整理的是关于Java类的初始化顺序知识点总结，需要的朋友们可以学习下。
    2020-02-02

最新评论