您好,登錄后才能下訂單哦!
這篇文章給大家分享的是有關(guān)RxJava+Retrofit+OkHttp如何實現(xiàn)文件上傳的內(nèi)容。小編覺得挺實用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。
效果
實現(xiàn)
1.定義service接口
注意:Multipart是指定大文件上傳過程中的標(biāo)示,一般上傳圖片的過程中我們需要附帶信息,所以我們需要用到@part指定傳遞的數(shù)值,MultipartBody.Part是指定傳遞的文件;
/*上傳文件*/ @Multipart @POST("AppYuFaKu/uploadHeadImg") Observable<BaseResultEntity<UploadResulte>> uploadImage(@Part("uid") RequestBody uid, @Part("auth_key") RequestBody auth_key,@Part MultipartBody.Part file);
2.加入進度條
retrofit是基于okhttp的處理,所以我們可以自定義RequestBody,復(fù)寫writeTo(BufferedSink sink)方法,得到傳遞的進度數(shù)據(jù)
public class ProgressRequestBody extends RequestBody { //實際的待包裝請求體 private final RequestBody requestBody; //進度回調(diào)接口 private final UploadProgressListener progressListener; //包裝完成的BufferedSink private BufferedSink bufferedSink; public ProgressRequestBody(RequestBody requestBody, UploadProgressListener progressListener) { this.requestBody = requestBody; this.progressListener = progressListener; } /** * 重寫調(diào)用實際的響應(yīng)體的contentType * @return MediaType */ @Override public MediaType contentType() { return requestBody.contentType(); } /** * 重寫調(diào)用實際的響應(yīng)體的contentLength * @return contentLength * @throws IOException 異常 */ @Override public long contentLength() throws IOException { return requestBody.contentLength(); } /** * 重寫進行寫入 * @param sink BufferedSink * @throws IOException 異常 */ @Override public void writeTo(BufferedSink sink) throws IOException { if (null == bufferedSink) { bufferedSink = Okio.buffer(sink(sink)); } requestBody.writeTo(bufferedSink); //必須調(diào)用flush,否則最后一部分?jǐn)?shù)據(jù)可能不會被寫入 bufferedSink.flush(); } /** * 寫入,回調(diào)進度接口 * @param sink Sink * @return Sink */ private Sink sink(Sink sink) { return new ForwardingSink(sink) { //當(dāng)前寫入字節(jié)數(shù) long writtenBytesCount = 0L; //總字節(jié)長度,避免多次調(diào)用contentLength()方法 long totalBytesCount = 0L; @Override public void write(Buffer source, long byteCount) throws IOException { super.write(source, byteCount); //增加當(dāng)前寫入的字節(jié)數(shù) writtenBytesCount += byteCount; //獲得contentLength的值,后續(xù)不再調(diào)用 if (totalBytesCount == 0) { totalBytesCount = contentLength(); } Observable.just(writtenBytesCount).observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<Long>() { @Override public void call(Long aLong) { progressListener.onProgress(writtenBytesCount, totalBytesCount); } }); } }; } }
3自定義接口,回調(diào)progress進度
public interface UploadProgressListener { /** * 上傳進度 * @param currentBytesCount * @param totalBytesCount */ void onProgress(long currentBytesCount, long totalBytesCount); }
4創(chuàng)建RequestBody對象,加入進度
File file=new File("/storage/emulated/0/Download/11.jpg"); RequestBody requestBody=RequestBody.create(MediaType.parse("image/jpeg"),file); MultipartBody.Part part= MultipartBody.Part.createFormData("file_name", file.getName(), new ProgressRequestBody(requestBody, new UploadProgressListener() { @Override public void onProgress(long currentBytesCount, long totalBytesCount) { tvMsg.setText("提示:上傳中"); progressBar.setMax((int) totalBytesCount); progressBar.setProgress((int) currentBytesCount); } }));
5.傳遞附帶信息
和封裝二中post請求的方式一樣,我們需要繼承baseentity,復(fù)寫里面的方法,然后設(shè)置需要傳遞的參數(shù),因為是測試接口,所以我的參數(shù)直接寫死在entity里面,part文件動態(tài)指定
/** * 上傳請求api * Created by WZG on 2016/10/20. */ public class UplaodApi extends BaseEntity { /*需要上傳的文件*/ private MultipartBody.Part part; public UplaodApi(HttpOnNextListener listener, RxAppCompatActivity rxAppCompatActivity) { super(listener, rxAppCompatActivity); setShowProgress(true); } public MultipartBody.Part getPart() { return part; } public void setPart(MultipartBody.Part part) { this.part = part; } @Override public Observable getObservable(HttpService methods) { RequestBody uid= RequestBody.create(MediaType.parse("text/plain"), "4811420"); RequestBody key = RequestBody.create(MediaType.parse("text/plain"), "21f8d9bcc50c6ac1ae1020ce12f5f5a7"); return methods.uploadImage(uid,key,getPart()); } }
6.post請求處理
請求和封裝二中的請求一樣,通過傳遞一個指定的HttpOnNextListener 對象來回調(diào)來監(jiān)聽結(jié)果信息,一一對應(yīng)
private void uploadeDo(){ File file=new File("/storage/emulated/0/Download/11.jpg"); RequestBody requestBody=RequestBody.create(MediaType.parse("image/jpeg"),file); MultipartBody.Part part= MultipartBody.Part.createFormData("file_name", file.getName(), new ProgressRequestBody(requestBody, new UploadProgressListener() { @Override public void onProgress(long currentBytesCount, long totalBytesCount) { tvMsg.setText("提示:上傳中"); progressBar.setMax((int) totalBytesCount); progressBar.setProgress((int) currentBytesCount); } })); UplaodApi uplaodApi = new UplaodApi(httpOnNextListener,this); uplaodApi.setPart(part); HttpManager manager = HttpManager.getInstance(); manager.doHttpDeal(uplaodApi); } /** * 上傳回調(diào) */ HttpOnNextListener httpOnNextListener=new HttpOnNextListener<UploadResulte>() { @Override public void onNext(UploadResulte o) { tvMsg.setText("成功"); Glide.with(MainActivity.this).load(o.getHeadImgUrl()).skipMemoryCache(true).into(img); } @Override public void onError(Throwable e) { super.onError(e); tvMsg.setText("失敗:"+e.toString()); } };
感謝各位的閱讀!關(guān)于“RxJava+Retrofit+OkHttp如何實現(xiàn)文件上傳”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學(xué)到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。