从AsyncTask迁移到RxJava2：如何发送进度消息与结果对象？

嘿，我来帮你搞定这个用AsyncTask实现文件下载+处理，还能清晰区分两种进度消息的需求～

核心思路 #

因为你需要区分下载阶段和处理阶段的不同格式进度消息，还要最终返回List<File>，我们可以用一个自定义的ProgressUpdate类来封装进度类型和内容，这样onProgressUpdate就能轻松区分处理两种进度消息，完美适配AsyncTask的泛型参数特性。

具体实现步骤 #

1. 定义进度封装类 #

先创建一个简单的内部类，用来标记进度类型（下载/处理），同时携带对应的消息内容：

// 封装进度类型和消息的内部类
private static class ProgressUpdate {
    public enum Type { DOWNLOAD, PROCESS }
    public Type type;
    public String message;

    public ProgressUpdate(Type type, String message) {
        this.type = type;
        this.message = message;
    }
}

2. 实现自定义AsyncTask #

AsyncTask的泛型参数设为：Params用String（传入下载链接），Progress用我们的ProgressUpdate，Result用List<File>，这样每个方法的职责和参数类型就清晰区分开了：

public class FileDownloadProcessTask extends AsyncTask<String, ProgressUpdate, List<File>> {

    @Override
    protected void onPreExecute() {
        super.onPreExecute();
        // 初始化操作，比如显示加载提示
        publishProgress(new ProgressUpdate(ProgressUpdate.Type.DOWNLOAD, "Connecting..."));
    }

    @Override
    protected List<File> doInBackground(String... urls) {
        List<File> downloadedFiles = new ArrayList<>();
        // 第一阶段：下载文件
        for (String url : urls) {
            publishProgress(new ProgressUpdate(ProgressUpdate.Type.DOWNLOAD, "Downloading " + url + "..."));
            // 替换成你的实际下载逻辑
            File downloadedFile = downloadFileFromServer(url);
            if (downloadedFile != null) {
                downloadedFiles.add(downloadedFile);
                publishProgress(new ProgressUpdate(ProgressUpdate.Type.DOWNLOAD, "Downloaded " + downloadedFile.getName()));
            }
        }

        // 第二阶段：处理文件
        int totalFiles = downloadedFiles.size();
        for (int i = 0; i < totalFiles; i++) {
            File file = downloadedFiles.get(i);
            publishProgress(new ProgressUpdate(ProgressUpdate.Type.PROCESS, "Processed file " + (i+1) + "/" + totalFiles));
            // 替换成你的实际文件处理逻辑
            processFile(file);
        }

        return downloadedFiles;
    }

    @Override
    protected void onProgressUpdate(ProgressUpdate... values) {
        super.onProgressUpdate(values);
        ProgressUpdate update = values[0];
        // 根据进度类型区分处理不同消息
        switch (update.type) {
            case DOWNLOAD:
                // 更新下载进度UI，比如显示在TextView里
                Log.d("DownloadStatus", update.message);
                break;
            case PROCESS:
                // 更新文件处理进度UI
                Log.d("ProcessStatus", update.message);
                break;
        }
    }

    @Override
    protected void onPostExecute(List<File> result) {
        super.onPostExecute(result);
        // 处理最终结果，比如通知用户任务完成，或者用这个文件列表做后续操作
        Log.d("TaskFinish", "All done! Total processed files: " + result.size());
        // 这里可以把result传递给上层业务逻辑
    }

    // 模拟下载方法，实际替换成你的网络下载实现
    private File downloadFileFromServer(String url) {
        // 省略真实下载代码，返回一个模拟的File对象
        return new File(url.substring(url.lastIndexOf("/") + 1));
    }

    // 模拟文件处理方法，实际替换成你的业务处理代码
    private void processFile(File file) {
        // 省略真实处理逻辑，模拟耗时操作
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

3. 启动AsyncTask #

在你的Activity/Fragment里直接调用即可：

// 传入需要下载的文件链接数组
new FileDownloadProcessTask().execute("https://example.com/file1.pdf", "https://example.com/file2.jpg");

关键说明 #

• 用ProgressUpdate类封装进度类型，完美解决了AsyncTask进度参数只能是单一类型的限制，清晰区分下载和处理阶段的消息。
• 严格遵循Android线程规范：doInBackground只做耗时操作（下载+处理），不碰UI；onProgressUpdate和onPostExecute负责UI更新和结果处理。
• 最终的List<File>会在onPostExecute中返回，你可以在这里完成后续的业务逻辑。

内容的提问来源于stack exchange，提问作者Daniel F