温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Android如何实现下载m3u8视频文件功能

发布时间:2023-01-17 09:29:12 来源:亿速云 阅读:112 作者:iii 栏目:开发技术

本篇内容主要讲解“Android如何实现下载m3u8视频文件功能”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Android如何实现下载m3u8视频文件功能”吧!

    简介

    Aria

    下载器采用开源框架Aria

    github

    中文文档

    导入Aria

       implementation 'me.laoyuyu.aria:core:3.8.16'
        annotationProcessor 'me.laoyuyu.aria:compiler:3.8.16'
        implementation 'me.laoyuyu.aria:m3u8:3.8.16'

    介绍

    service在Appliaction中启动,即启动app即启动service并且service只启动一次,后序通过单例binder去调用服务

    启动Service

    在Application中默认启动Service

    private void bindService(){
            DownloadService.bindService(this, new ServiceConnection() {
                @Override
                public void onServiceConnected(ComponentName name, IBinder service) {
                }
                @Override
                public void onServiceDisconnected(ComponentName name) {
                    downloadService = null;
                }
            });
        }

    DownloadService

    用于Aplication调用起服务

    public static void bindService(Context context, ServiceConnection connection){
            Intent intent = new Intent(context, DownloadService.class);
            context.bindService(intent, connection, Service.BIND_AUTO_CREATE);
        }

    注册下载器

    @Override
        public void onCreate() {
            super.onCreate();
            Aria.download(this).register();
            Log.d("DownloadService","create service");
        }

    若上次有未下载完成的视频,则恢复下载,并将binder赋给另一个单例binder,后续使用binder进行具体下载事项

    @Nullable
        @Override
        public IBinder onBind(Intent intent) {
            Log.d("DownloadService","bind service");
            long taskId = (long)SP.getInstance().GetData(BaseApplication.getContext(),"lastDownloadID",0L);
            if (taskId != 0L){
                List<DownloadEntity> entityList = Aria.download(this).getAllNotCompleteTask();
                if (entityList != null){
                    HttpNormalTarget target = Aria.download(this).load(taskId);
                    if (target.getTaskState() != STATE_COMPLETE){
                        target.m3u8VodOption(DownloadBinder.getInstance().getOption());
                        target.resume();
                        Log.d("DownloadService","resume download");
                    } else {
                        HttpNormalTarget resume =  Aria.download(this).load( entityList.get(0).getId());
                        resume.m3u8VodOption(DownloadBinder.getInstance().getOption());
                        if ((resume.getTaskState() == STATE_FAIL) || (resume.getTaskState() == STATE_OTHER)){
                            resume.resetState();
                            Log.d("DownloadService","resetState");
                        }else {
                            resume.resume();
                            Log.d("DownloadService","resumeState");
                        }
                    }
                }
            }
            return DownloadBinder.getInstance();
        }

    注销aria下载器和解除binder绑定

     @Override
        public boolean onUnbind(Intent intent) {
            Log.d("DownloadService","unbind service");
            return super.onUnbind(intent);
        }
        @Override
        public void onDestroy() {
            super.onDestroy();
            Aria.download(this).unRegister();
            Log.d("DownloadService","service onDestroy");
        }

    下载回调

    然后将Aria下载器的回调在进行一次中转,回调至单例binder,后面在下载就不需要binder服务,直接调用单例binder即可

        @Download.onNoSupportBreakPoint public void onNoSupportBreakPoint(DownloadTask task) {
            Log.d("DownloadService","该下载链接不支持断点");
           // DownloadBinder.getInstance().onTaskStart(task);
        }
        @Download.onTaskStart public void onTaskStart(DownloadTask task) {
            Log.d("DownloadService",task.getDownloadEntity().getFileName() +":开始下载");
            DownloadBinder.getInstance().onTaskStart(task);
        }
        @Download.onTaskStop public void onTaskStop(DownloadTask task) {
            Log.d("DownloadService",task.getDownloadEntity().getFileName() +":停止下载");
            DownloadBinder.getInstance().onTaskStop(task);
        }
        @Download.onTaskCancel public void onTaskCancel(DownloadTask task) {
            Log.d("DownloadService",task.getDownloadEntity().getFileName() +":取消下载");
            DownloadBinder.getInstance().onTaskCancel(task);
        }
        @Download.onTaskFail public void onTaskFail(DownloadTask task) {
            Log.d("DownloadService",task.getDownloadEntity().getFileName() +":下载失败");
            DownloadBinder.getInstance().onTaskFail(task);
        }
        @Download.onTaskComplete public void onTaskComplete(DownloadTask task) {
            Log.d("DownloadService",task.getDownloadEntity().getFileName() +":下载完成");
            DownloadBinder.getInstance().onTaskComplete(task);
        }
        /**
         * @param e 异常信息
         */
        @Download.onTaskFail void taskFail(DownloadTask task, Exception e) {
            try {
                DownloadBinder.getInstance().taskFail(task,e);
                ALog.d("DownloadService", task.getDownloadEntity().getFileName() +"error:"+ALog.getExceptionString(e));
            }catch (Exception ee){
                ee.printStackTrace();
            }
        }
        @Download.onTaskRunning public void onTaskRunning(DownloadTask task) {
            Log.d("DownloadService","pre = "+task.getPercent()+"   "+"speed = "+ task.getConvertSpeed());
            DownloadBinder.getInstance().onTaskRunning(task);
        }
    }

    回调接口

    将服务中的Aria回调,回调至单例binder中

    public interface ServiceCallback {
        void onTaskStart(DownloadTask task);
        void onTaskStop(DownloadTask task);
        void onTaskCancel(DownloadTask task);
        void onTaskFail(DownloadTask task);
        void onTaskComplete(DownloadTask task);
        void onTaskRunning(DownloadTask task);
        void taskFail(DownloadTask task, Exception e);
    }

    单例Binder

    构造单例

    public class DownloadBinder extends Binder implements ServiceCallback {
     private static DownloadBinder binder;
        private DownloadBinder() {
        }
        public static DownloadBinder getInstance() {
            if (binder == null) {
                binder = new DownloadBinder();
                downloadReceiver = Aria.download(BaseApplication.getContext());
            }
            return binder;
        }

    下载

    将下载信息传入,并以视频type+id+name等构件下载文件夹名称,确保唯一性,然后通过配置Aria Option,使其切换至m3u8文件下载模式,具体配置文件还可配置下载速度、最大下载文件数量、线程数等等。

    Aria自带数据库,可通过其数据库保存一些数据,但读取数据较慢

        public void startDownload(DownloadBean downloadBean) {
            if (downloadBean == null) return;
            String locationDir = FileUtils.getInstance().mainCatalogue();
            String name = downloadBean.getVideoType()+downloadBean.gettId() + downloadBean.getsId() + downloadBean.geteId();
            String subFile = FileUtils.getInstance().createFile(locationDir, name);
            String path = subFile + File.separator + name + ".m3u8";
            Log.d("DownloadService", "start download");
            boolean isExist = IsExist(path);
            if (isExist) {
                Log.d("DownloadService", "exist same item");
                if (repeatTaskId != 0) {
                    if (Aria.download(this).load(repeatTaskId).getTaskState() != STATE_RUNNING) {
                        if (downloadReceiver.load(repeatTaskId).getEntity().getRealUrl().equals(downloadBean.getVideoUrl())) {
                            downloadReceiver.load(repeatTaskId).m3u8VodOption(DownloadBinder.getInstance().getOption());
                            downloadReceiver.load(repeatTaskId).resume();
                        } else {
                            downloadReceiver.load(repeatTaskId).m3u8VodOption(DownloadBinder.getInstance().getOption());
                            downloadReceiver.load(repeatTaskId).updateUrl(downloadBean.getVideoUrl()).resume();
                        }
                    }
                    Log.d("DownloadService", "resume exist same item");
                    return;
                }
            }
            HttpBuilderTarget target = downloadReceiver.load(downloadBean.getVideoUrl())
                    .setFilePath(path)
                    .ignoreFilePathOccupy()
                    .m3u8VodOption(getOption());
            List<DownloadEntity> downloadEntityList = downloadReceiver.getDRunningTask();
            if (downloadEntityList == null) {
                repeatTaskId = target.create();
            } else {
                repeatTaskId = target.add();
            }
            try {
                repeatTaskId = target.getEntity().getId();
                downloadBean.setTaskId(repeatTaskId);
                SP.getInstance().PutData(BaseApplication.getContext(),"lastDownloadID",repeatTaskId);
                target.setExtendField(new Gson().toJson(downloadBean)).getEntity().save();
            }catch (NullPointerException e){
                e.printStackTrace();
            }
        }

    辐射

    再一次将service回调的接口回调至binder的接口,通过EventBus辐射至外部,通过一层层封装,在外部监听当前文件下载状态,只需通过监听EventBus事件即可

     /**
         * download status
         * 0:prepare
         * 1:starting
         * 2:pause
         * 3:cancel
         * 4:failed
         * 5:completed
         * 6:running
         * 7:exception*/
        @Override
        public void onTaskStart(DownloadTask task) {
            EventBus.getDefault().postSticky(new DownloadStatusBean(1,task.getDownloadEntity().getId(), task.getConvertSpeed(), task.getPercent(),task.getConvertFileSize(),task.getFilePath()));
        }
        @Override
        public void onTaskStop(DownloadTask task) {
            EventBus.getDefault().postSticky(new DownloadStatusBean(2,task.getDownloadEntity().getId(), task.getConvertSpeed(), task.getPercent(),task.getConvertFileSize(),task.getFilePath()));
        }
        @Override
        public void onTaskCancel(DownloadTask task) {
            EventBus.getDefault().postSticky(new DownloadStatusBean(3,task.getDownloadEntity().getId(), task.getConvertSpeed(), task.getPercent(),task.getConvertFileSize(),task.getFilePath()));
        }
        @Override
        public void onTaskFail(DownloadTask task) {
            EventBus.getDefault().postSticky(new DownloadStatusBean(4,task.getDownloadEntity().getId(), task.getConvertSpeed(), task.getPercent(),task.getConvertFileSize(),task.getFilePath()));
        }
        @Override
        public void onTaskComplete(DownloadTask task) {
            EventBus.getDefault().postSticky(new DownloadStatusBean(5,task.getDownloadEntity().getId(), task.getConvertSpeed(), task.getPercent(),task.getConvertFileSize(),task.getFilePath()));
        }
        @Override
        public void onTaskRunning(DownloadTask task) {
            EventBus.getDefault().postSticky(new DownloadStatusBean(6,task.getDownloadEntity().getId(), task.getConvertSpeed(), task.getPercent(),task.getConvertFileSize(),task.getFilePath()));
        }
        @Override
        public void taskFail(DownloadTask task, Exception e) {
            try {
                EventBus.getDefault().postSticky(new DownloadStatusBean(4,task.getDownloadEntity().getId(), task.getConvertSpeed(), task.getPercent(),task.getConvertFileSize(),task.getFilePath()));
            }catch (NullPointerException ee){
                ee.printStackTrace();
            }
        }
    }

    创建下载实例

    一句话我们就可以实现视频下载,然后后天服务自动回调给binder,然后binder回调给EventBus

     DownloadBean bean = new DownloadBean(0L,m_id,"","",sourceBean.getLink(),detailBean.getCover(),detailBean.getTitle(),"","","movie","",0);
      DownloadBinder.getInstance().startDownload(bean);

    监听下载状态

    然后只需要在需要更新界面的地方注册EventBus即可,通过封装,不同的类做不同的事情,将数据处理和UI更新进行隔离,可以提高代码阅读和执行效率

     /**
         * download status
         * 0:prepare
         * 1:starting
         * 2:pause
         * 3:cancel
         * 4:failed
         * 5:completed
         * 6:running
         * 7:exception*/
        /**
         * 下载item状态监听*/
        @Subscribe(threadMode = ThreadMode.MAIN, sticky = true)
        public void OnEvent(DownloadStatusBean bean) {
            taskID = bean.getTaskID();
            switch (bean.getStatus()) {
                case 1:
                    getRunningItem();
                    Log.d("DownloadService", "status start");
                    break;
                case 2:
                    updateStatus(bean);
                    Log.d("DownloadService", "status pause");
                    break;
                case 3:
                    if ((index == -1) && (beanList.size() > 0)){
                        index = 0;
                    }
                    Log.d("DownloadService", "status cancel"+bean.getTaskID());
                    break;
                case 4:
                    //update url
                    failCount++;
                    if (failCount >= 3){
                        failedReconnect(bean);
                        failCount = 0;
                        isRunning = true;
                        Log.d("DownloadService", "status fail in");
                    }
                    Log.d("DownloadService", "status fail");
                    break;
                case 5:
                    removeDownloadBead(bean.getTaskID());
                    startDownload();
                    Log.d("DownloadService", "status complete");
                    break;
                case 6:
                    if (isRunning) {
                        getRunningItem();
                    }
                    updateCurItem(bean);
                    Log.d("DownloadService", "status running: "+index);
                    break;
            }
        }

    到此,相信大家对“Android如何实现下载m3u8视频文件功能”有了更深的了解,不妨来实际操作一番吧!这里是亿速云网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

    向AI问一下细节

    免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

    AI