秒懂Retrofit2之带进度条的文件下载实现方法

我不是女神ヾ 2022-05-14 08:57 1114阅读 0赞

> 版权申明】非商业目的注明出处可自由转载  
> 博文地址：[https://blog.csdn.net/ShuSheng0007/article/details/82428733][https_blog.csdn.net_ShuSheng0007_article_details_82428733]  
> 出自：shusheng007

*  概述
 *  实现效果
 *  实现方法
 *  具体实现
    
     *  第一步：引入Retrofit类库
     *  第二步：定义服务接口
     *  第三步：自定义返回结果 ResponseBody
     *  第四步：定义下载拦截器
     *  第五步：构建Okhttp实例，并设置拦截器
     *  第六步：构建Retrofit实例，并发起下载的网络请求
 *  如何使用
 *  总结

# 概述 #

`Retrofit`这个`Okhttp`的封装库俨然已经成为Android开发中网络请求的标配，使用其处理`Http`请求非常方便，但是涉及到下载功能时，特别是需要实时获得下载进度的场景时就比较棘手了，而下载时需要获得下载进度又属于刚需，所以本文总结一下这部分的知识。

# 实现效果 #

先上一张具体的实现图  
![这里写图片描述][70]

# 实现方法 #

我们知道`Retrofit`是`Okhttp`的封装库，真正发起网络请求的是`OkHttp`，而`OkHttp`拥有强大的拦截器机制。如果不了解什么事拦截器机制，就简单看下下面的示例，否则直接跳过：

例如王二狗和李胖子都喜欢牛翠花，王二狗与牛翠花中间隔着李胖子，那王二狗给牛翠花写了个求爱的小纸条，在扔给牛翠花的时候被中间的李胖子给拦截住了，那李胖子就可以修改这个纸条上的内容，甚至把原来的纸条丢掉换个自己的纸条过去，或者干脆不把纸条给牛翠花，等等操作。。。在此例中李胖子就好比是一个拦截器。

其实实时向外报告下载进度就是通过`OkHttp`的拦截器实现的，在`OkHttp`的下载过程中使用拦截器拦截到下载的内容，算出进度，然后暴露给使用者就可以了。

# 具体实现 #

## 第一步：引入Retrofit类库 ##

dependencies { implementation 'com.squareup.retrofit2:retrofit:2.2.0' }

## 第二步：定义服务接口 ##

public interface DownloadService { 
        @Streaming
        @GET
        Call<ResponseBody> downloadWithDynamicUrl(@Url String fileUrl);
    }

这个下载的接口是一个`Get`请求，但是需要使用`@Streaming`注解标记，如果不使用这个注解，那么`Okhttp`就会将下载的内容一次性载入内存中才返回，这在下载稍微大点的文件时候就会发生`OOM`。值得注意的是我们使用了`@Url`标记了我们的参数，表示可以传入动态`Url`部分。

## 第三步：自定义返回结果 `ResponseBody` ##

由于我们会使用拦截器拦截下载的内容，其是一个`ResponseBody`类型的数据，我们就是在这里面获取到下载进度的。

public class DownloadResponseBody extends ResponseBody { 
    
        private ResponseBody responseBody;
        private DownloadListener downloadListener;
        private BufferedSource bufferedSource;
        private Executor executor;
    
        public DownloadResponseBody(ResponseBody responseBody, Executor executor, DownloadListener downloadListener) {
            this.responseBody = responseBody;
            this.downloadListener = downloadListener;
            this.executor = executor;
        }
    
        @Override
        public MediaType contentType() {
            return responseBody.contentType();
        }
    
        @Override
        public long contentLength() {
            return responseBody.contentLength();
        }
    
        @Override
        public BufferedSource source() {
            if (bufferedSource == null) {
                bufferedSource = Okio.buffer(source(responseBody.source()));
            }
            return bufferedSource;
        }
    
        private Source source(Source source) {
            return new ForwardingSource(source) {
                long totalBytesRead = 0L;
    
                @Override
                public long read(Buffer sink, long byteCount) throws IOException {
                    final long bytesRead = super.read(sink, byteCount);
                    // read() returns the number of bytes read, or -1 if this source is exhausted.
                    if (null != downloadListener) {
                        totalBytesRead += bytesRead != -1 ? bytesRead : 0;
                        Logger.t("DownloadUtil").d("已经下载的：" + totalBytesRead + "共有：" + responseBody.contentLength());
                        final int progress = (int) (totalBytesRead * 100 / responseBody.contentLength());
                        if (executor != null) {
                            executor.execute(() -> downloadListener.onProgress(progress));
                        } else {
                            downloadListener.onProgress(progress);
                        }
                    }
                    return bytesRead;
                }
            };
        }
    }

主要看`private Source source(Source source)` 这个方法，其为`Okio`提供了数据源（okhttp内部使用Okio来处理IO）.我们可以看到在source方法中，有一个可以读取到字节流的函数`read()`,我们就是在这个函数中计算下载进度的。此处值得注意的是我们使用了一个`Executor`，这个是用来将暴露进度的方法切换到`UI`线程的。

## 第四步：定义下载拦截器 ##

拦截器就比较简单了，构造函数中传入了一个用于切换线程的`executor`和一个进度监听的`listener`，通过设置这个拦截器，下载过程就会在我们自定义的`DownloadResponseBody`中拦截到。

public class DownloadInterceptor implements Interceptor { 
    
        private DownloadListener listener;
        private Executor executor;
    
        public DownloadInterceptor(Executor executor, DownloadListener listener) {
            this.listener = listener;
            this.executor = executor;
        }
    
        @Override
        public Response intercept(Chain chain) throws IOException {
            Response originalResponse = chain.proceed(chain.request());
    
            return originalResponse.newBuilder()
                    .body(new DownloadResponseBody(originalResponse.body(), executor, listener))
                    .build();
        }
    }

## 第五步：构建Okhttp实例，并设置拦截器 ##

OkHttpClient client = new OkHttpClient.Builder()
            .addInterceptor(interceptor)
            .retryOnConnectionFailure(true)
            .connectTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS)
            .build();

## 第六步：构建Retrofit实例，并发起下载的网络请求 ##

final DownloadService api = new Retrofit.Builder()
            .baseUrl(baseUrl)
            .client(client)
            .build()
            .create(DownloadService.class);
    new Thread(() -> { try { Response<ResponseBody> result = api.downloadWithDynamicUrl(rUrl).execute(); File file = writeFile(filePath, result.body().byteStream()); if (listener != null){ executor.execute(()->{ listener.onFinish(file); }); } } catch (IOException e) { if (listener != null){ executor.execute(()->{ listener.onFailed(e.getMessage()); }); } e.printStackTrace(); } }).start();

# 如何使用 #

使用方法非常简单，获取下载工具类实例后调用下载函数即可，出入要下载的文件网络地址以及本地保存地址，传入进度监听，在监听回调中完成自己的业务逻辑。

DownloadUtil.getInstance()
                    .downloadFile(baseUrl, url, desFilePath, new DownloadListener() {
                        @Override
                        public void onFinish(final File file) {
                            tvFileLocation.setText("下载的文件地址为：" + file.getAbsolutePath());
                            installAPK(file, MainActivity.this);
                        }
    
                        @Override
                        public void onProgress(int progress) {
                            tvProgress.setText(String.format("下载进度为：%s", progress));
                        }
    
                        @Override
                        public void onFailed(String errMsg) {
    
                        }
                    });

# 总结 #

显然与其他的OkHttp封装类库相比，Retrofit在下载这方面显得较为繁琐，但是却给了开发者更大的灵活性。`OkHttp`的拦截器机制值得我们每个人学习。

[源码下载地址][Link 1]

[https_blog.csdn.net_ShuSheng0007_article_details_82428733]: https://blog.csdn.net/ShuSheng0007/article/details/82428733
[70]: /images/20220514/c5619211330349adb1f80c52ba11e465.png
[Link 1]: https://github.com/shusheng007/RetrofitDownloadWithProgress