Apipost实战：高效调用文件下载接口的完整解决方案

1次阅读

共计 4090 个字符，预计需要花费 11 分钟才能阅读完成。

在实际开发中，调用文件下载接口往往会遇到以下几个典型问题：

超时问题：大文件下载时容易因网络波动或服务器响应慢导致请求超时，特别是当文件超过 100MB 时更为明显。
内存占用高：一次性加载整个文件到内存，当并发请求多或文件较大时容易引发 OOM。
断点续传困难：传统下载方式中断后需要重新下载，缺乏有效的断点续传机制。
进度反馈缺失：用户无法实时感知下载进度，体验较差。
错误处理不完善：网络异常、服务器错误等场景缺乏健壮的重试机制。

Apipost 作为专业的 API 调试和测试工具，针对文件下载场景提供了多项实用功能：

可视化请求构建：通过 GUI 界面快速配置下载请求参数，无需手动拼接 URL。
多线程下载支持：自动将大文件分块并行下载，显著提升下载速度。
断点续传机制：基于 Range 头自动记录下载进度，支持意外中断后继续下载。
实时进度监控：提供下载速度、剩余时间等实时数据展示。
自动化测试：可集成到 CI/CD 流程中进行接口稳定性验证。

import requests
from pathlib import Path

def download_file(url, save_path, chunk_size=8192, max_retry=3):
    """
    带进度显示和断点续传的文件下载函数
    :param url: 文件下载地址
    :param save_path: 本地保存路径
    :param chunk_size: 分块大小(字节)
    :param max_retry: 最大重试次数
    """temp_file = Path(f'{save_path}.tmp')
    headers = {}

    # 检查临时文件实现断点续传
    if temp_file.exists():
        downloaded_size = temp_file.stat().st_size
        headers = {'Range': f'bytes={downloaded_size}-'}
    else:
        downloaded_size = 0

    for attempt in range(max_retry):
        try:
            with requests.get(url, headers=headers, stream=True) as r:
                r.raise_for_status()
                total_size = int(r.headers.get('content-length', 0)) + downloaded_size

                # 追加模式写入临时文件
                with open(temp_file, 'ab') as f:
                    for chunk in r.iter_content(chunk_size=chunk_size):
                        if chunk:
                            f.write(chunk)
                            downloaded_size += len(chunk)
                            progress = (downloaded_size / total_size) * 100
                            print(f'\r 下载进度: {progress:.2f}%', end='')

                # 下载完成重命名文件
                temp_file.rename(save_path)
                print(f'\n 文件已保存到: {save_path}')
                return True

        except Exception as e:
            print(f'\n 第 {attempt + 1} 次尝试失败: {str(e)}')
            if attempt == max_retry - 1:
                return False

# 使用示例
if __name__ == '__main__':
    download_file(
        url='https://example.com/large-file.zip',
        save_path='./downloads/sample.zip'
    )

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;

public class FileDownloader {
    private static final int BUFFER_SIZE = 8192;
    private static final int MAX_RETRY = 3;

    public static boolean downloadFile(String fileUrl, String savePath) {File tempFile = new File(savePath + ".tmp");
        long downloadedBytes = 0;

        // 检查已有下载进度
        if (tempFile.exists()) {downloadedBytes = tempFile.length();
        }

        for (int attempt = 0; attempt < MAX_RETRY; attempt++) {
            HttpURLConnection connection = null;
            InputStream input = null;
            OutputStream output = null;

            try {URL url = new URL(fileUrl);
                connection = (HttpURLConnection) url.openConnection();

                // 设置断点续传范围
                if (downloadedBytes > 0) {connection.setRequestProperty("Range", "bytes=" + downloadedBytes + "-");
                }

                connection.connect();

                // 检查服务器响应
                if (connection.getResponseCode() / 100 != 2) {throw new IOException("服务器返回错误:" + connection.getResponseCode());
                }

                // 获取文件总大小
                long contentLength = downloadedBytes + connection.getContentLengthLong();

                // 打开数据流
                input = connection.getInputStream();
                output = Files.newOutputStream(Paths.get(tempFile.getAbsolutePath()), 
                    StandardOpenOption.CREATE, 
                    StandardOpenOption.APPEND
                );

                byte[] buffer = new byte[BUFFER_SIZE];
                int bytesRead;
                long lastPrintTime = 0;

                while ((bytesRead = input.read(buffer)) != -1) {output.write(buffer, 0, bytesRead);
                    downloadedBytes += bytesRead;

                    // 每秒更新一次进度
                    long currentTime = System.currentTimeMillis();
                    if (currentTime - lastPrintTime > 1000) {double progress = (double) downloadedBytes / contentLength * 100;
                        System.out.printf("\r 下载进度: %.2f%%", progress);
                        lastPrintTime = currentTime;
                    }
                }

                // 下载完成后重命名文件
                File saveFile = new File(savePath);
                tempFile.renameTo(saveFile);
                System.out.println("\n 文件下载完成:" + savePath);
                return true;

            } catch (Exception e) {System.out.printf("\n 第 %d 次尝试失败: %s\n", attempt + 1, e.getMessage());
                if (attempt == MAX_RETRY - 1) {return false;}
            } finally {
                try {if (input != null) input.close();
                    if (output != null) output.close();
                    if (connection != null) connection.disconnect();} catch (IOException e) {e.printStackTrace();
                }
            }
        }
        return false;
    }

    public static void main(String[] args) {
        downloadFile(
            "https://example.com/large-file.zip",
            "./downloads/sample.zip"
        );
    }
}