在安卓中使用MultipartBuilder获取进度

// 导入相关类
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;

import java.io.File;
import java.io.IOException;

// 创建OkHttpClient实例
OkHttpClient client = new OkHttpClient();

// 创建文件对象
File file = new File("path/to/file");

// 创建RequestBody，指定文件类型
RequestBody requestBody = new MultipartBody.Builder()
        .setType(MultipartBody.FORM)
        .addFormDataPart("file", file.getName(),
                RequestBody.create(MediaType.parse("application/octet-stream"), file))
        .build();

// 创建请求对象
Request request = new Request.Builder()
        .url("http://example.com/upload")
        .post(requestBody)
        .build();

// 发送请求并获取响应
try (Response response = client.newCall(request).execute()) {
    if (!response.isSuccessful()) {
        throw new IOException("Unexpected code " + response);
    }

    // 处理响应结果
    System.out.println(response.body().string());
}

import okhttp3.MediaType;
import okhttp3.RequestBody;
import okio.BufferedSink;
import okio.Okio;
import okio.Source;

import java.io.File;
import java.io.IOException;

public class ProgressRequestBody extends RequestBody {
    private static final int DEFAULT_BUFFER_SIZE = 2048;

    private File file;
    private ProgressListener listener;

    public ProgressRequestBody(File file, ProgressListener listener) {
        this.file = file;
        this.listener = listener;
    }

    @Override
    public MediaType contentType() {
        return MediaType.parse("application/octet-stream");
    }

    @Override
    public long contentLength() {
        return file.length();
    }

    @Override
    public void writeTo(BufferedSink sink) throws IOException {
        try (Source source = Okio.source(file)) {
            long totalBytesRead = 0;
            long bytesRead;
            while ((bytesRead = source.read(sink.buffer(), DEFAULT_BUFFER_SIZE)) != -1) {
                totalBytesRead += bytesRead;
                sink.flush();
                listener.onProgress(totalBytesRead, contentLength());
            }
        }
    }

    public interface ProgressListener {
        void onProgress(long bytesRead, long contentLength);
    }
}

// 创建RequestBody，指定文件类型
RequestBody requestBody = new MultipartBody.Builder()
        .setType(MultipartBody.FORM)
        .addFormDataPart("file", file.getName(),
                new ProgressRequestBody(file, new ProgressRequestBody.ProgressListener() {
                    @Override
                    public void onProgress(long bytesRead, long contentLength) {
                        // 进度更新逻辑
                        float progress = (float) bytesRead / contentLength * 100;
                        System.out.println("上传进度：" + progress + "%");
                    }
                }))
        .build();