从OKHTTP下载二进制文件

Question

我在android应用程序中使用OKHTTP客户端进行网络连接。

public class InputStreamRequestBody extends RequestBody {

    private InputStream inputStream;
    private MediaType mediaType;

    public static RequestBody create(final MediaType mediaType, 
            final InputStream inputStream) {
        return new InputStreamRequestBody(inputStream, mediaType);
    }

    private InputStreamRequestBody(InputStream inputStream, MediaType mediaType) {
        this.inputStream = inputStream;
        this.mediaType = mediaType;
    }

    @Override
    public MediaType contentType() {
        return mediaType;
    }

    @Override
    public long contentLength() {
        try {
            return inputStream.available();
        } catch (IOException e) {
            return 0;
        }
    }

    @Override
    public void writeTo(BufferedSink sink) throws IOException {
        Source source = null;
        try {
            source = Okio.source(inputStream);
            sink.writeAll(source);
        } finally {
            Util.closeQuietly(source);
        }
    }
}

OkHttpClient client = new OkHttpClient();
request = new Request.Builder().url("URL string here")
                    .addHeader("X-CSRFToken", csrftoken)
                    .addHeader("Content-Type", "application/json")
                    .build();
response = getClient().newCall(request).execute();

InputStream is = response.getEntity().getContent();

接受下面的回答。我修改过的代码：

request = new Request.Builder().url(urlString).build();
response = getClient().newCall(request).execute();

InputStream is = response.body().byteStream();

BufferedInputStream input = new BufferedInputStream(is);
OutputStream output = new FileOutputStream(file);

byte[] data = new byte[1024];

long total = 0;

while ((count = input.read(data)) != -1) {
    total += count;
    output.write(data, 0, count);
}

output.flush();
output.close();
input.close();

Answer 1

无论如何，我推荐来自okio的response.body().source()（因为OkHttp已经在本地支持它），以便更容易地操作下载文件时可能出现的大量数据。

@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();
}

与InputStream相比，文档中有几个优点：

该接口在功能上等效于InputStream。当使用的html" target="_blank">数据异构时，InputStream需要多个层：用于基本值的DataInputStream、用于缓冲的BufferedInputStream，以及用于字符串的InputStreamReader。此类使用BufferedSource实现上述所有功能。源代码避免了不可能实现的available（）方法。相反，调用方指定它们需要多少字节。

在实现一个源时，您不必担心单字节读取方法，这种方法难以有效地实现，并且返回257个可能值中的一个。

source有一个更强的skip方法：bufferedsource.skip（long）不会过早返回。