Pobierz plik binarny z OKHTTP

Jeśli to coś warte, polecam response.body().source() z okio (ponieważ OkHttp obsługuje go już natywnie), aby cieszyć się łatwiejszym sposobem manipulowania dużą ilością danych, które mogą pojawić się podczas pobierania pliku.

@Override
public void onResponse(Call call, Response response) throws IOException {
    File downloadedFile = new File(context.getCacheDir(), filename);
    BufferedSink sink = Okio.buffer(Okio.sink(downloadedFile));
    sink.writeAll(response.body().source());
    sink.close();
}

Kilka zalet zaczerpniętych z Dokumentacji w porównaniu z InputStream:

Ten interfejs jest funkcjonalnie równoważny do InputStream. InputStream wymaga wielu warstw, gdy zużyte dane są niejednorodne: a DataInputStream dla wartości pierwotnych, Buforedinputstream dla buforowania i InputStreamReader dla ciągów znaków. Ta klasa używa BufferedSource dla wszystkich powyższych. Source unika niemożliwej do implementacji metody available (). Zamiast tego wywołujący określają, ile bajtów wymagają.

Source pomija znacznik unsafe-to-compose i stan resetowania śledzony przez strumień wejściowy; wywołujący zamiast tego buforują to, czego potrzebują.

Implementując źródło, nie musisz się martwić o jednobajtowa Metoda odczytu, która jest niewygodna do efektywnej implementacji i zwraca jedną z 257 możliwych wartości.

I source ma mocniejszą metodę pomijania: BufferedSource.skip (long) nie powróci przedwcześnie.

Najlepsza opcja do pobrania (na podstawie kodu źródłowego "okio")

private void download(@NonNull String url, @NonNull File destFile) throws IOException {
    Request request = new Request.Builder().url(url).build();
    Response response = okHttpClient.newCall(request).execute();
    ResponseBody body = response.body();
    long contentLength = body.contentLength();
    BufferedSource source = body.source();

    BufferedSink sink = Okio.buffer(Okio.sink(destFile));
    Buffer sinkBuffer = sink.buffer();

    long totalBytesRead = 0;
    int bufferSize = 8 * 1024;
    for (long bytesRead; (bytesRead = source.read(sinkBuffer, bufferSize)) != -1; ) {
        sink.emit();
        totalBytesRead += bytesRead;
        int progress = (int) ((totalBytesRead * 100) / contentLength);
        publishProgress(progress);
    }
    sink.flush();
    sink.close();
    source.close();
}

Tak używam Okhttp + Okio biblioteki podczas publikowania postępu pobierania po każdym pobraniu fragmentu:

public static final int DOWNLOAD_CHUNK_SIZE = 2048; //Same as Okio Segment.SIZE

try {
        Request request = new Request.Builder().url(uri.toString()).build();

        Response response = client.newCall(request).execute();
        ResponseBody body = response.body();
        long contentLength = body.contentLength();
        BufferedSource source = body.source();

        File file = new File(getDownloadPathFrom(uri));
        BufferedSink sink = Okio.buffer(Okio.sink(file));

        long totalRead = 0;
        long read = 0;
        while (read = (source.read(sink.buffer(), DOWNLOAD_CHUNK_SIZE)) != -1) {
            totalRead += read;
            int progress = (int) ((totalRead * 100) / contentLength);
            publishProgress(progress);
        }
        sink.writeAll(source);
        sink.flush();
        sink.close();
        publishProgress(FileInfo.FULL);
} catch (IOException e) {
        publishProgress(FileInfo.CODE_DOWNLOAD_ERROR);
        Logger.reportException(e);
}

Lepszym rozwiązaniem jest użycie OkHttpClient jako:

OkHttpClient client = new OkHttpClient();

            Request request = new Request.Builder()
                    .url("http://publicobject.com/helloworld.txt")
                    .build();



            client.newCall(request).enqueue(new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
                    e.printStackTrace();
                }

                @Override
                public void onResponse(Call call, Response response) throws IOException {

                    if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

//                    Headers responseHeaders = response.headers();
//                    for (int i = 0; i < responseHeaders.size(); i++) {
//                        System.out.println(responseHeaders.name(i) + ": " + responseHeaders.value(i));
//                    }
//                    System.out.println(response.body().string());

                    InputStream in = response.body().byteStream();
                    BufferedReader reader = new BufferedReader(new InputStreamReader(in));
                    String result, line = reader.readLine();
                    result = line;
                    while((line = reader.readLine()) != null) {
                        result += line;
                    }
                    System.out.println(result);


                }
            });