从 OKHTTP 下载二进制文件

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

This https://stackoverflow.com/questions/25367888/upload-binary-file-with-okhttp-from-resources示例显示如何上传二进制文件。我想知道如何使用 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。类似的回应Apache HTTP Client像这样OkHttp回复：

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

EDIT

接受下面的答案。 我修改后的代码：

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

对于它的价值，我会推荐response.body().source() from okio https://github.com/square/okio#sources-and-sinks（因为 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。 当使用的数据是异构的时，InputStream 需要多个层：用于原始值的 DataInputStream、用于缓冲的 BufferedInputStream 以及用于字符串的 InputStreamReader。此类使用 BufferedSource 来实现上述所有功能。 Source 避免了不可能实现的 available() 方法。相反，调用者指定他们需要多少字节。

Source 忽略了由 InputStream 跟踪的不安全组合标记和重置状态；调用者只是缓冲他们需要的内容。

实现源时，您无需担心单字节读取方法，该方法难以高效实现并且返回 257 个可能值之一。

而source有一个更强的skip方法：BufferedSource.skip(long)不会过早返回。