欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

如何構建可重復讀取inputStream的request

 更新時間:2022年03月15日 11:30:43   作者:bjo2008cn  
這篇文章主要介紹了如何構建可重復讀取inputStream的request,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教

構建可重復讀取inputStream的request

我們知道,request的inputStream只能被讀取一次,多次讀取將報錯,那么如何才能重復讀取呢?答案之一是:增加緩沖,記錄已讀取的內容。

代碼如下所示:

import lombok.extern.log4j.Log4j2;
import org.springframework.mock.web.DelegatingServletInputStream;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.io.*;
/**
?* request wrapper: 可重復讀取request.getInputStream
?*/
@Log4j2
public class RepeatedlyReadRequestWrapper extends HttpServletRequestWrapper {
? ? private static final int BUFFER_START_POSITION = 0;
? ? private static final int CHAR_BUFFER_LENGTH = 1024;
? ? /**
? ? ?* input stream 的buffer
? ? ?*/
? ? private final String body;
? ? /**
? ? ?* @param request {@link javax.servlet.http.HttpServletRequest} object.
? ? ?*/
? ? public RepeatedlyReadRequestWrapper(HttpServletRequest request) {
? ? ? ? super(request);
? ? ? ? StringBuilder stringBuilder = new StringBuilder();
? ? ? ? InputStream inputStream = null;
? ? ? ? try {
? ? ? ? ? ? inputStream = request.getInputStream();
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? log.error("Error reading the request body…", e);
? ? ? ? }
? ? ? ? if (inputStream != null) {
? ? ? ? ? ? try (BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream))) {
? ? ? ? ? ? ? ? char[] charBuffer = new char[CHAR_BUFFER_LENGTH];
? ? ? ? ? ? ? ? int bytesRead;
? ? ? ? ? ? ? ? while ((bytesRead = bufferedReader.read(charBuffer)) > 0) {
? ? ? ? ? ? ? ? ? ? stringBuilder.append(charBuffer, BUFFER_START_POSITION, bytesRead);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? log.error("Fail to read input stream",e);
? ? ? ? ? ? }
? ? ? ? } else {
? ? ? ? ? ? stringBuilder.append("");
? ? ? ? }
? ? ? ? body = stringBuilder.toString();
? ? }
? ? @Override
? ? public ServletInputStream getInputStream() throws IOException {
? ? ? ? final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(body.getBytes());
? ? ? ? return new DelegatingServletInputStream(byteArrayInputStream);
? ? }
}

接下來,需要一個對應的Filter.

代碼如下所示:

import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
public class RepeatlyReadFilter implements Filter {
? ? @Override
? ? public void init(FilterConfig filterConfig) throws ServletException {
? ? ? ? //Do nothing
? ? }
? ? @Override
? ? public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
? ? ? ? if (request instanceof HttpServletRequest) {
? ? ? ? ? ? request = new RepeatedlyReadRequestWrapper((HttpServletRequest) request);
? ? ? ? }
? ? ? ? chain.doFilter(request, response);
? ? }
? ? @Override
? ? public void destroy() {
? ? ? ? //Do nothing
? ? }
}

最后,需要在web.xml中,增加該Filter的配置(略)。 

request中inputStream多次讀取

在使用HTTP協議實現應用間接口通信時,服務端讀取客戶端請求過來的數據,會用到request.getInputStream(),第一次讀取的時候可以讀取到數據,但是接下來的讀取操作都讀取不到數據。

原因

一個InputStream對象在被讀取完成后,將無法被再次讀取,始終返回-1;

InputStream并沒有實現reset方法(可以重置首次讀取的位置),無法實現重置操作;

解決方法(緩存讀取到的數據)

使用request、session等來緩存讀取到的數據,這種方式很容易實現,只要setAttribute和getAttribute就行;

使用HttpServletRequestWrapper來包裝HttpServletRequest,在中初始化讀取request的InputStream數據,以byte[]形式緩存在其中,然后在Filter中將request轉換為包裝過的request;

代碼

編寫rHttpServletRequestWrapper子類,用來處理請求數據

import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.nio.charset.Charset;
import java.util.Enumeration;
import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class BodyReaderHttpServletRequestWrapper extends HttpServletRequestWrapper
{
	private final byte[] body;
	public BodyReaderHttpServletRequestWrapper(HttpServletRequest request) throws IOException
	{
		super(request);
		Enumeration<String> e = request.getHeaderNames();
		while (e.hasMoreElements())
		{
			String name = (String) e.nextElement();
			String value = request.getHeader(name);
			log.debug("HttpServletRequest頭信息:{}-{}", name, value);
		}
		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 boolean isFinished()
			{
				return false;
			}
			@Override
			public boolean isReady()
			{
				return false;
			}
			@Override
			public void setReadListener(ReadListener listener)
			{
				
			}
			@Override
			public int read() throws IOException
			{
				return bais.read();
			}
			
		};
		
	}
	@Override
	public String getHeader(String name)
	{
		return super.getHeader(name);
	}
	@Override
	public Enumeration<String> getHeaderNames()
	{
		return super.getHeaderNames();
	}
	@Override
	public Enumeration<String> getHeaders(String name)
	{
		return super.getHeaders(name);
	}
}

調用

public void doFilter(ServletRequest request, ServletResponse response, FilterChain filterChain) throws IOException, ServletException
	{
		HttpServletRequest httpRequest = (HttpServletRequest) request;
		HttpServletResponse httpResponse = (HttpServletResponse) response;
		
		ServletRequest requestWrapper = null;
		requestWrapper = new BodyReaderHttpServletRequestWrapper(httpRequest);
		
		//數據讀取處理
		//...
		//將requestWrapper專遞給后面的過濾器
		filterChain.doFilter(requestWrapper, httpResponse);
	}

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關文章

  • java String類常用方法練習小結

    java String類常用方法練習小結

    本文主要介紹了java String類常用方法的例子,具有很好的參考價值,下面跟著小編一起來看下吧
    2017-02-02
  • 在Android的應用中實現網絡圖片異步加載的方法

    在Android的應用中實現網絡圖片異步加載的方法

    這篇文章主要介紹了在Android的應用中實現網絡圖片異步加載的方法,一定程度上有助于提高安卓程序的使用體驗,需要的朋友可以參考下
    2015-07-07
  • java中的executeQuery()方法使用

    java中的executeQuery()方法使用

    這篇文章主要介紹了java中的executeQuery()方法使用,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-03-03
  • 匯總Java中List 去重的 6 種方法

    匯總Java中List 去重的 6 種方法

    這篇文章主要介紹了匯總Java中List 去重的 6 種方法,文章圍繞主題展開List去重的方法,具有一定的參考價值,需要的小伙伴可以參考一下
    2022-05-05
  • 一文徹底了解Java的組合模式

    一文徹底了解Java的組合模式

    組合模式(Composite?Pattern)指將對象組合成樹形結構以表示“部分-整體”的層次結構,?使得用戶對單個對象和組合對象的使用具有一致性。本文就來帶大家深入了解一下Java的組合模式吧
    2023-02-02
  • Jenkins一鍵打包部署SpringBoot應用

    Jenkins一鍵打包部署SpringBoot應用

    本文主要介紹了Jenkins一鍵打包部署SpringBoot應用,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2023-01-01
  • Maven如何構建可執(zhí)行的jar包(包含依賴jar包)

    Maven如何構建可執(zhí)行的jar包(包含依賴jar包)

    這篇文章主要介紹了Maven如何構建可執(zhí)行的jar包(包含依賴jar包) ,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-11-11
  • 在java中使用dom4j解析xml(示例代碼)

    在java中使用dom4j解析xml(示例代碼)

    鑒于目前的趨勢,我們這里來講講Dom4j的基本用法,不涉及遞歸等復雜操作。Dom4j的用法很多,官網上的示例有那么點兒晦澀,這里就不寫了
    2013-10-10
  • Spring Cloud Zuul的重試配置詳解

    Spring Cloud Zuul的重試配置詳解

    這篇文章主要介紹了Spring Cloud Zuul的重試配置詳解,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-04-04
  • Java 可視化垃圾回收_動力節(jié)點Java學院整理

    Java 可視化垃圾回收_動力節(jié)點Java學院整理

    Ben Evans是一名資深培訓師兼顧問,他在演講可視化垃圾回收中從基礎談起討論了垃圾回收。以下是對其演講的簡短總結。感興趣的朋友一起學習吧
    2017-05-05

最新評論