Android多任务多线程断点续传下载

下载这个需求时常遇到,以前是版本更新下载单个apk包,用okhttp+service或者系统提供的DownloadManager实现即可,方便快捷,不涉及多线程多任务下载,特别是DownloadManager提供了完善的断点、状态保存、网络判断等功能,非常适合单一任务的下载情况,但遇到批量下载(类似迅雷的下载)以上的方案就略显不足了。如果全部自己来实现多任务、多线程、断点续传、暂停等功能,那工作量还是很大的,除非所开发的项目是专业下载的app,不然还是别造这个轮子了,就像我现在做的项目,批量下载只是app中一个小小的功能而已,所以我选择用第三方库。我采用的方案是Aria,也看过流利说的开源方案,但是那个库很久没维护,且使用复杂,就选择了aria。目前来看符合项目的需求,下载效果如下:

在这里插入图片描述

我采用service+notification对aria进行了封装,简化外部调用,直接看代码(项目引入请看aria文档):

import android.app.Service;
import android.content.Context;
import android.content.Intent;
import android.os.Binder;
import android.os.Build;
import android.os.CountDownTimer;
import android.os.IBinder;
import android.text.TextUtils;

import androidx.annotation.NonNull;
import androidx.annotation.Nullable;

import com.arialyy.annotations.Download;
import com.arialyy.aria.core.Aria;
import com.arialyy.aria.core.download.DownloadEntity;
import com.arialyy.aria.core.download.DownloadReceiver;
import com.arialyy.aria.core.task.DownloadTask;
import com.orhanobut.logger.Logger;

import java.io.File;
import java.util.List;

/**
 * 集成aria框架的下载service,主要功能:
 * 1、提供前台通知及任务进度通知展示
 * 2、下载任务查重
 * 3、向外部提供进度更新接口
 * <p>
 * 添加下载任务直接调用静态方法{@link #download(Context c, String u, String e)}
 * 在任务列表需要显示进度的页面bindService,通过#OnUpdateStatusListener更新数据
 * <p>
 * aria文档:https://aria.laoyuyu.me/aria_doc/start/start.html
 * Created by ly on 2021/7/19 14:09
 */
public class AriaService extends Service {

    private static final String URL = "url";
    private static final String EXTRA = "extra";
    private static final int FOREGROUND_NOTIFY_ID = 1;
    private static final int PROGRESS_NOTIFY_ID = 2;
    private NotificationUtils notificationUtils;
    private static volatile boolean isForegroundSuc;
    private boolean timerFlag;
    private OnUpdateStatusListener onUpdateStatusListener;

    /**
     * 添加下载任务
     *
     * @param url   下载链接
     * @param extra 展示列表需要保存到数据库的额外数据
     */
    public static void download(@NonNull Context context, @NonNull String url, String extra) {
        if (!TextUtils.isEmpty(url)) {
            Intent intent = new Intent(context, AriaService.class);
            intent.putExtra(URL, url);
            intent.putExtra(EXTRA, extra);

            if (!isForegroundSuc) {
                if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
                    //android8.0以上通过startForegroundService启动service
                    context.startForegroundService(intent);
                } else {
                    context.startService(intent);
                }
            } else {
                context.startService(intent);
            }
        }
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        Logger.d("onBind>>>");
        return new MBinder();
    }

    public class MBinder extends Binder {
        public AriaService getService() {
            return AriaService.this;
        }
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        Logger.d("onStartCommand>>>");
        //只处理start启动并且传入下载url的情况
        if (intent != null && intent.hasExtra(URL)) {
            String url = intent.getStringExtra(URL);
            String extra = intent.getStringExtra(EXTRA);

            if (!isNeedlessDownload(url)) {
                File file = FUtils.createFileIsNotExist(new File(Constants.PATH_DOWNLOAD + System.currentTimeMillis()));
                long taskId = Aria()
                        .load(url)
                        .setExtendField(extra)//自定义数据
                        .setFilePath(file.getAbsolutePath())//设置文件保存的完整路径
                        .create();//启动下载
                if (taskId > 0) {
                    //如果任务创建成功,则开启前台service,开始下载
                    startForeground();
                } else {
                    ToastUtil.showShort(R.string.task_create_fail);
                }
            }

            /*
             * 用startForegroundService启动后5s内还没有startForeground表示没有下载任务,则自动销毁service(否则O及以上的系统会anr)
             * 该操作对用户不可见(startForeground后立马stop了),代价就是创建了一个空service,好处就是外部调用便利。
             *
             * 以下情况可以移除该操作:
             * 1、不在service内做下载查重工作
             * 2、不采用aria下载(aria需要传入this,不灵活。但目前没发现其他更好的方案,无奈。、、)
             */
            if (!timerFlag) {
                timerFlag = true;
                new CountDownTimer(4500, 4500) {

                    public void onTick(long millisUntilFinished) {
                    }

                    public void onFinish() {
                        if (!isForegroundSuc) {
                            startForeground();
                            stopSelf();
                        }
                    }
                }.start();
            }
        }

        return super.onStartCommand(intent, flags, startId);
    }

    @Override
    public void onCreate() {
        super.onCreate();
        Logger.d("onCreate>>>" + this);
        Aria.get(this).getDownloadConfig()
                .setUseBlock(true)
                .setMaxTaskNum(2)
                .setConvertSpeed(false)
                .setUpdateInterval(500);

        Aria().register();

        notificationUtils = new NotificationUtils(this)
                .setNotifyId(PROGRESS_NOTIFY_ID)
                .setTitle(R.string.downloading)
                .setPendingClassName("com.xxx.DownloadTaskActivity");

        notificationUtils.getBuilder()
                .setOngoing(true)//设置通知不可被取消
                .setOnlyAlertOnce(true)
                .setTicker(getString(R.string.downloading));

    }

    private void startForeground() {
        if (!isForegroundSuc) {
            startForeground(FOREGROUND_NOTIFY_ID, notificationUtils.build());
            isForegroundSuc = true;
        }
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        Logger.w("onDestroy>>>");
        isForegroundSuc = false;
        timerFlag = false;
        Aria().unRegister();
    }

    /**
     * 判断本地是否存在,避免重复添加到列表
     */
    private boolean isNeedlessDownload(String url) {
        boolean isExist = Aria().taskExists(url);
        if (isExist) {
            DownloadEntity entity = Aria().getFirstDownloadEntity(url);

            isExist = new File(entity.getFilePath()).exists();
            if (!isExist) {//文件不存在了,则移除记录
                Aria().load(entity.getId()).removeRecord();
            } else {
                Logger.w("该任务已存在:" + url);
            }
        }
        return isExist;
    }

    private void update(DownloadTask task) {
        if (onUpdateStatusListener != null)
            onUpdateStatusListener.update(task);
    }

    private void notification(DownloadTask task, boolean isCompleted) {
        if (isCompleted) {
            //全部下载完成后,重新newBuilder、用户可选择移除通知
            notificationUtils.newBuilder().setTitle(R.string.all_download_completed).setContent("");
            notificationUtils.getBuilder().setTicker(getString(R.string.all_download_completed));

        } else {
            //中间状态的通知设置为静默
            notificationUtils.getBuilder().setNotificationSilent();

            List<DownloadEntity> allTaskList = Aria().getTaskList();
            List<DownloadEntity> completedList = Aria().getAllCompleteTask();
            int taskNum = allTaskList == null ? 0 : allTaskList.size();
            int completeNum = completedList == null ? 0 : completedList.size();

            notificationUtils.setTitle(getString(R.string.download_progress) + completeNum + "/" + taskNum)
                    .setContent(getString(R.string.cur_download_task) + task.getTaskName());
        }

        notificationUtils.send();
    }

    public void setOnUpdateStatusListener(OnUpdateStatusListener onUpdateStatusListener) {
        this.onUpdateStatusListener = onUpdateStatusListener;
    }

    public interface OnUpdateStatusListener {
        void update(DownloadTask task);
    }

    public DownloadReceiver Aria() {
        return Aria.download(this);
    }

    public void cancelNotification() {
        notificationUtils.cancel(FOREGROUND_NOTIFY_ID);
        notificationUtils.cancel();
    }


    //-----------aria框架回调-------------
    @Download.onTaskPre
    public void onTaskPre(DownloadTask task) {
        update(task);
    }

    @Download.onTaskStart
    public void onTaskStart(DownloadTask task) {
        update(task);
        notification(task, false);
    }

    @Download.onTaskStop
    public void onTaskStop(DownloadTask task) {
        update(task);
    }

    @Download.onTaskResume
    public void onTaskResume(DownloadTask task) {
        update(task);
        notification(task, false);
    }

    @Download.onTaskCancel
    public void onTaskCancel(DownloadTask task) {
        update(task);
    }

    @Download.onTaskFail
    public void onTaskFail(DownloadTask task) {
        update(task);
    }

    @Download.onTaskComplete
    public void onTaskComplete(DownloadTask task) {
        Logger.i("onTaskComplete>>>>" + task.getTaskName());
        update(task);

        List<DownloadEntity> list = Aria().getAllNotCompleteTask();
        List<DownloadEntity> completedList = Aria().getAllCompleteTask();

        int unCompleteNum = list == null ? 0 : list.size();
        if (unCompleteNum == 0 && completedList != null && !completedList.isEmpty()) {
            notification(task, true);
            ToastUtil.showShort(R.string.all_download_completed);
            //移除前台通知
            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) {
                stopForeground(true);
                isForegroundSuc = false;
            }
            //全部完成,结束service
            stopSelf();
        } else {
            notification(task, false);
        }
    }

    @Download.onTaskRunning
    public void onTaskRunning(DownloadTask task) {
        update(task);
    }
}

service中有一些基础的工具类没有贴出,替换成你自己的即可。

外部只需调用内部的download方法即可(最好自己先处理一下文件读写权限),需要注意的是DownloadItem 是显示用的额外实体类,传入后aria会把它与下载任务关联并以string的形式保存到数据库:

DownloadItem downloadIte = new DownloadItem();
downloadIte.taskNameDesc = "test";
downloadIte.coverPic = "https://t7.baidu.com/it/u=2621658848,3952322712&fm=193&f=GIF.jpg";
AriaService.download(CloudMineActivity.this, url, new Gson().toJson(downloadIte));

通知工具类还是贴一下吧:

import android.app.Notification;
import android.app.NotificationChannel;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.content.Context;
import android.content.Intent;
import android.os.Build;
import android.text.TextUtils;

import androidx.annotation.IntRange;
import androidx.annotation.NonNull;
import androidx.annotation.StringRes;
import androidx.core.app.NotificationCompat;
import androidx.core.app.NotificationManagerCompat;

import java.util.Random;


/**
 * Created by ly on 2021/7/19 17:04
 */
public class NotificationUtils {

    private static final int MAX = 100;
    private int notifyId;
    private String channelId;
    private NotificationCompat.Builder builder;
    private final NotificationManager notificationManager;
    private NotificationManagerCompat notificationManagerCompat;

    private String title, content;
    private int progress;
    private PendingIntent pendingIntent;
    private final Context mContext;

    public NotificationUtils(@NonNull Context context) {
        this.mContext = context;

        notificationManager = (NotificationManager) mContext.getSystemService(Context.NOTIFICATION_SERVICE);
        newBuilder();
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            //创建通知渠道
            CharSequence name = "default";
            String description = "default";
            int importance = NotificationManager.IMPORTANCE_HIGH;//重要性级别 这里用默认的
            NotificationChannel mChannel = new NotificationChannel(getChannelId(), name, importance);

            mChannel.setDescription(description);//渠道描述
            mChannel.enableLights(true);//是否显示通知指示灯
            mChannel.enableVibration(true);//是否振动

            notificationManager.createNotificationChannel(mChannel);//创建通知渠道
        } else {
            notificationManagerCompat = NotificationManagerCompat.from(mContext);
        }
    }

    public NotificationUtils newBuilder() {
        builder = new NotificationCompat.Builder(mContext, getChannelId());
        return this;
    }

    public NotificationUtils send() {
        return send(notifyId);
    }

    public NotificationUtils send(int notifyId) {
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            notificationManager.notify(notifyId, build());
        } else {
            notificationManagerCompat.notify(notifyId, build());
        }
        return this;
    }

    public Notification build() {
        builder.setSmallIcon(R.mipmap.ic_launcher)
                .setPriority(NotificationCompat.PRIORITY_MAX)
                //铃声、闪光、震动均系统默认
                .setDefaults(Notification.DEFAULT_ALL)
                .setAutoCancel(true)
                .setContentTitle(title)
                .setContentText(content);

        if (progress > 0 && progress < MAX) {
            builder.setProgress(MAX, progress, false);
        } else {
            builder.setProgress(0, 0, false);
        }
        if (pendingIntent != null) {
            builder.setContentIntent(pendingIntent).setAutoCancel(true);
            builder.setFullScreenIntent(pendingIntent, true);
        }

        return builder.build();
    }

    public void cancel() {
        cancel(notifyId);
    }

    public void cancel(int notifyId) {
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            notificationManager.cancel(notifyId);
        } else {
            notificationManagerCompat.cancel(notifyId);
        }
    }

    public NotificationUtils setTitle(@StringRes int title) {
        this.title = mContext.getString(title);
        return this;
    }

    public NotificationUtils setContent(@StringRes int content) {
        this.content = mContext.getString(content);
        return this;
    }

    public NotificationUtils setTitle(String title) {
        this.title = title;
        return this;
    }

    public NotificationUtils setContent(String content) {
        this.content = content;
        return this;
    }


    public NotificationUtils setProgress(@IntRange(from = 0, to = MAX) int progress) {
        this.progress = progress;
        return this;
    }

    public NotificationUtils setPendingClass(Class<?> cls) {
        Intent intent = new Intent(mContext, cls);
        pendingIntent = PendingIntent.getActivity(mContext, 0, intent, 0);
        return this;
    }

    public NotificationUtils setPendingClassName(String cls) {
        Intent intent = new Intent();
        intent.setClassName(mContext, cls);
        pendingIntent = PendingIntent.getActivity(mContext, 0, intent, 0);
        return this;
    }

    public NotificationUtils setNotifyId(int notifyId) {
        this.notifyId = notifyId;
        return this;
    }

    public NotificationUtils setChannelId(String channelId) {
        this.channelId = channelId;
        return this;
    }

    public int getNotifyId() {
        if (notifyId == 0)
            this.notifyId = new Random().nextInt() + 1;
        return notifyId;
    }

    public String getChannelId() {
        if (TextUtils.isEmpty(channelId))
            this.channelId = String.valueOf(new Random().nextInt() + 1);
        return channelId;
    }

    public String getTitle() {
        return title;
    }

    public String getContent() {
        return content;
    }

    public int getProgress() {
        return progress;
    }

    public NotificationCompat.Builder getBuilder() {
        return builder;
    }
}

到此,下载的全部代码都分享完毕,说一下我对aria的一些看法:
1、框架335kb,挺大的了,里面包含了http、下载上传等功能,不精简。作者如果能把http、上传等功能分离抽出来做成可选依赖会更好。
2、目前没找到批量添加下载任务的api(发现的朋友请留言告诉我

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,634评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,951评论 3 391
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 161,427评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,770评论 1 290
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,835评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,799评论 1 294
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,768评论 3 416
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,544评论 0 271
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,979评论 1 308
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,271评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,427评论 1 345
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,121评论 5 340
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,756评论 3 324
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,375评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,579评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,410评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,315评论 2 352

推荐阅读更多精彩内容