美文网首页AndroidWorldAndroid基础知识Android developing tips
【译】Retrofit 2 - 如何从服务器下载文件

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

作者: 小鄧子 | 来源:发表于2016-04-01 13:13 被阅读28699次

    如何声明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高效下载大文件了。

    相关文章

      网友评论

      • 南柯一梦00:有点疑惑,call.enqueue()方法本身就在子线程中,还能再加一个AsyncTask吗
        Android之路:Retrofit的call.enqueue()应该是在UI线程,OKHTTP那个是子线程!
      • 范蓄能:writeResponseBodyToDisk 这个方法貌似在主线程中跑了呀
        范蓄能:@boyrt 看代码是在onResponse调用了这个IO耗时操作啊
        boyrt:我碰到这个问题了,什么情况啊
      • 山岭巨人郭敬明:额,楼主试过吗。。我加了子线程运行还是报NetWorkOnMainThreadException啊。。。。。。。。。。。。。。。
      • bitdp:networkonmainthread这个问题困扰我好几天了。。赶紧记下来。。。:fearful:
      • zhuhf:用rx来处理,比如用map,doOnNext等,把ResponseBody处理完之后,再回调。
        大棋17:受教了:grin: 我用map解决的
      • CasperJACKSON:你好,对于@Streaming 的实现流程能大概说说吗? 看源代码很无力
      • 包牙齿:现在github上有一款超高效的轮子,如果你在项目中加入的retrofit引用,可以直接用。推荐看看,请移步:https://github.com/lingochamp/FileDownloader
        大姨夫斯基:FileDownloader 遇上https + httpDNS 就抓瞎了。
        仙人掌RT:@包牙齿 这个东西看不懂,下载了也编译不了,小白表示忧郁
      • 包牙齿:之所以有Retrofit,为什么还要用AsyncTask
        包牙齿:@小鄧子 知道了,作者辛苦了 :smiley:
        小鄧子:@r17171709 感谢理解。:)
        皮球二二:@包牙齿 可以用rx来处理,只不过作者是翻译不是自己来实际写,尊重原文而已
      • Diffey:有文件上传的文章么?

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

      本文链接:https://www.haomeiwen.com/subject/ozhylttx.html