快捷導(dǎo)航

關(guān)于post請(qǐng)求內(nèi)容無(wú)法重復(fù)獲取的解決方法

更新時(shí)間：2024年03月04日 11:09:49 作者：isfox

這篇文章主要介紹了關(guān)于post請(qǐng)求內(nèi)容無(wú)法重復(fù)獲取的解決方法,文中通過代碼示例給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下

post請(qǐng)求體內(nèi)容無(wú)法重復(fù)獲取

為什么會(huì)無(wú)法重復(fù)讀取呢？

以tomcat為例，在進(jìn)行請(qǐng)求體讀取時(shí)實(shí)際底層調(diào)用的是org.apache.catalina.connector.Request的getInputStream()方法，而該方法返回的是CoyoteInputStream輸入流

public ServletInputStream getInputStream() throws IOException {

    if (usingReader) {
        throw new IllegalStateException(sm.getString("coyoteRequest.getInputStream.ise"));
    }

    usingInputStream = true;
    if (inputStream == null) {
        inputStream = new CoyoteInputStream(inputBuffer);
    }
    return inputStream;

}

在使用CoyoteInputStream進(jìn)行讀取時(shí)

public int read(byte[] b, int off, int len) throws IOException {
  // 如果流關(guān)閉，則拋出異常
    if (closed) {
        throw new IOException(sm.getString("inputBuffer.streamClosed"));
    }
// 如果已經(jīng)讀完了，則返回-1
    if (checkByteBufferEof()) {
        return -1;
    }
    int n = Math.min(len, bb.remaining());
    bb.get(b, off, n);
    return n;
}

而流讀取完畢都會(huì)進(jìn)行close，這個(gè)流close之后，close狀態(tài)就置為了true，所以導(dǎo)致流無(wú)法進(jìn)行二次讀取

那么如何解決呢？將tomcat的Request類進(jìn)行重新實(shí)現(xiàn)嗎？代價(jià)太大了，sun公司當(dāng)初在設(shè)計(jì)的時(shí)候就已經(jīng)提供了解決方法，對(duì)于請(qǐng)求和響應(yīng)，sun公司提供了包裝類，可以HttpServletRequestWrapper類包裝原始的request對(duì)象，實(shí)現(xiàn)了HttpServletRequest接口的所有方法，內(nèi)部調(diào)用了所包裝的request對(duì)象的對(duì)應(yīng)方法；相應(yīng)的也有HttpServletResponseWrapper類來(lái)包裝原始的response對(duì)象繼承HttpServletRequestWrapper來(lái)進(jìn)行方法重寫，可以使用HttpServletResponseWrapper和HttpServletRequestWrapper來(lái)進(jìn)行定制響應(yīng)和請(qǐng)求

public class BodyReaderHttpServletRequestWrapper extends HttpServletRequestWrapper {
		// 存儲(chǔ)請(qǐng)求體
    private byte[] body;

    private HttpServletRequest orgRequest;

    public BodyReaderHttpServletRequestWrapper(HttpServletRequest request) throws IOException {
        super(request);
        this.orgRequest = request;
        body = HttpHelper.getBody(request);
    }

    public HttpServletRequest getOrgRequest() {
        return this.orgRequest;
    }

  // 重寫讀取，從存儲(chǔ)的字節(jié)數(shù)組中讀
    @Override
    public BufferedReader getReader() throws IOException {
        return new BufferedReader(new InputStreamReader(getInputStream()));
    }

  // 重寫讀取，從存儲(chǔ)的字節(jié)數(shù)組中讀
    @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) {

            }
        };
    }
}

到此這篇關(guān)于關(guān)于post請(qǐng)求內(nèi)容無(wú)法重復(fù)獲取的解決方法的文章就介紹到這了,更多相關(guān)post請(qǐng)求無(wú)法重復(fù)獲取內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: