使用InpuStream下载大文件

Question

我们有一个运行在Linux上的Weblogic服务器，有多个受管服务器。我所关心的托管服务器的最大堆大小为1024MB。该服务器上部署了多个应用程序。其中一个应用程序处理来自REST api的响应来下载250MB的文件。对于大于50 MB的文件，有时没有问题，但有时服务器会因OOM错误而崩溃。以下是我的代码:

Client client = Client.create();          
WebResource webResource = client.resource(url.toString());
ClientResponse response = webResource.accept("application/json").get(ClientResponse.class);
if (response.getStatus() != 200) {
            throw new RuntimeException("Failed : HTTP error code : "+ response.getStatus());
        }
String output = response.getEntity(String.class);
byte[] fileContent = Base64.decodeBase64(output.getBytes());
if (fileContent != null) {
        OutputStream out = null;
        try {
            res.reset();
            out = res.getOutputStream();
            res.setContentType(contentType);
            res.setHeader("Content-Disposition", "inline; filename=" + fileName + "; size=" + String.valueOf(fileContent.length));
            res.setContentLength(fileContent.length);
            out.write(fileContent);
        } catch (Exception ex) {
            e.printStackTrace();
        } finally {
            out.flush();
            out.close();
        }
    } 

由于存在内存问题，我尝试采用InpuStream方法。以下是更改后的代码：

Client client = Client.create();          
WebResource webResource = client.resource(url.toString());
ClientResponse response = webResource.accept("application/json").get(ClientResponse.class);
if (response.getStatus() != 200) {
        throw new RuntimeException("Failed : HTTP error code : "+ response.getStatus());
    }
InputStream source = response.getEntityInputStream(); // IS THIS OKAY?

if (source!= null) {
        OutputStream out = null;
        int count = 0;
        try {
            byte[] buffer = new byte[1024];
            int read = 0;
            res.reset();
            res.setContentType(contentType);
            res.setHeader("Content-Disposition", "inline; filename=" + fileName);
            out = res.getOutputStream();
            while ((read = source.read(buffer)) != -1) {
                out.write(buffer, 0, read);
                count++;
            }                
            System.out.println("COUNT: " + count);// For a 60MB file, this prints 86000. why?
        } catch (Exception ex) {
            e.printStackTrace();
        }finally{
            out.flush();
            out.close();
            source.close();
        }

此代码没有进入OOM，但文件未能加载/损坏。问题是否与它是Base64编码的响应以及我没有正确处理它有关？如果是，我该怎么办？应用程序在Java7上运行。我使用InpuStream来解决OOM的方法可以吗？该服务没有以块的形式发送响应。我还可以采取其他方法吗？我担心我只是为了50MB的文件而遇到错误（并不总是如此）。服务器是远程服务器，由另一个组处理。我如何检查是否有其他原因导致服务器崩溃？

Answer 1

我使用Base64InputStream来解码InputStream响应，它工作得很好。

InputStream stream = response.getEntityInputStream();
Base64InputStream bis = new Base64InputStream(stream);

然后，使用 bis 写入文件。此方法现在打印 count 变量大约在 65000。

Answer 2

嗨，试试这个本指南。https://www.baeldung.com/java-download-file

这是一个很棒的网站，提供了几乎所有可以想象的场景的Java指南。

祝你好运！:-)