Java Jersey客户端-使用256Mb客户端JVM堆上载1Gb文件

Question

我使用的是Jersey 2.28，想要编写一个客户端来上传1Gb的文件，而客户端JVM堆不能超过256Mb。

我在这里有什么选择？

我试着用下面的代码片段，但结果是OOM，因为Jersey似乎一直在尽可能多地从InputStream中读取数据。为了处理大量输入，可以指示球衣进行冲洗吗？

public Response upload(InputStream inputStream) {
    Client client = ClientBuilder.newBuilder().build();
    client.register(MultiPartFeature.class);
    WebTarget target = client.target("http://myexample.com").path("/upload");
    Invocation.Builder builder = target.request();

    FormDataMultiPart form = new FormDataMultiPart();
    form.bodyPart(new StreamDataBodyPart("file", inputStream, "filename.zip"));

    return builder.post(Entity.entity(form, form.getMediaType()));
}

Caused by: java.lang.OutOfMemoryError: Java heap space
    at java.util.Arrays.copyOf(Arrays.java:3236)
    at java.io.ByteArrayOutputStream.grow(ByteArrayOutputStream.java:118)
    at java.io.ByteArrayOutputStream.ensureCapacity(ByteArrayOutputStream.java:93)
    at java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:153)
    at sun.net.www.http.PosterOutputStream.write(PosterOutputStream.java:78)
    at org.glassfish.jersey.message.internal.CommittingOutputStream.write(CommittingOutputStream.java:200)
    at org.glassfish.jersey.message.internal.WriterInterceptorExecutor$UnCloseableOutputStream.write(WriterInterceptorExecutor.java:276)

Answer 1

解决方案是添加：

client.property(ClientProperties.REQUEST_ENTITY_PROCESSING,
                RequestEntityProcessing.CHUNKED);

ClientProperties.REQUEST_ENTITY_PROCESSING：

该属性指定连接器应如何将实体序列化到输出流。；是否应使用缓冲或实体以分块编码进行流传输。

对于属性的编程定义，该值必须是< code>String的实例或枚举值< code > RequestEntityProcessing 。允许的值为:

缓冲：实体将被缓冲，内容长度将在内容长度头中发送。

分块：将使用分块编码，并对实体进行流式传输。

默认值是分块的。但是，由于限制，一些连接器可以定义不同的默认值（通常在接口上无法正确支持分块编码的情况下）。此详细信息应在该特定连接器的Javadoc中指定。例如，HttpUrlConnector（默认的连接器使用缓冲作为默认模式。

配置属性常量的 String 值为“jersey.config.client.request.entity.processing”。