无法发布大文件使用SpringRest模板w/自定义拦截器

Question

我正在尝试使用spring rest模板POST w/自定义拦截器将一个大文件从一个微服务发布到另一个微服务，如下所示：

SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
requestFactory.setBufferRequestBody(false);
restTemplate = new RestTemplate(requestFactory);
restTemplate.getInterceptors().add({customInterceptor});
MultiValueMap<String, Object> body = new LinkedMultiValueMap<>();
body.add("file", {InputStreamResource});
body.add("metadata", {JSON string});
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.MULTIPART_FORM_DATA);
HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(body, headers);
restTemplate.exchange({url}, HttpMethod.POST, requestEntity, ...);

（我是否使用SimpleClientHttpask estFactory或HttpComponentsClientHttpask estFactory没有区别）

添加拦截器会在调用getRequestFactory时创建一个新的侦听ClientHttPrequestFactory（包装原始请求工厂）。

这适用于较小的文件，但适用于较大的文件-由于请求从未委托给原始请求工厂，因此不会发生流，因此会导致java。lang.OutOfMemoryError:Java堆空间异常。

任何帮助都将不胜感激。

Answer 1

我也遇到过这个问题，但此时切换到WebClient不是一个选项，所以我选择通过实现一个新的clienthtprequestfactory（尽管是通过abstractclienthtprequestfactorywrapper）来解决这个问题；这主要是因为我们只调整了标题，而不是正文。

SimpleClientHttpRequestFactory simpleRequestFactory =
    new SimpleClientHttpRequestFactory();

simpleRequestFactory.setConnectTimeout(10000);
simpleRequestFactory.setReadTimeout(60000);
simpleRequestFactory.setBufferRequestBody(false); // this enables streaming

SomeHeaderInterceptingClientHttpRequestFactory interceptingRequestFactory =
    new SomeHeaderInterceptingClientHttpRequestFactory(simpleRequestFactory);

RestTemplate restTemplate = new RestTemplate(interceptingRequestFactory);

这就是的的样子：

public class SomeHeaderInterceptingClientHttpRequestFactory
    extends AbstractClientHttpRequestFactoryWrapper {

    // you can have fields here that are initialized in the constructor
    // e.g. a service that supplies the header value that you want to populate

    public SomeHeaderInterceptingClientHttpRequestFactory(ClientHttpRequestFactory requestFactory) {
        super(requestFactory);
        // initialize fields
    }

    @Override
    protected ClientHttpRequest createRequest(URI uri,
                                              HttpMethod httpMethod,
                                              ClientHttpRequestFactory requestFactory)
                                              throws IOException {
        ClientHttpRequest request = requestFactory.createRequest(uri, httpMethod);
        HttpHeaders headers = request.getHeaders();

        headers.set("SOME_HEADER", "some value");

        return request;
    }
}

如果您想对身体做一些事情，那么您也可以尝试实现一个新的ClientHttpRequest。然后，您将返回一个新引入的ClientHttpRequest的createRequest方法中的新实例。

Answer 2

似乎RestTemplate的这个问题不会根据这个问题得到解决

既然WebClient已经可用，并且为流提供了一流的支持，我们就不支持这个了。

请注意，WebClient在Spring5中可用。