diff --git a/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/http/ByteArrayHttpInputMessage.java b/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/http/ByteArrayHttpInputMessage.java index 2451a715..c74f2e99 100644 --- a/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/http/ByteArrayHttpInputMessage.java +++ b/spring-cloud-alibaba-dubbo/src/main/java/org/springframework/cloud/alibaba/dubbo/http/ByteArrayHttpInputMessage.java @@ -16,10 +16,11 @@ */ package org.springframework.cloud.alibaba.dubbo.http; +import com.alibaba.dubbo.common.io.UnsafeByteArrayInputStream; + import org.springframework.http.HttpHeaders; import org.springframework.http.HttpInputMessage; -import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; @@ -28,7 +29,7 @@ import java.io.InputStream; * * @author Mercy */ -public class ByteArrayHttpInputMessage implements HttpInputMessage { +class ByteArrayHttpInputMessage implements HttpInputMessage { private final HttpHeaders httpHeaders; @@ -40,7 +41,7 @@ public class ByteArrayHttpInputMessage implements HttpInputMessage { public ByteArrayHttpInputMessage(HttpHeaders httpHeaders, byte[] body) { this.httpHeaders = httpHeaders; - this.inputStream = new ByteArrayInputStream(body); + this.inputStream = new UnsafeByteArrayInputStream(body); } @Override