Android批量处理上传和下载

效果图

GIF 2021-9-8 10-25-13.gif
GIF 2021-9-8 14-11-24.gif

部分源码和理解说明

一个基于okhttp的文件下载、上传工具

下载：支持多线程、断点续传下载，以及下载管理，原理、以及用法

上传：支持表单形式上传、直接将文件作为请求体上传，原理、以及用法

批量下载

image.png

这些就是简单类的方法了。
先串联起来就必须有简单单个下载方式。

image.png

这样就是一个简单的方式了。
通过这个思路继续下去，开始批量，进行梳理。

同单例来保障数据获取和下载的独立性

 private volatile static DownloadManger downloadManager;

    public static DownloadManger getInstance(Context context) {
        if (downloadManager == null) {
            synchronized (DownloadManger.class) {
                if (downloadManager == null) {
                    downloadManager = new DownloadManger(context);
                }
            }
        }
        return downloadManager;
    }

    private DownloadManger(Context context) {
        this.context = context;
    }

用DBuilder 来封装获取数据来源问题进行统一。
DownloadProgressHandler 来进行 Handler 数据进行回到和梳理。
FileTask 和ThreadPool 来进行真正的下载功能，在task是一个run方式，对于，每次下载还进处理并记录，从而可以导向的进行每个下载的文件进行合理的显示。

/**
     * data + callback 形式直接开始下载
     *
     * @param downloadData
     * @param downloadCallback
     * @return
     */
    public DownloadManger start(DownloadData downloadData, DownloadCallback downloadCallback) {
        execute(downloadData, downloadCallback);
        return downloadManager;
    }

这个是先通过进行分配和添加，导致可以进行合理的分配处理下载的进度。
然后在进行分离开。

 /**
     * 根据url开始下载（需先注册监听）
     *
     * @param url
     */
    public DownloadManger start(String url) {
        execute(downloadDataMap.get(url), callbackMap.get(url));
        return downloadManager;
    }

    /**
     * 注册监听
     *
     * @param downloadData
     * @param downloadCallback
     */
    public synchronized void setOnDownloadCallback(DownloadData downloadData, DownloadCallback downloadCallback) {
        downloadDataMap.put(downloadData.getUrl(), downloadData);
        callbackMap.put(downloadData.getUrl(), downloadCallback);
    }

根据url开始下载（需先注册监听） 这注册的时候，就是下载码setcallback ....
这样就很好的看到了，我们下载 下载内容了。

/**
     * 执行下载任务
     */
    private synchronized void execute(DownloadData downloadData, DownloadCallback downloadCallback) {
        //防止同一个任务多次下载
        if (progressHandlerMap.get(downloadData.getUrl()) != null) {
            return;
        }

        //默认每个任务不通过多个异步任务下载
        if (downloadData.getChildTaskCount() == 0) {
            downloadData.setChildTaskCount(1);
        }

        DownloadProgressHandler downloadProgressHandler = new DownloadProgressHandler(context, downloadData, downloadCallback);
        FileTask fileTask = new FileTask(context, downloadData, downloadProgressHandler.getHandler());
        downloadProgressHandler.setFileTask(fileTask);

        downloadDataMap.put(downloadData.getUrl(), downloadData);
        callbackMap.put(downloadData.getUrl(), downloadCallback);
        fileTaskMap.put(downloadData.getUrl(), fileTask);
        progressHandlerMap.put(downloadData.getUrl(), downloadProgressHandler);

        ThreadPool.getInstance().getThreadPoolExecutor().execute(fileTask);

        //如果正在下载的任务数量等于线程池的核心线程数，则新添加的任务处于等待状态
        if (ThreadPool.getInstance().getThreadPoolExecutor().getActiveCount() == ThreadPool.getInstance().getCorePoolSize()) {
            downloadCallback.onWait();
        }
    }

这里不得不看 单例里面四个主要的静态的变量了。

private Map<String, DownloadProgressHandler> progressHandlerMap = new HashMap<>();//保存任务的进度处理对象
    private Map<String, DownloadData> downloadDataMap = new HashMap<>();//保存任务数据
    private Map<String, DownloadCallback> callbackMap = new HashMap<>();//保存任务回调
    private Map<String, FileTask> fileTaskMap = new HashMap<>();//保存下载线程

对着四个进行添加和删除的过程就行下载和完成的过程了。

增加部分

1，批量上传
批量处理方式根据批量下载思路来的，这样就必须搞清楚批量下载。然后开始着手去创建，相同的文件和类。

image.png

发现上传 不会续传，后台根本没有这样做，失败了重新上传，或者提示上传失败就完了，
省下了存数据的烦恼了。

/**
     * 根据url开始下载（需先注册监听）
     *
     * @param uploadData
     */
    public UploadManger start(UploadFile uploadData) {
        execute(uploadData, callbackMap.get(uploadData.getFile().getAbsolutePath()));
        return downloadManager;
    }

    /**
     * 注册监听
     *
     * @param uploadData
     * @param uploadCallback
     */
    public synchronized void setOnDownloadCallback(UploadFile uploadData, UploadCallback uploadCallback) {
        uploadDataMap.put(uploadData.getFile().getAbsolutePath(), uploadData);
        callbackMap.put(uploadData.getFile().getAbsolutePath(), uploadCallback);
    }

    /**
     * 执行上传任务
     */
    private synchronized void execute(UploadFile uploadData, UploadCallback uploadCallback) {
        //防止同一个任务多次上传
        if (progressHandlerMap.get(uploadData.getFile().getAbsolutePath()) != null) {
            return;
        }

        uploadDataMap.put(uploadData.getFile().getAbsolutePath(), uploadData);
        callbackMap.put(uploadData.getFile().getAbsolutePath(), uploadCallback);

        Call upload = DUtil.initFormUpload()
                .url("http://192.168.1.110:8080/file/uploadFile") 
                .addFile("file", uploadData.getFile().getName(), uploadData.getFile())
                .fileUploadBuild()
                .upload(uploadCallback);
        progressHandlerMap.put(uploadData.getFile().getAbsolutePath(), upload);
    }

这样 先简化掉线程上传，回调等问题，先进行去操作可以批上传，进行逻辑。

列表代码

image.png image.png

最后加一键批量下载

image.png

public void startAll(ArrayList<UploadFile> uploadFiles) {
        for (UploadFile bean : uploadFiles) {
            start(bean);
        }
    }