OKHTTP 3 Отслеживание результатов многократной загрузки

Как я могу отслеживать ход загрузки в OkHttp 3 Я могу найти ответы для v2, но не v3, например this

Пример запроса Multipart из рецептов OkHttp

private static final String IMGUR_CLIENT_ID = "...";
private static final MediaType MEDIA_TYPE_PNG = MediaType.parse("image/png");

private final OkHttpClient client = new OkHttpClient();

public void run() throws Exception {
    // Use the imgur image upload API as documented at https://api.imgur.com/endpoints/image
    RequestBody requestBody = new MultipartBody.Builder()
            .setType(MultipartBody.FORM)
            .addFormDataPart("title", "Square Logo")
            .addFormDataPart("image", "logo-square.png",
                    RequestBody.create(MEDIA_TYPE_PNG, new File("website/static/logo-square.png")))
            .build();

    Request request = new Request.Builder()
            .header("Authorization", "Client-ID " + IMGUR_CLIENT_ID)
            .url("https://api.imgur.com/3/image")
            .post(requestBody)
            .build();

    Response response = client.newCall(request).execute();
    if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

    System.out.println(response.body().string());
}

Ответ 1

Вы можете украсить тело запроса OkHttp, чтобы подсчитать количество байтов, записанных при его записи; чтобы выполнить эту задачу, оберните свой MultiPart RequestBody в этот RequestBody экземпляром Listener и Voila!

public class ProgressRequestBody extends RequestBody {

    protected RequestBody mDelegate;
    protected Listener mListener;
    protected CountingSink mCountingSink;

    public ProgressRequestBody(RequestBody delegate, Listener listener) {
        mDelegate = delegate;
        mListener = listener;
    }

    @Override
    public MediaType contentType() {
        return mDelegate.contentType();
    }

    @Override
    public long contentLength() {
        try {
            return mDelegate.contentLength();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return -1;
    }

    @Override
    public void writeTo(BufferedSink sink) throws IOException {
        mCountingSink = new CountingSink(sink);
        BufferedSink bufferedSink = Okio.buffer(mCountingSink);
        mDelegate.writeTo(bufferedSink);
        bufferedSink.flush();
    }

    protected final class CountingSink extends ForwardingSink {
        private long bytesWritten = 0;
        public CountingSink(Sink delegate) {
            super(delegate);
        }
        @Override
        public void write(Buffer source, long byteCount) throws IOException {
            super.write(source, byteCount);
            bytesWritten += byteCount;
            mListener.onProgress((int) (100F * bytesWritten / contentLength()));
        }
    }

    public interface Listener {
        void onProgress(int progress);
    }
}

Отметьте эту ссылку для более подробной информации.

Ответ 2

В соответствии с ответом Sourabh, я хочу сказать, что поле CountingSink

private long bytesWritten = 0;

должен быть перемещен в класс ProgressRequestBody

Ответ 3

К сожалению, приведенный выше код не решил мою проблему. Этот код работал для меня:

// TODO: Build a request body
RequestBody body = null;

// Decorate the request body to keep track of the upload progress
CountingRequestBody countingBody = new CountingRequestBody(body,
        new CountingRequestBody.Listener() {

    @Override
    public void onRequestProgress(long bytesWritten, long contentLength) {
        float percentage = 100f * bytesWritten / contentLength;
        // TODO: Do something useful with the values
    }
});

// TODO: Build a request using the decorated body