From a49f6622d7d9d3593b60672df56318d8da1823a6 Mon Sep 17 00:00:00 2001 From: mercyblitz Date: Wed, 20 Feb 2019 16:21:56 +0800 Subject: [PATCH] Polish spring-cloud-incubator/spring-cloud-alibaba#348 : Performance optimization --- .../alibaba/dubbo/http/ByteArrayHttpInputMessage.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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