okhttp上传并且显示进度

小铲子

okhttp非常好的一个http请求框架，可惜上传没有提供上传进度，需要自定义RequestBody才能实现。网上有很多的文章表示都是差不多。自定义RequestBoyd代码如下：

1. private RequestBody createUploadFileRequestBody(final MediaType mediaType,
   
2.                                               final  File file,
   
3.                                               final IProgressListener iProgressListener) {
   
4.         return new RequestBody() {
   
5.             @Override
   
6.             public MediaType contentType() {
   
7.                 return mediaType;
   
8.             }
   
9. 
   
10.             @Override
    
11.             public long contentLength() throws IOException {
    
12.                 return file.length();
    
13.             }
    
14. 
    
15.             @Override
    
16.             public void writeTo(BufferedSink sink) throws IOException {
    
17.                 Source source;
    
18.                 try {
    
19.                     source = Okio.source(file);
    
20.                     Buffer buffer = new Buffer();
    
21.                     long conentLength = contentLength();
    
22.                     long length = -1;
    
23.                     long bufferSize = 1024 * 1024;
    
24.                     long progress = 0;
    
25.                     while ((length = source.read(buffer, bufferSize)) != -1) {
    
26.                         sink.write(buffer, length);
    
27.                         progress += length;
    
28.                         iProgressListener.onProgress(conentLength,
    
29.                                 progress, (progress == conentLength));
    
30.                     }
    
31. 
    
32.                     sink.flush();
    
33. source.close();
    
34.                 } catch (Exception e) {
    
35.                     e.printStackTrace();
    
36.                 }
    
37.             }
    
38.         };
    
39.     }
    

复制代码

监听下载进度的接口

1. public interface IProgressListener {
   
2.     /**
   
3.      * 上传,下载 进度的监听
   
4. * @param contentLength 文件的大小
   
5. * @param progress  进度
   
6. * @param isDone 是否完成
   
7. */
   
8. void onProgress(long contentLength, long progress, boolean isDone);
   
9. 
   
10.     /**
    
11.      * 错误接口
    
12. * @param requestUrl 请求的url
    
13.      * @param errorMsg 错误的信息
    
14. */
    
15. void onFailure(String requestUrl, String errorMsg);
    
16. }
    

复制代码

使用方法

1. RequestBody uploadFileRequestBody = createUploadFileRequestBody(MultipartBody.<font color="#660e7a"><i>FORM</i></font>,
   
2.         uploadFile, iProgressListener);
   
3. 
   
4. Request uploadRequest = <font color="#000080">new </font>Request.Builder()
   
5.                             .url(uploadHttpUrl)
   
6.                             .post(uploadRequestBody)
   
7.                             .build();
   
8. 
   
9. <font color="#660e7a">mOkHttpClient</font>.newCall(uploadRequest).enqueue(<font color="#000080">new </font>Callback() {
   
10.      <font color="#808000">@Override
    
11. </font><font color="#808000">     </font><font color="#000080">public void </font>onFailure(Call call, IOException e) {
    
12.          System.<font color="#660e7a"><i>out</i></font>.println(<font color="#008000">"onFailure: " </font>+ e.getMessage());
    
13.      }
    
14. 
    
15.      <font color="#808000">@Override
    
16. </font><font color="#808000">     </font><font color="#000080">public void </font>onResponse(Call call, Response response) <font color="#000080">throws </font>IOException {
    
17.          System.<font color="#660e7a"><i>out</i></font>.println(<font color="#008000">"onResponse code: " </font>+ response.code());
    
18.          <font color="#000080">if </font>(response.isSuccessful()) {
    
19.              System.<font color="#660e7a"><i>out</i></font>.println(<font color="#008000">"onResponse: " </font>+ response.body().string());
    
20.          }
    
21.          call.cancel();
    
22.      }
    
23. });
    

复制代码