如何使用OKIO正确地读取一个文件块？

Question

不管怎样，我在我的项目中使用了registfit/OkHttp，并认为这应该是Okio的一个很好的用法。这就是我目前所拥有的，它似乎起作用了。但是我是Okio的新手，不知道我是否遗漏了一些明显的东西，或者这是否可以用更好的方式来完成。

private void chunkedUpload(int offset, int chunkSize, int blockNumber, @Nonnull CompletableFuture<Foo> future) {
  File file = ...
  String url = ...

  try (final BufferedSource bufferedSource = Okio.buffer(Okio.source(file))) {
    bufferedSource.skip(offset);
    final Buffer buffer = new Buffer();
    final boolean isFinal = !bufferedSource.request(chunkSize);
    bufferedSource.read(buffer, chunkSize);
    final RequestBody requestFile = RequestBody.create(buffer.readByteArray(), null);
    upload(offset, chunkSize, url, requestFile, blockNumber, future, isFinal);
  } catch (IOException e) {
    future.completeExceptionally(e);
  }
}

private void upload(int offset, int chunkSize, @Nonnull String url, @Nonnull RequestBody requestFile, int blockNumber, @Nonnull CompletableFuture<Foo> future, boolean isFinal) {
        fileUloadService.uploadApp(url + "&block_number=" + blockNumber, requestFile)
            .whenComplete((responseBody, throwable) -> {
                if (throwable != null) {
                    future.completeExceptionally(throwable);
                } else {
                    if (isFinal) {
                        future.complete();
                        return;
                    }

                    chunkedUpload(offset + chunkSize, chunkSize, blockNumber + 1, future);
                }
            });
    }

您可以看到，我正在绑定upload一个块，等待成功响应（来自Java8CompletableFuture)，然后使用更新的Offset和BlockNumber再次调用ChunkedUpload方法。就像我说的，它很有效，但我是Okio的新手，我想知道我是否错过了一些明显的东西？

我想使用Okio的原因很大程度上是因为我要上传的文件通常在30MB到1GB之间，所以不要想一下子把所有这些都加载到内存中：）。

Answer 1

这是我使用Okio和OkHttp从assets文件夹读取图像文件并将其作为多部分/表单数据发送到请求正文中的代码。

您基本需要：

1. 创建OKHttpClient
2. 创建RequestBody对象
3. 将RequestBody添加为多部分/表单数据
4. 创建一个Request对象，将RequestBody和头添加到该对象中
5. 使用OkHttpClient调用请求
6. 向队列中添加回调，以便您可以返回响应bject

    // Read image file from the assets folder
    BufferedSource img = Okio.buffer(Okio.source(getAssets().open("image.jpg")));
    byte[] image = img.readByteArray();

    // Create the OkHttpClient
    OkHttpClient client = new OkHttpClient().newBuilder().build();

    // Create the request body
    RequestBody rq =  RequestBody.create(MediaType.parse("image/jpeg"),image);

    RequestBody body = new MultipartBody.Builder().setType(MultipartBody.FORM)
            .addFormDataPart("image", "image.jpg", rq)
            .build();

    // Create the request and add the RequestBody to it
    Request request = new Request.Builder()
            .url(YOUR_URL)
            .method("POST", body)
            .addHeader("Authorization", "Bearer " + BEARER_TOKEN)
            .build();

    // Use OkHttpClient to call the request
    client.newCall(request).enqueue(new okhttp3.Callback() {
        @Override
        public void onFailure(okhttp3.Call call, IOException e) {
            Snackbar.make(upload, "Error", Snackbar.LENGTH_SHORT).show();

        }

        @Override
        public void onResponse(okhttp3.Call call, okhttp3.Response response) throws IOException {
            Snackbar.make(upload, "Success", Snackbar.LENGTH_SHORT).show();

        }
    });