20

我正在尝试在我的下载管理器中实现暂停/恢复，我在网上搜索并阅读了几篇文章并根据它们更改了我的代码，但恢复似乎无法正常工作，有什么想法吗？

                if (!downloadPath.exists()) 
                    downloadPath.mkdirs(); 

                if (outputFileCache.exists())
                {
                    downloadedSize = outputFileCache.length();
                    connection.setAllowUserInteraction(true);
                    connection.setRequestProperty("Range", "bytes=" + downloadedSize + "-");
                    connection.setConnectTimeout(14000);
                    connection.connect();
                    input = new BufferedInputStream(connection.getInputStream());
                    output = new FileOutputStream(outputFileCache, true);
                    input.skip(downloadedSize); //Skip downloaded size
                }
                else
                {
                    connection.setConnectTimeout(14000);
                    connection.connect();
                    input = new BufferedInputStream(url.openStream());
                    output = new FileOutputStream(outputFileCache);
                }

                fileLength = connection.getContentLength();                 


                byte data[] = new byte[1024];
                int count = 0;
                int __progress = 0;
                long total = downloadedSize;

                while ((count = input.read(data)) != -1 && !this.isInterrupted()) 
                {
                    total += count;
                    output.write(data, 0, count);
                    __progress = (int) (total * 100 / fileLength);

                }
                output.flush();
                output.close();
                input.close();
4

5 回答 5

21

好的问题已解决，这是我为其他想要实现暂停/恢复的用户的代码：

        if (outputFileCache.exists())
        {
            connection.setAllowUserInteraction(true);
            connection.setRequestProperty("Range", "bytes=" + outputFileCache.length() + "-");
        }

        connection.setConnectTimeout(14000);
        connection.setReadTimeout(20000);
        connection.connect();

        if (connection.getResponseCode() / 100 != 2)
            throw new Exception("Invalid response code!");
        else
        {
            String connectionField = connection.getHeaderField("content-range");

            if (connectionField != null)
            {
                String[] connectionRanges = connectionField.substring("bytes=".length()).split("-");
                downloadedSize = Long.valueOf(connectionRanges[0]);
            }

            if (connectionField == null && outputFileCache.exists())
                outputFileCache.delete();

            fileLength = connection.getContentLength() + downloadedSize;
            input = new BufferedInputStream(connection.getInputStream());
            output = new RandomAccessFile(outputFileCache, "rw");
            output.seek(downloadedSize);

            byte data[] = new byte[1024];
            int count = 0;
            int __progress = 0;

            while ((count = input.read(data, 0, 1024)) != -1 
                    && __progress != 100) 
            {
                downloadedSize += count;
                output.write(data, 0, count);
                __progress = (int) ((downloadedSize * 100) / fileLength);
            }

            output.close();
            input.close();
       }
于 2013-03-21T14:16:37.660 回答
5

如果没有更多信息，就无法判断出了什么问题，但需要注意的是：

  1. 您必须发出 HTTP/1.1 请求（很难从您的示例代码中看出）
  2. 服务器必须支持 HTTP/1.1
  3. 服务器将通过响应中的 Accept-Ranges 标头告诉您它支持什么
  4. If-Range 应该是服务器为您提供的资源的 etag，而不是上次修改时间

你应该用一些简单的东西来检查你的范围请求，以测试源实际上首先支持范围请求（如 curl 或 wget ）

于 2013-03-13T03:14:43.560 回答
2

可能是您的服务器需要很长时间才能响应（超过超时限制），或者这也是并非所有服务器都支持暂停 - 恢复的事实。还需要思考的是，文件是通过 Http、https、ftp 或 udp 下载的。

暂停”可能只是意味着读取一些流并将其写入磁盘。恢复时，您必须使用标题来指定要下载的内容。

您可以尝试以下方法：

 HttpURLConnection connection = (HttpURLConnection) url.openConnection();
    if(ISSUE_DOWNLOAD_STATUS.intValue()==ECMConstant.ECM_DOWNLOADING){
         File file=new File(DESTINATION_PATH);
        if(file.exists()){
             downloaded = (int) file.length();
         connection.setRequestProperty("Range", "bytes="+(file.length())+"-");
    }
}else{
    connection.setRequestProperty("Range", "bytes=" + downloaded + "-");
}
connection.setDoInput(true);
connection.setDoOutput(true);
progressBar.setMax(connection.getContentLength());
 in = new BufferedInputStream(connection.getInputStream());
 fos=(downloaded==0)? new FileOutputStream(DESTINATION_PATH): new FileOutputStream(DESTINATION_PATH,true);
 bout = new BufferedOutputStream(fos, 1024);
byte[] data = new byte[1024];
int x = 0;
while ((x = in.read(data, 0, 1024)) >= 0) {
    bout.write(data, 0, x);
     downloaded += x;
     progressBar.setProgress(downloaded);
}

请尝试同步内容。

于 2013-03-21T10:15:14.883 回答
1

我将从这一行开始调试：

connection.setRequestProperty("Range", "bytes=" + downloadedSize + "-");

由于无法从源代码中确定是什么downloadedSize，因此很难进一步详细说明，但格式应该是bytes=from-to.

无论如何，我建议您使用Apache HttpClient来避免常见的陷阱。这是一个在类似主题上使用 Apache HttpClient 的人提出的问题，并提供了一些示例代码。

于 2013-03-15T21:24:28.947 回答
0

我认为您只需要删除 input.skip(downloadedSize) 行。为字节范围设置 HTTP 标头意味着服务器将跳过发送这些字节。

假设您有一个 20 字节长的文件，其中包含“aaaaabbbbbcccccddddd”，并假设在下载 5 个字节后传输暂停。然后 Range 标头将导致服务器发送“bbbbbcccccddddd”，您应该阅读所有这些内容并将其附加到文件中——不要跳过（）。但是代码中的 skip() 调用将跳过“bbbbb”，留下“cccccddddd”要下载。如果您已经下载了至少 50% 的文件，那么 skip() 将耗尽所有输入并且不会发生任何事情。

此外，stringy05 的帖子中的所有内容都适用。您应该确保服务器支持 HTTP/1.1，确保资源支持 Range 标头（动态生成的内容可能不支持它），并确保资源没有使用 etag 和修改日期进行修改。

于 2013-03-21T01:55:12.800 回答