1

RestEasy クライアント バージョン 3.0* を使用しています。
リクエスト本文に非常に大きなコンテンツを投稿しようとしています。
コンテンツの長さが 1 MB 未満の場合、次のコードは正しく実行されています。
コンテンツの長さが非常に大きい (約 500 MB) 場合、リクエストはスタックします。
コードは次のようになります。 

InputStream inputStream = new FileInputStream(tempFile);
ResteasyClient client = new ResteasyClientBuilder().build();
ResteasyWebTarget target = client.target("<SomeUrl>");
response = target.request(MediaType.WILDCARD).post(Entity.entity(inputStream, MediaType.WILDCARD));

大きなコンテンツをサポートするには、コードをどのように変更すればよいですか?

1週間後...
誰も私に答えなかったので、古き良きSpringソリューションを使用しました（以下を参照）。
Spring は RestEasy クライアントより優れていますか?

InputStream inputStream = new FileInputStream(tempFile);
SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
factory.setBufferRequestBody(false);
RestTemplate r = new RestTemplate(factory);

RequestCallback requestCallback = new RequestCallback() {
     @Override
     public void doWithRequest(ClientHttpRequest clientHttpRequest) throws IOException {
         List<org.springframework.http.MediaType> MEDIA_TYPES = Collections.unmodifiableList(Arrays.asList(org.springframework.http.MediaType.ALL));
         clientHttpRequest.getHeaders().setAccept(MEDIA_TYPES);
         OutputStream requestOutputStream = clientHttpRequest.getBody();
         try {
             int copiedBytes = IOUtils.copy(inputStream, requestOutputStream);
         } finally {
             IOUtils.closeQuietly(requestOutputStream);
         }
      }
};

ResponseExtractor<Response> responseExtractor = new ResponseExtractor<Response>() {
    @Override
    public Response extractData(ClientHttpResponse response) throws IOException {
        return Response.status(response.getRawStatusCode()).build();
    }
};

response = r.execute(url, HttpMethod.POST, requestCallback, responseExtractor);
4

1 に答える 1

0

Spring 4.0.1 では、SimpleClientHttpRequestFactory の代わりに Apache HTTP クライアントと HttpComponentsClientHttpRequestFactory を使用できると思います。元のメモは次のとおりです: SPR-10728

<bean id="restTemplateStreaming" class="org.springframework.web.client.RestTemplate">
    <constructor-arg>
        <bean class="org.springframework.http.client.HttpComponentsClientHttpRequestFactory">
            <property name="bufferRequestBody" value="false" />
            <property name="httpClient">
                <bean class="com.spotfire.server.http.spring.HttpClientFactory">
                    <property name="clientBuilder">
                        <bean class="org.apache.http.impl.client.HttpClientBuilder">
                            <property name="connectionManager" ref="poolingHttpClientConnectionManager" />
                            <property name="redirectStrategy">
                                <bean class="org.apache.http.impl.client.LaxRedirectStrategy" />
                            </property>
                        </bean>
                    </property>
                </bean>
            </property>
        </bean>
    </constructor-arg>      
</bean>

ただし、コールバックの実装も変更されていることに注意してください。clientHttpRequest.getBody(); を呼び出すことはできなくなりました。代わりに、以下に示すように少し複雑な構造を使用する必要があります。

class StreamingRequestCallback implements RequestCallback {

private final InputStream inputStream;

StreamingRequestCallback(InputStream inputStream) {
  this.inputStream = inputStream;
}

@Override
public void doWithRequest(final ClientHttpRequest request) throws IOException {
  request.getHeaders().add("Content-type", MediaType.APPLICATION_OCTET_STREAM_VALUE);

  ((StreamingHttpOutputMessage) request).setBody(new StreamingHttpOutputMessage.Body() {
    @Override
    public void writeTo(final OutputStream outputStream) throws IOException {
      IOUtils.copy(inputStream, outputStream);
    }
  });
}

};

于 2014-02-04T21:43:50.827 に答える