要在Android中使用Retrofit获取普通HTTP调用的进度,可以使用Retrofit的ResponseBody
和okhttp3.ResponseBody
接口结合使用。以下是一个示例代码:
首先,确保你已经在项目的build.gradle
文件中添加了Retrofit和OkHttp的依赖项:
implementation 'com.squareup.retrofit2:retrofit:2.9.0'
implementation 'com.squareup.okhttp3:okhttp:4.9.0'
接下来,在你的API接口中添加一个ResponseBody
参数,用于接收服务器的响应数据。例如:
public interface MyApi {
@GET("your/api/endpoint")
Call getData();
}
然后,在你的Activity或Fragment中,创建一个带有进度回调的okhttp3.ResponseBody
拦截器。例如:
private class ProgressResponseBodyInterceptor implements Interceptor {
private final ProgressListener progressListener;
public ProgressResponseBodyInterceptor(ProgressListener progressListener) {
this.progressListener = progressListener;
}
@Override
public Response intercept(Chain chain) throws IOException {
Response originalResponse = chain.proceed(chain.request());
return originalResponse.newBuilder()
.body(new ProgressResponseBody(originalResponse.body(), progressListener))
.build();
}
}
接下来,创建一个okhttp3.ResponseBody
的子类ProgressResponseBody
,用于实现进度监听器。例如:
private class ProgressResponseBody extends ResponseBody {
private final ResponseBody responseBody;
private final ProgressListener progressListener;
private BufferedSource bufferedSource;
public ProgressResponseBody(ResponseBody responseBody, ProgressListener progressListener) {
this.responseBody = responseBody;
this.progressListener = progressListener;
}
@Override
public MediaType contentType() {
return responseBody.contentType();
}
@Override
public long contentLength() {
return responseBody.contentLength();
}
@Override
public BufferedSource source() {
if (bufferedSource == null) {
bufferedSource = Okio.buffer(source(responseBody.source()));
}
return bufferedSource;
}
private Source source(Source source) {
return new ForwardingSource(source) {
long totalBytesRead = 0;
@Override
public long read(Buffer sink, long byteCount) throws IOException {
long bytesRead = super.read(sink, byteCount);
totalBytesRead += bytesRead != -1 ? bytesRead : 0;
progressListener.onProgress(totalBytesRead, responseBody.contentLength(), bytesRead == -1);
return bytesRead;
}
};
}
}
在ProgressResponseBody
中,我们继承了okhttp3.ResponseBody
,并实现了一个source()
方法,该方法在读取数据时会调用进度监听器的onProgress()
方法。
最后,在你的Activity或Fragment中,实现一个ProgressListener
接口,用于处理进度更新的逻辑。例如:
private interface ProgressListener {
void onProgress(long bytesRead, long contentLength, boolean done);
}
在onProgress()
方法中,你可以更新UI来显示下载或上传的进度。
最后,使用上述代码示例来创建Retrofit实例,并在调用API时传递进度监听器。例如:
OkHttpClient client = new OkHttpClient.Builder()
.addInterceptor(new ProgressResponseBodyInterceptor(new ProgressListener() {
@Override
public void onProgress(long bytesRead, long contentLength, boolean done) {
// 更新UI显示进度
}
}))
.build();
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("http://your.api.base.url/")
.client(client)
.build();
MyApi myApi = retrofit.create(MyApi.class);
Call call = myApi.getData();
call.enqueue(new Callback() {
@Override
public void onResponse(Call call, Response response) {
// 处理服务器响应
}
@Override
public void onFailure(Call call, Throwable t) {
// 处理请求失败
}
});
通过上述步骤,你就可以使用Retrofit获取普通HTTP调用的进度了。在ProgressListener
的onProgress()
方法中,你可以更新UI来显示下载或上传的进度。