Android实现下载m3u8视频文件问题解决

目录
  • 效果图
  • 简介
    • Aria
    • 导入Aria
    • 介绍
  • 启动Service
  • DownloadService
    • 下载回调
  • 回调接口
  • 单例Binder
    • 构造单例
    • 下载
  • 辐射
  • 创建下载实例
  • 监听下载状态

效果图

简介

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视频文件问题解决的文章就介绍到这了,更多相关Android下载m3u8视频内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • Android 边播边缓存的实现(MP4 未加密m3u8)

    实现思路 红色框的 ProxyServer就是需要实现的一个代理服务器. 当客户端拿到一个视频的url(mp4或者m3u8)时,通过proxyServer转化为一个代理的url,然后请求代理服务器:代理服务器接收到客户端的请求后,先查看本地是否存在缓存,如果不存在则向真实服务器发送请求,拿到结果后再存到本地. 实现重点 缓存是一个代理服务器的主要部分,所以这部分是一个重点.本设计的缓存是一个分片的LRU缓存.分片的好处是灵活方便做LRU.当真实服务器返回一个大文件时,我们在进行切割后缓存在本地,

  • Python解析m3u8拼接下载mp4视频文件的示例代码

    一.关于m3u8: m3u8是苹果公司推出一种视频播放标准,是m3u的一种,不过编码方式是utf-8,是一种文件检索格式,将视频切割成一小段一小段的ts格式的视频文件,然后存在服务器中(现在为了减少I/o访问次数,一般存在服务器的内存中),通过m3u8解析出来路径,然后去请求. 示例: #EXTM3U #EXT-X-TARGETDURATION:10 #EXTINF:9, http://data.video.iqiyi.com/videos/vts/20210301/69/b8/73ad4ef0

  • python 下载m3u8视频的示例代码

    import requests import os import datetime import threading class xiazai(): def __init__(self,url): self.url = url work_dir = os.getcwd() # print(work_dir) # 用来保存ts文件 file_dir = os.path.join(work_dir, 'file_tmp') if not os.path.exists(file_dir): os.mk

  • Android中如何获取视频文件的截图、缩略图

    背景 公司最近要求给我负责的APP加上视频录制和发布的功能,我简单的完成了基本的录制和视频压缩功能,后来发现发布接口需要上传视频的截图,网上搜索了一下资料,在这里整理一下. 代码实现 /** * 获取视频文件截图 * * @param path 视频文件的路径 * @return Bitmap 返回获取的Bitmap */ public static Bitmap getVideoThumb(String path) { MediaMetadataRetriever media = new Me

  • Android实现下载zip压缩文件并解压的方法(附源码)

    前言 其实在网上有很多介绍下载文件或者解压zip文件的文章,但是两者结合的不多,所以这篇文章在此记录一下下载zip文件并直接解压的方法,直接上代码,文末有源码下载. 下载: import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream

  • python基于tkinter制作m3u8视频下载工具

    这是我为了学习tkinter用python 写的一个下载m3u8视频的小程序,程序使用了多线程下载,下载后自动合并成一个视频文件,方便播放. 目前的众多视频都是m3u8的播放类型,只要知道视频的m3u8地址,就可以完美下载整个视频. m3u8地址获取 打开浏览器,点开你要获取地址的视频 重要的来了,右键>>审查元素或者按F12也可以 根据开发或测试的实际环境选择相应的设备,选择iphone6 plus 选择好了以后,刷新页面,点击漏斗,选择media,一定刷新之后再点击,没出来的话切换几下选项

  • Android raw 目录下视频的缩略图的获取

     Android raw 目录下视频的缩略图的获取 以下代码用于获取 Android raw目录下视频文件的缩略图: /** * 获取 raw 下 指定视频文件的缩略图 * @param aVideoName * @return */ private Drawable getThumbnail(String aVideoName) { Drawable ret = null; int id = 0; try { id = R.raw.class.getDeclaredField(aVideoNa

  • Android播放assets文件里视频文件相关问题分析

    本文实例讲述了Android播放assets文件里视频文件相关问题.分享给大家供大家参考,具体如下: 今天做了一个功能,就是播放项目工程里面的视频文件,不是播放SD卡视频文件. 我开始尝试把视频文件放到 assets文件目录下. 因为之前写webview加载assets文件夹时,是这样写的: webView = new WebView(this); webView.loadUrl(file:///android_asset/sample3_8.html); 依次类推,我尝试将视频video.3g

  • Android Studio 下载视频到本地

    最近在研究视频下载到本地的问题,像爱奇艺,腾讯视频,迅雷看看等等一些视频播放器,如果在一个播放器里面视频下载到一半用户退出App之后,再次登录从头开始,那么就太可悲了,所以在做视频音频类的项目时,要实现的一个功能就是断点续传,就是将用户下载的视频或者音频等以字节流的形式存入数据库,下次用户再次下载时,将继续上次数据库的接着下载,这样用户体验就会很好,也大大节省了成本. 好了废话不多说,开始今天的正题. 一.先上效果图 二.使用GreenDao我们需要导入依赖 1.以下在项目gradle依赖中添加

  • python3.6根据m3u8下载mp4视频

    需要下载某网站的视频,chrome浏览器按F12打开开发者模式,发现视频链接是以"blob:http"开头的链接,打开这个链接后找不到网页,网上查了下,找到了下载方法,在这里做个记录,如果有错误,欢迎指出. 程序在Windows 10下运行,不过Linux应该也没问题. 使用到的有re模块,requests模块和Crypto模块,其中requests模块和Crypto模块如果没安装可以使用pip命令安装.(Crypto模块安装感觉比较坑,我是从anaconda里拷贝了一份) 下面开始正

  • python 实现多线程下载m3u8格式视频并使用fmmpeg合并

    电影之类的长视频好像都用m3u8格式了,这就导致了多线程下载视频的意义不是很大,都是短视频,线不线程就没什么意义了嘛. 我们知道,m3u8的链接会下载一个文档,相当长,半小时的视频,应该有接近千行ts链接. 这些ts链接下载成ts文件,就是碎片化的视频,加以合并,就成了需要的视频. 那,即便网速很快,下几千行视频,效率也就低了,更何况还要合并.我就琢磨了一下午,怎么样才能多线程下载m3u8格式的视频呢? 先上代码,再说重难点: import datetime import os import r

随机推荐

其他