okhttp3下载文件检测进度与断点续传

之前有用过retrofit来做下载的功能,虽然retrofit基于okhttp,但是这还是有点不同。
我是在做更新功能的时候用到这个,具体的操作可能不会说太多,因为网上能找到很多基本的操作,我就说下一些流程和BUG,不管是okhttp还是retrofit都适用。

一.下载文件

1.下载操作

下载文件其实我感觉并不像上传那么复杂,就按照拉取文本文件一样弄就行。
这是我普通的用okhttp的get请求

        Request request = new Request.Builder()
                .url(murl)
                .build();
        Call call = okHttpClient.newCall(request);
        call.enqueue(callback);

下载文件的操作其实差不多

public Call download(String url, final DownloadListener downloadListener, final long startsPoint, Callback callback){
        Request request = new Request.Builder()
                .url(url)
                .header("RANGE", "bytes=" + startsPoint + "-")//断点续传
                .build();

        // 重写ResponseBody监听请求
        Interceptor interceptor = new Interceptor() {
            @Override
            public Response intercept(Chain chain) throws IOException {
                Response originalResponse = chain.proceed(chain.request());
                return originalResponse.newBuilder()
                        .body(new DownloadResponseBody(originalResponse, startsPoint, downloadListener))
                        .build();
            }
        };
        
        OkHttpClient.Builder dlOkhttp = new OkHttpClient.Builder()
                .addNetworkInterceptor(interceptor);
        // 绕开证书
        try {
            setSSL(dlOkhttp);
        } catch (Exception e) {
            e.printStackTrace();
        }
        
        // 发起请求
        Call call = dlOkhttp.build().newCall(request);
        call.enqueue(callback);
        return call;
    }

注释讲得也比较请求,要重写ResponseBody是因为要监听下载进度,网上有很多人的写法是在onResponse的回调中读写字节到本地时监听进度,我建议是重写ResponseBody来监听下载进度,因为好像写在onResponse会有什么问题我忘记了,就算没问题,自定义ResponseBody也会显得更灵活。

2.自定义的ResponseBody
public class DownloadResponseBody extends ResponseBody{

    private Response originalResponse;
    private DownloadListener downloadListener;
    private long oldPoint = 0;

    public DownloadResponseBody(Response originalResponse, long startsPoint, DownloadListener downloadListener){
        this.originalResponse = originalResponse;
        this.downloadListener = downloadListener;
        this.oldPoint = startsPoint;
    }

    @Override
    public MediaType contentType() {
        return originalResponse.body().contentType();
    }

    @Override
    public long contentLength() {
        return originalResponse.body().contentLength();
    }

    @Override
    public BufferedSource source() {
        return Okio.buffer(new ForwardingSource(originalResponse.body().source()) {
            private long bytesReaded = 0;
            @Override
            public long read(Buffer sink, long byteCount) throws IOException {
                long bytesRead = super.read(sink, byteCount);
                bytesReaded += bytesRead == -1 ? 0 : bytesRead;
                if (downloadListener != null) {
                    downloadListener.loading((int) ((bytesReaded+oldPoint)/(1024)));
                }
                return bytesRead;
            }
        });
    }

}

主要就是要重写这个source方法来实现监听,代码也不难,其实不用多说什么。

3.定义请求中的回调

最好是用一个接口来定义在下载过程中的行为,接口的好处不用多说

public interface DownloadListener {

    /**
     *  开始下载
     */
    void start(long max);
    /**
     *  正在下载
     */
    void loading(int progress);
    /**
     *  下载完成
     */
    void complete(String path);
    /**
     *  请求失败
     */
    void fail(int code, String message);
    /**
     *  下载过程中失败
     */
    void loadfail(String message);
}

我这里定义了两种失败,主要是这边要根据请求网络的失败和读写过程的失败写不同的逻辑,如果没有特定的需求,这里只定义一个失败的回调也是可以的。

二.下载的文件保存到本地

okhttp中是写在onResponse方法中进行io操作,retrofit可以写在onNext中

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                long length = response.body().contentLength();
                if (length == 0){
                    // 说明文件已经下载完,直接跳转安装就好
                    downloadListener.complete(String.valueOf(getFile().getAbsoluteFile()));
                    return;
                }
                downloadListener.start(length+startsPoint);
                // 保存文件到本地
                InputStream is = null;
                RandomAccessFile randomAccessFile = null;
                BufferedInputStream bis = null;

                byte[] buff = new byte[2048];
                int len = 0;
                try {
                    is = response.body().byteStream();
                    bis  =new BufferedInputStream(is);

                    File file = getFile();
                    // 随机访问文件,可以指定断点续传的起始位置
                    randomAccessFile =  new RandomAccessFile(file, "rwd");
                    randomAccessFile.seek (startsPoint);
                    while ((len = bis.read(buff)) != -1) {
                        randomAccessFile.write(buff, 0, len);
                    }

                    // 下载完成
                    downloadListener.complete(String.valueOf(file.getAbsoluteFile()));
                } catch (Exception e) {
                    e.printStackTrace();
                    downloadListener.loadfail(e.getMessage());
                } finally {
                    try {
                        if (is != null) {
                            is.close();
                        }
                        if (bis != null){
                            bis.close();
                        }
                        if (randomAccessFile != null) {
                            randomAccessFile.close();
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }

            }
        });

    private File getFile() {
        String root = Environment.getExternalStorageDirectory().getPath();
        File file = new File(root,"updateDemo.apk");
        return file;
    }

    private long getFileStart(){
        String root = Environment.getExternalStorageDirectory().getPath();
        File file = new File(root,"updateDemo.apk");
        return file.length();
    }

因为我们之前在请求时写了


这里先获取报文的长度,如果长度为0,说明在我门本地已经下载好文件了,这里就不用下载了,直接跳转到安装。这个主要是对断点续传的一个判断,你想想,如果我都已经下载完文件了,那我有什么必要再去开启io流。
这里还要注意一下,获取文件长度用file.length()而不用fis.available()是因为网上有个朋友测试过用fis.available()如果数据过大的话会出问题。

downloadListener.start(length+startsPoint);是我在开始读写前要先给ProgressBar设最大值。
读写时用到RandomAccessFile,这个主要是能随时读写,做的就是断点续传的操作。其实断点续传主要就三句代码

.header("RANGE", "bytes=" + startsPoint + "-")
 randomAccessFile =  new RandomAccessFile(file, "rwd");
 randomAccessFile.seek (startsPoint);

后面就没有什么了,就是普通的io操作。

三.安装应用

下载完成后跳转到安装页面,需要做一个7.0的判断

    private void installApk(String path){
        try {
            Intent intent = new Intent(Intent.ACTION_VIEW);
            File file = new File(path);
            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) {
                intent.setFlags(Intent.FLAG_GRANT_READ_URI_PERMISSION);
                String authority = "com.example.kylin.mindabs" + ".fileProvider";
                Uri fileUri = FileProvider.getUriForFile(getActivity().getApplicationContext(), authority, file);
                intent.setDataAndType(fileUri, "application/vnd.android.package-archive");
            } else {
                intent.setDataAndType(Uri.fromFile(file),"application/vnd.android.package-archive");
                intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
            }
            this.startActivityForResult(intent, 0);
        }catch (Exception e){
            // todo 安装失败的操作
        }

    }

配置在清单中

       <provider
            tools:replace="android:authorities"
            android:name="android.support.v4.content.FileProvider"
            android:authorities="com.example.kylin.mindabs.fileProvider"
            android:grantUriPermissions="true"
            android:exported="false">
            <meta-data
                tools:replace="android:resource"
                android:name="android.support.FILE_PROVIDER_PATHS"
                android:resource="@xml/file_paths" />
        </provider>

定义一个xml文件

<paths>
    <external-path path="Android/data/com.example.kylin.mindabs/" name="files_root" />
    <external-path path="." name="external_storage_root" />
</paths>

还有就是很多人网上写的跳转是用startActivity,我建议用startActivityForResult,这样可以拿到安装页面解析时的回到,方便之后做解析失败之类的。

    @Override
    public void onActivityResult(int requestCode, int resultCode, Intent data) {
        super.onActivityResult(requestCode, resultCode, data);
        if(requestCode == 0) {
           ......
        }
    }

我这里之前调试的时候打印成功和失败的回调

(1)成功



看到resultCode为0,data为空。注意,就算你不安装应用点取消,只要是能识别这个包出来,都是算解析成功,那么什么时候是失败的呢,比如安装包损坏这些才会回调失败的情况。
(2)失败



我自己模拟了一个失败的情况,这种情况它会直接提示你安装包解析失败。

四.开发中遇到的问题

1.断点续传的细节

在使用

.header("RANGE", "bytes=" + startsPoint + "-")

之后,其实就是从文件的startsPoint 字节开始去下载,startsPoint 是我获取的当前本地文件的大小,这本来是没啥问题的,但是在apk已经下载完成的情况下startsPoint 就是整个文件的长度,按理说这里这样操作应该会让response.body().contentLength()等于0,而实际上我在调试的时候没有崩溃,但是response.body().contentLength()莫名其妙的等于229,我认真看日记才发现请求时报416错误,就是越界了。为了解决这个文件,我在拿到断点的时候会做一个-1的操作

final long startsPoint = getFileStart() > 0 ? getFileStart()-1 : getFileStart();
2.流程问题

其实更新的知识点就那两三个,但是对于流程来说需要严谨些,说得直白些,尽量有条能走通的路,所以我的代码里大量加了try-catch

3.请求放在service

请求为什么要放在service中呢,其实是一个生命周期的问题,如果请求是在activity中发起的,关闭activity之后其实activity还不会结束,他会被请求影响生命周期,所以需要再service中请求。而如果你不是在activity中请求的话,比如你在弹框中请求,只要在弹框消失的时候取消请求就行,这种情况放不放在service里面做请求我觉得就无所谓了。

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

推荐阅读更多精彩内容