From d46f00d2bead8ec4fbdc6307a70309b96786e46f Mon Sep 17 00:00:00 2001
From: Looly <loolly@aliyun.com>
Date: Tue, 12 Dec 2023 23:04:27 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dgraalvm=E7=BC=96=E8=AF=91?=
 =?UTF-8?q?=E5=90=8E=EF=BC=8C=E6=9C=AA=E8=AF=BB=E5=8F=96Content-Length?=
 =?UTF-8?q?=E5=8F=AF=E8=83=BD=E5=AF=BC=E8=87=B4=E7=9A=84=E8=AF=BB=E5=8F=96?=
 =?UTF-8?q?=E6=97=B6=E9=97=B4=E8=BF=87=E9=95=BF=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 CHANGELOG.md                                  |  1 +
 .../hutool/http/server/HttpServerRequest.java | 20 ++++++++++++++++++-
 2 files changed, 20 insertions(+), 1 deletion(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 449d27dee..dadd50756 100755
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -21,6 +21,7 @@
 * 【cache 】      修复StampedCache的get方法非原子问题（issue#I8MEIX@Gitee）
 * 【core  】      修复StrSplitter.splitByRegex使用空参数导致的OOM问题（issue#3421@Github）
 * 【db    】      修复嵌套SQL中order by子句错误截断问题（issue#I89RXV@Gitee）
+* 【http  】      修复graalvm编译后，未读取Content-Length可能导致的读取时间过长问题（issue#I6Q30X@Gitee）
 
 -------------------------------------------------------------------------------------------------------------
 # 5.8.23(2023-11-12)
diff --git a/hutool-http/src/main/java/cn/hutool/http/server/HttpServerRequest.java b/hutool-http/src/main/java/cn/hutool/http/server/HttpServerRequest.java
index 05555f58a..0872dadc6 100644
--- a/hutool-http/src/main/java/cn/hutool/http/server/HttpServerRequest.java
+++ b/hutool-http/src/main/java/cn/hutool/http/server/HttpServerRequest.java
@@ -3,6 +3,7 @@ package cn.hutool.http.server;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.io.IORuntimeException;
 import cn.hutool.core.io.IoUtil;
+import cn.hutool.core.io.LimitedInputStream;
 import cn.hutool.core.map.CaseInsensitiveMap;
 import cn.hutool.core.map.multi.ListValueMap;
 import cn.hutool.core.net.NetUtil;
@@ -294,7 +295,24 @@ public class HttpServerRequest extends HttpServerBase {
 	 * @return 流
 	 */
 	public InputStream getBodyStream() {
-		return this.httpExchange.getRequestBody();
+		InputStream bodyStream = this.httpExchange.getRequestBody();
+
+		//issue#I6Q30X，读取body长度，避免读取结束后无法正常结束问题
+		final String contentLengthStr = getHeader(Header.CONTENT_LENGTH);
+		long contentLength = 0;
+		if(StrUtil.isNotBlank(contentLengthStr)){
+			try{
+				contentLength = Long.parseLong(contentLengthStr);
+			} catch (final NumberFormatException ignore){
+				// ignore
+			}
+		}
+
+		if(contentLength > 0){
+			bodyStream = new LimitedInputStream(bodyStream, contentLength);
+		}
+
+		return bodyStream;
 	}
 
 	/**