okhttp3大文件下载中的OutOfMemoryError

Question

我正在尝试通过OKHTTP3html" target="_blank">下载zip文件（大小为160 Mb）。几秒钟后，应用程序与堆栈崩溃：

IllegalStateException：在scheduler.worker线程上引发的致命异常。在java.util.concurrent.executors$runnableadapter.call(executors.java:59)在java.util.concurrent.futuretask.run(futuretask.java:237)在java.util.concurrent.scheduledthreadpoolexecutor$scheduledfuturetask.run（scheduledthreadpoolexecutor.java:272)在java.util.concurrent.threadpoolexecutor.java:113)，在：607）在java.lang.thread.run（thread.java:761）处造成：java.lang.outofMemoryError：未能分配8204字节的分配，1688个空闲字节和1688B直到OOM在OKIO.segment.（segment.java:61)在OKIO.segmentpool.take(Segmentpool.java:46)在OKIO.obuffer.writableSegment（buffer.java:1151)在OKIO.obkio$2处读取(ocio.java:136)在OKIO.asynctimeout$2处读取：45）位于okhttp3.internal.http.http1xstream$fixedlengthsource.read(http1xstream.jaVA:377)在OKIO.realBufferedSource.request(realBufferedSource.request(realBufferedSource.java:66)在OKHTTP3.logging.httpLoggingInterceptor.java:238)在OKHTTP3.internal.http.realInterceptorchain.proce(realInterceptorchain.java:92)在OKHTTP3.internal.http.realInterceptorchain.proce(realInterceptorchain.java:92)在.bvs.data.MapService$2.在rx.observable.unsafeSubScribe(observable.java:10142)html" target="_blank">调用(MapService.java:94)

下面是我的代码：

Observable.create((Observable.OnSubscribe<ResponseBody>) subscriber -> {
        Timber.e("Start zip loading");
        Request request = new Request.Builder()
                .url(Tweakables.DEV_API_ENDPOINT + "files/" + Tweakables.MAP_ZIP)
                .build();
        try {
            Response response = client.newCall(request).execute(); // Crash appeared at this line 
            subscriber.onNext(response.body());
            response.close();
        } catch (IOException e) {
            subscriber.onError(e);
        }
    })
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<ResponseBody>() {
                @Override
                public void onCompleted() {

                }

                @Override
                public void onError(Throwable e) {
                    e.printStackTrace();
                }

                @Override
                public void onNext(ResponseBody responseBody) {

                }
            });

Answer 1

也许会对某人有帮助。通过使用改型注释流解决了问题

@Streaming
@GET("files/"+Tweakables.MAP_ZIP)
Call<ResponseBody> downloadMap();