专栏首页小鄧子的技术博客专栏【译】Retrofit 2 - 如何从服务器下载文件

【译】Retrofit 2 - 如何从服务器下载文件

如何声明Retrofit请求

如果你在阅读本文前没有写过任何一行Retrofit请求代码,那么最好看一下前面几篇博客。对于很多Retrofit使用者来说:定义一个下载文件的请求与其他请求几乎无异:

// option 1: a resource relative to your base URL
@GET("/resource/example.zip")
Call<ResponseBody> downloadFileWithFixedUrl();

// option 2: using a dynamic URL
@GET
Call<ResponseBody> downloadFileWithDynamicUrlSync(@Url String fileUrl);  

如果你要下载的文件是一个静态资源(存在于服务器上的同一个地点),Base URL指向的就是所在的服务器,这种情况下可以选择使用方案一。正如你所看到的,它看上去就像一个普通的Retrofit 2请求。值得注意的是,我们将ResponseBody作为了返回类型。Retrofit会试图解析并转换它,所以你不能使用任何其他返回类型,否则当你下载文件的时候,是毫无意义的。

第二种方案是Retrofit 2的新特性。现在你可以轻松构造一个动态地址来作为全路径请求。这对于一些特殊文件的下载是非常有用的,也就是说这个请求可能要依赖一些参数,比如用户信息或者时间戳等。你可以在运行时构造URL地址,并精确的请求文件。如果你还没有试过动态URL方式,可以翻到开头,看看这篇专题博客Retrofit 2中的动态URL

哪一种方案对你有用呢,我们接着往下看。

如何调用请求

声明请求后,实际调用方式如下:

FileDownloadService downloadService = ServiceGenerator.create(FileDownloadService.class);

Call<ResponseBody> call = downloadService.downloadFileWithDynamicUrlSync(fileUrl);

call.enqueue(new Callback<ResponseBody>() {  
    @Override
    public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
        if (response.isSuccess()) {
            Log.d(TAG, "server contacted and has file");

            boolean writtenToDisk = writeResponseBodyToDisk(response.body());

            Log.d(TAG, "file download was a success? " + writtenToDisk);
        } else {
            Log.d(TAG, "server contact failed");
        }
    }

    @Override
    public void onFailure(Call<ResponseBody> call, Throwable t) {
        Log.e(TAG, "error");
    }
});

如果你对ServiceGenerator.create()感到困惑,可以阅读我们的第一篇博客 。一旦创建了service,我们就能像其他Retrofit调用一样做网络请求了。

还剩下一件很重要的事,隐藏在代码块中的writeResponseBodyToDisk()函数:负责将文件写进磁盘。

如何保存文件

writeResponseBodyToDisk()方法持有ResponseBody对象,通过读取它的字节,并写入磁盘。代码看起来比实际略复杂:

private boolean writeResponseBodyToDisk(ResponseBody body) {  
    try {
        // todo change the file location/name according to your needs
        File futureStudioIconFile = new File(getExternalFilesDir(null) + File.separator + "Future Studio Icon.png");

        InputStream inputStream = null;
        OutputStream outputStream = null;

        try {
            byte[] fileReader = new byte[4096];

            long fileSize = body.contentLength();
            long fileSizeDownloaded = 0;

            inputStream = body.byteStream();
            outputStream = new FileOutputStream(futureStudioIconFile);

            while (true) {
                int read = inputStream.read(fileReader);

                if (read == -1) {
                    break;
                }

                outputStream.write(fileReader, 0, read);

                fileSizeDownloaded += read;

                Log.d(TAG, "file download: " + fileSizeDownloaded + " of " + fileSize);
            }

            outputStream.flush();

            return true;
        } catch (IOException e) {
            return false;
        } finally {
            if (inputStream != null) {
                inputStream.close();
            }

            if (outputStream != null) {
                outputStream.close();
            }
        }
    } catch (IOException e) {
        return false;
    }
}

大部分都是一般Java I/O流的样板代码。你只需要关心第一行代码就行了,也就是文件最终以什么命名被保存。当你做完这些工作,就能够用Retrofit来下载文件了。

但是我们并没有完全做好准备。而且这里存在一个大问题:默认情况下,Retrofit在处理结果前会将整个Server Response读进内存,这在JSON或者XML等Response上表现还算良好,但如果是一个非常大的文件,就可能造成OutofMemory异常。

如果你的应用需要下载略大的文件,我们强烈建议阅读下一节内容。

当心大文件:请使用@Streaming!

如果下载一个非常大的文件,Retrofit会试图将整个文件读进内存。为了避免这种现象的发生,我们添加了一个特殊的注解来声明请求。

@Streaming
@GET
Call<ResponseBody> downloadFileWithDynamicUrlAsync(@Url String fileUrl);  

声明@Streaming并不是意味着你需要观察一个Netflix文件。它意味着立刻传递字节码,而不需要把整个文件读进内存。值得注意的是,如果你使用了@Streaming,并且依然使用以上的代码片段来进行处理。Android将会抛出android.os.NetworkOnMainThreadException异常。

因此,最后一步就是把这些操作放进一个单独的工作线程中,例如ASyncTask

final FileDownloadService downloadService =  
                ServiceGenerator.create(FileDownloadService.class);

new AsyncTask<Void, Long, Void>() {  
   @Override
   protected Void doInBackground(Void... voids) {
       Call<ResponseBody> call = downloadService.downloadFileWithDynamicUrlSync(fileUrl);
       call.enqueue(new Callback<ResponseBody>() {
           @Override
           public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
               if (response.isSuccess()) {
                   Log.d(TAG, "server contacted and has file");

                   boolean writtenToDisk = writeResponseBodyToDisk(response.body());

                   Log.d(TAG, "file download was a success? " + writtenToDisk);
               }
               else {
                   Log.d(TAG, "server contact failed");
               }
           }
       return null;
   }
}.execute();            

至此,如果你能够记住@Streaming的使用和以上代码片段,那么就能够使用Retrofit高效下载大文件了。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 【译】与Adapter一起使用(ListView, GridView, ...)

    首先,我们需要为测试提供一些图像。我们从eatfoody.com截取了部分美味的食谱图,上传至imgur。

    小鄧子
  • 【译】避免打断链式结构:使用.compose( )操作符

    *[Chains break by the weakest link](https://www.flickr.com/photos/hernanpc/71153...

    小鄧子
  • 【译】Activity分割动画如何使用我的动画##

    在切换不同Activity时,系统级过渡动画是作用于整个Activity的,而我想要实现的动画效果是将Activity A分割成两部分,然后将他们向外推开,最后...

    小鄧子
  • Spring+SpringMVC+MyBatis+easyUI整合基础篇(八)mysql中文查询bug修复

    前言   在测试搜索时出现的问题,mysql通过中文查询条件搜索不出数据,但是英文和数字可以搜索到记录,中文无返回记录。本文就是写一下发现问题的过程及解决方法...

    我是十三
  • 医疗AI市场三年内规模可达66亿美元,哪些应用最有潜力?| 报告

    一项最新研究显示,随着人工智能向健康领域渗透,加之人们越来越接受机器为病人提供医疗服务,医疗人工智能可能会在三年内成长为一个66亿美元的市场。 ? 咨询公司埃森...

    量子位
  • JavaScript 对象所有API解析【2020版】

    近日发现有挺多人对对象基础API不熟悉,举个开发中常见的需求,经常会有类似的封装http到原型Vue.prototype,一般人是这样封装的,但容易被篡改。

    前端迷
  • JavaScript 对象所有API解析

    该构造器可以接受任何类型的参数,并且会自动识别参数的类型,并选择更合适的构造器来完成相关操作。比如:

    前端博客 : alili.tech
  • 英特尔与博雅睿视共同发布SVT-AVS3实时编码器

    作为LiveVideoStackCon 2019的收官之作,在经过了组委会四个月以来的精心筹备,这场国内顶级音视频技术交流峰会最终于12月14号,在位于南山区圣...

    LiveVideoStack
  • 学习 PixiJS — 粒子效果

    你如何创造火,烟,魔法和爆炸等效果?你制作了许多小精灵,几十,几百,甚至上千个精灵。然后对这些精灵应用一些物理效果,使它们的行为类似于你尝试模拟的元素。你还必须...

    FEWY
  • Mac+httpclient高并发配置实例

    本人近期在做服务端的压力测试,在准备测试脚本的过程中遇到了一些配置方面的问题,在经过查阅资料和对比结果后总结了在Mac电脑配置和httpclient配置上的经验...

    FunTester

扫码关注云+社区

领取腾讯云代金券