带有rest调用的Java spring文件下载代理

Question

我需要用java创建一个rest服务，它将连接到另一个rest服务以下载文件。目前，我只需要将文件从另一个后端传输到客户机，但在将来会进行一些处理/转换。

对于我项目中的所有web服务，我们都使用spring rest（用于提供和使用服务）。

我的问题是，考虑到文件会很大，而且我不想遇到内存不足的错误，什么才是合适的方法呢。

其他一些帖子中的人建议在两端使用流，但这真的有可能吗？为此，我需要先将文件写入磁盘吗？

我当前的文件下载代码（消费者）-

public BackendResponse<byte[]> callBackendForFile(BackendRequest request) {

        String body = null;
        ResponseEntity<byte[]> responseEntity = null;
        URI uri = createURI(request);

        MultiValueMap<String, String> requestHeaders = getHeadersInfo(request.getHttpRequest());

        if (HttpMethod.GET.equals(request.getMethod())) {
            responseEntity = restTemplate.exchange(uri, request.getMethod(),
                    new HttpEntity<String>(body, requestHeaders), byte[].class);
        } else {
            LOG.error("Method:{} not supported yet", request.getMethod());
        }

        BackendResponse<byte[]> response = new BackendResponse<>();
        response.setResponse(responseEntity);
        return response;

    }

我的客户代码（提供商）：

@RequestMapping(value = "/file", method = RequestMethod.GET, produces = "application/xml")
    @ResponseBody
    public void downloadFileWithoutSpring(HttpMethod method, HttpServletRequest httpRequest,
            HttpServletResponse httpResponse) {

        BackendRequest request = new BackendRequest(method,
                httpRequest.getRequestURI(), httpRequest.getQueryString(), httpRequest);

        BackendResponse<byte[]> backendResponse = dutyplanService.getFile(request);
        ResponseEntity<byte[]> response = backendResponse.getResponse();

        httpResponse.addHeader("Content-Disposition", "attachment; filename=\"" + "attachment.zip" + "\"");
        httpResponse.getOutputStream().write(response.getBody());
        httpResponse.flushBuffer();
}

注意：由于下载的附件是一个损坏的文件，上面的代码无法正常工作

Answer 1

您可以直接在restTemplate中传递HttpServletResponse#getOutputStream（），并在服务器中写入它，而无需保存文件。

public void getFile(HttpServletResponse response) throws IOException {
        restTemplate.execute(
                "http://ip:port/temp.csv",
                HttpMethod.GET,
                null,
                clientHttpResponse -> {
                    StreamUtils.copy(clientHttpResponse.getBody(), response.getOutputStream());
                    return null;
                }
        );
    }

请注意，在调用getFile（）之后，您应该像这样关闭输出流response.get输出流。

Answer 2

我认为，只要从另一台服务器接收到文件的字节数组内容，就不需要在服务器上创建该文件。

您可以尝试将产生注释的值更改为值Application/zip（或Application/octet-stream，具体取决于目标浏览器），而不是Application/xml