MVP實戰心得---封裝Retrofit2.0+RxAndroid+RxBus
介紹:
Retrofit:
對okhttp的封裝,能夠更方便的使用okhttpjava
RxAndroid
響應式編程框架,rxjava的擴展,很爽的鏈式編程 魅力在於對數據的處理,與線程切換的靈活性. 用來處理異步操做(Lambda表達式不會用.用Lambda表達式代碼會更少,但不會的人會看不懂代碼.不是很推薦)git
RxBus
用RxJava實現的EventBusgithub
說說爲何要配合起來用
Retrofit負責連接網絡,請求網絡. RxAndroid負責處理請求的結果.異步操做 RxBus能夠很方便的進行各組件之間的通訊. 我以前是用asynchttpclient作網絡請求的,各類代碼縮進,if套if,各類回調,慘不忍睹啊. 用了Retrofit+RxAndroid我就完全放棄asynchttpclient了.編程
使用
1.RxJava
傳送門:RxJava---------這個做爲入門學習rxjava很是好json
2.Retrofit
這個寫點基本的用法吧..api
首先看用的包:bash
//retrofit2--看名字就知道是啥了
compile 'com.squareup.retrofit2:retrofit:2.1.0'
//CallAdapterFactory的Rx依賴包---導這個包才能配合rxAndroid使用
compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
//ConverterFactory的String依賴包----這個是解析數據的工廠.用來格式化數據的,配置編碼啊,gson解析啊.
compile 'com.squareup.retrofit2:converter-scalars:2.1.0'
複製代碼
而後是retrofit註解：(使用retrofit,註解是很重要的)服務器
方法註解 : 包含@GET、@POST、@PUT、@DELETE、@PATCH、@HEAD、@OPTIONS、@HTTP。
這個很少講.通常用的就是@GET、@POST,很明顯,一個是get請求,一個是post請求
複製代碼
標記註解 : 包含@FormUrlEncoded、@Multipart、@Streaming。
這個得和參數註解一塊兒說
複製代碼
參數註解 : 包含@Query,@QueryMap、@Body、@Field，@FieldMap、@Part，@PartMap。
@Get---------用的參數註解就@Query,@QueryMap,
@Post--------則會用到 @Body、@Field，@FieldMap、@Part，@PartMap。
@Body-------將數據轉化成Json,而後post.具體轉化根據設置的解析工廠(下面有講)
---------------------------------------------------分割線----------------------------------------------------------
@Field，@FieldMap------post上傳表單.@Field表示單個,@FieldMap表示集合.
須要添加上面的@FormUrlEncoded表示表單提交 ,
對應Content-Type:application/x-www-form-urlencoded
如:
@FormUrlEncoded
@POST("login的url")
Observable<User> login(@Field("name") String name, @FieldMap Map params);
--------------------------------------------------分割線------------------------------------------------------------
@Part，@PartMap----post上傳文件/數據.@Part表示單個,@PartMap表示集合.
其中@Part MultipartBody.Part 類型表明文件，@Part("key") RequestBody類型表明參數
須要添加@Multipart表示支持文件上傳的表單，Content-Type: multipart/form-data
@Multipart
@POST("update的url")
Observable<User> update(@Part ("file") MultipartBody.Part file, @Part("key") RequestBody key,@PartMap Map<String,RequestBody> files);
若是參數較少,使用@Part ("file")就能夠解決了,若是參數較多,那就須要使用@PartMap了.
複製代碼
其餘註解 : @Path、@Header,@Headers、@Url
這幾個用處挺大的,這裏就不細說了,並非必用的,我用的很少.
複製代碼
Retrofit 配置代碼.網絡
//這個是處理網絡請求的log信息的,能夠實現Interceptor接口來自定義.
HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {
@Override
public void log(String message) {
HLog.i("RxJava", message);
}
});
OkHttpClient client = new OkHttpClient.Builder()
.addInterceptor(interceptor)
.build();
Retrofit retrofit = new Retrofit.Builder()
.client(client)//Retrofit須要配置一個OkHttpClient實例.
.baseUrl(API_HOST)//須要指定一個baseUrl,通常就是服務器的域名
.addConverterFactory(FastjsonConverterFactory.create())//這個是數據解析工廠,我用的是fastjson
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())//支持rxJava,在第二個jar包裏面
.build();
複製代碼
下面是完整代碼:app
/**
* 寫成單例模式,由於並不須要多個Retrofit存在.
*/
public class RetrofitUtil {
/**
* 服務器地址
*/
private static final String API_HOST ="你的BaseUrl";
private RetrofitUtil() {
}
public static Retrofit getRetrofit() {
return Instanace.retrofit;
}
//靜態內部類,保證單例並在調用getRetrofit方法的時候纔去建立.
private static class Instanace {
private static final Retrofit retrofit = getInstanace();
private static Retrofit getInstanace() {
HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger(){
@Override
public void log(String message) {
HLog.i("RxJava", message);
}
});
OkHttpClient client = new OkHttpClient.Builder()
.addInterceptor(interceptor)
.build();
Reretrofit = new Retrofit.Builder()
.client(client)
.baseUrl(API_HOST)
.addConverterFactory(FastjsonConverterFactory.create())
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.build();
return retrofit;
}
}
}
複製代碼
json解析工廠,代碼太多,,具體能夠見demo
3.RxAndroid
若是沒接觸的話,能夠看前面的Rxjava連接.
(1).首先看Reretrofit+RxAndroid是怎麼使用的
@GET("login地址")
Observable<BaseResponse<LoginData>> login(@QueryMap HashMap<String, Object> params);
複製代碼
其實所謂的Reretrofit+RxAndroid就是這麼回事.
沒有RxAndroid的Reretrofit請求接口是這樣寫的:
@GET("login地址")
Call<BaseResponse<LoginData>> login(@QueryMap HashMap<String, Object> params);
複製代碼
把Call換成了Observable而已.
(2)寫一個接口類
/**
*全部的網絡請求均可以寫在這個接口類裏面.
*/
public interface APIService {
@GET("login地址")
Observable<BaseResponse<LoginData>> login(@QueryMap HashMap<String, Object> params);
......
}
複製代碼
(3)接口類的實現
/**
* 請求生成類。Retrofit一次生成,並做爲單例.
*/
public class ApiServcieImpl {
private ApiServcieImpl() {
}
public static APIService getInstance() {
return createAPIService.apiService;
}
/**
* Retrofit生成接口對象.
*/
private static class createAPIService {
//Retrofit會根據傳入的接口類.生成實例對象.
private static final APIService apiService = RetrofitUtil.getRetrofit().create(APIService.class);
}
}
複製代碼
而後就能夠經過ApiServcieImpl.getInstance()去調用APIService裏面寫的接口了. 如:
ApiServcieImpl.getInstance().login(new HashMap<String, Object>()) //傳入參數
.subscribe(new Action1<BaseResponse<LoginData>>() {//簡單的回調
@Override
public void call(BaseResponse<LoginData> loginDataBaseResponse) {
//拿到數據,作處理
}
});
複製代碼
4.封裝
有沒有發現,設置泛型的是<BaseResponse>,包了一層BaseResponse 這麼作是爲了請求完成後對返回的數據進行統一處理.
先看BaseResponse:
public class BaseResponse<T> {
private boolean success;//請求是否成功
private int resultCode;//狀態嗎
private String msg;//返回的提示消息
private T data;//主要內容,由於不知道返回的會是什麼類型,因此用泛型來表示
//get set方法就不貼了.
}
複製代碼
怎麼處理.
/**
* @author jlanglang 2016/11/15 16:14
*/
public class ModelFilteredFactory {
private final static Observable.Transformer transformer = new SimpleTransformer();
/**
* 將Observable<BaseResponse<T>>轉化Observable<T>,並處理BaseResponse
*
* @return 返回過濾後的Observable.
*/
@SuppressWarnings("unchecked")
public static <T> Observable<T> compose(Observable<BaseResponse<T>> observable) {
return observable.compose(transformer);
}
/**
* 這裏就不細講了,具體能夠去看rxjava的使用.這個類的意義就是轉換Observable.
*/
private static class SimpleTransformer<T> implements Observable.Transformer<BaseResponse<T>, T> {
//這裏對Observable,進行通常的通用設置.不用每次用Observable都去設置線程以及重連設置
@Override
public Observable<T> call(Observable<BaseResponse<T>> observable) {
return observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.unsubscribeOn(Schedulers.io())
.timeout(5, TimeUnit.SECONDS)//重連間隔時間
.retry(5)//重連次數
.flatMap(new Func1<BaseResponse<T>, Observable<T>>() {
@Override
public Observable<T> call(BaseResponse<T> tBaseResponse) {
return flatResponse(tBaseResponse);
}
});
}
/**
* 處理請求結果,BaseResponse
* @param response 請求結果
* @return 過濾處理, 返回只有data數據的Observable
*/
private Observable<T> flatResponse(final BaseResponse<T> response) {
return Observable.create(new Observable.OnSubscribe<T>() {
@Override
public void call(Subscriber<? super T> subscriber) {
if (response.isSuccess()) {//請求成功
if (!subscriber.isUnsubscribed()) {
subscriber.onNext(response.getData());
}
} else {//請求失敗
int resultCode = response.getResultCode();
if (!subscriber.isUnsubscribed()) {
//這裏拋出自定義的一個異常.能夠處理服務器返回的錯誤.
subscriber.onError(new APIException(response.getResultCode(), response.getMsg()));
}
return;
}
if (!subscriber.isUnsubscribed()) {//請求完成
subscriber.onCompleted();
}
}
});
}
}
}
複製代碼
僅僅只有上面那些了麼?接着看.
/**
* @author jlanglang 2016/11/14 17:32
* Subscriber,這個是用來處理Observable的結果的.
*/
public abstract class SimpleSubscriber<T> extends Subscriber<T> {
@Override
public void onCompleted() {//這個是請求完成時調用.若是走了onError()就不會走這個方法.
}
@Override
public void onError(Throwable e) {//這裏一般就處理異常
if (e instanceof APIException) {
APIException exception = (APIException) e;
ToastUtil.showToast( exception.message);
} else if (e instanceof UnknownHostException) {
ToastUtil.showToast("請打開網絡");
} else if (e instanceof SocketTimeoutException) {
ToastUtil.showToast( "請求超時");
} else if (e instanceof ConnectException) {
ToastUtil.showToast("鏈接失敗");
} else if (e instanceof HttpException) {
ToastUtil.showToast("請求超時");
}else {
ToastUtil.showToast("請求失敗");
}
e.printStackTrace();
}
@Override
public void onNext(T t) {//這裏的是得到了數據,方法意思很明顯,下一步幹啥
if (t != null) {//這裏最好判斷一下是否爲null.
call(t);
} else {
ToastUtil.showToast("鏈接失敗");
}
}
/**
*由於具體的處理這裏沒法得知,因此抽象.
*/
public abstract void call(T t);
}
複製代碼
好了,看看如今的具體使用吧:
ModelFilteredFactory.compose(ApiServcieImpl.getInstance().login(new HashMap<String, Object>()))
.subscribe(new SimpleSubscriber<LoginData>() {
@Override
public void call(LoginData loginData) {
}
});
看起來以前用起來差很少,可是卻作了不少的處理:
1.對Observable作了通用設置.網絡重連次數,線程設置,重連時間.
2.作了對服務器返回結果的統一處理.好比根據resultcode,處理登錄過時啊啥的.
3.判斷了data是否爲null,不會在call()裏面擔憂loginData是否爲null
4.統一處理了請求的各類異常.
複製代碼
5.用到MVP中.
你覺得上面那些就完了嗎?NO!
若是咱們在Presenter中這樣調用實際上是很不科學的.
ModelFilteredFactory.compose(ApiServcieImpl.getInstance().login(new HashMap<String, Object>()))
複製代碼
這個轉換咱們應該放在Modle和ModleImpl中去寫
public class LoginContract{
....//view接口省略
public interface Model {
/**
* 獲取登錄數據
* @return Observable<LoginData>
*/
Observable<LoginData> login(HashMap<String, Object> treeMap);
}
....//prensent接口省略
}
public class LoginModelImpl implements LoginContract.Model {
@Override
public Observable<LoginData> login(HashMap<String, Object> hashMap) {
return ModelFilteredFactory.compose(ApiServcieImpl.getInstance().login(hashMap));
}}
複製代碼
那麼咱們在presenter中調用就能夠這樣:
public class LoginPresenterImpl exdents BasePresenter implements LoginContract.Presenter{
.....
private LoginModelImpl loginModelImpl;
public void onCreate(){
loginModelImpl = new LoginModelImpl();//建立modle實例
}
public void login(){
//經過modle請求接口
loginModelImpl.login(new HashMap<String, Object>()))
.subscribe(new SimpleSubscriber<LoginData>() {
@Override
public void call(LoginData loginData) {
//處理請求的數據,綁定視圖
}
});
}
....
}
複製代碼
6.管理Observable的生命週期,也就是網絡請求的生命週期.
Observable是否是很高大上,然而若是你不進行處理,但是會內存泄漏的 RxAndroid也不會自動的根據Activity/frgament的生命週期結束異步請求. 但處理其實很簡單.
使用CompositeSubscription
只須要將Observable,異步處理到最後返回的subscribe添加到CompositeSubscription實例裏就好了.
public void login(){
Subscription subscribe = loginModelImpl.login(new HashMap<String, Object>()))
.subscribe(new SimpleSubscriber<LoginData>() {
@Override
public void call(LoginData loginData) {
//處理請求的數據,綁定視圖
}
});
compositeSubscription.add(subscribe);//添加訂閱
}
//在銷燬的時候,結束訂閱事件.
public void onDestroy() {
compositeSubscription.unsubscribe();//結束全部add的subscribe事件
}
複製代碼
那麼,實戰心得(二)中的BasePresenter就能夠進行改進了,具體見:
/**
* @author jlanglang 2016/11/11 15:10
*/
public abstract class BasePresenter<T extends BaseView> {
protected T mView;
protected CompositeSubscription compositeSubscription;
/**
* 綁定View
*/
public void onAttch(T view) {
this.mView = view;
compositeSubscription = new CompositeSubscription ();
}
/**
* 作初始化的操做,須要在V的視圖初始化完成以後才能調用
* presenter進行初始化.
*/
public abstract void onCreate();
/**
* 在這裏結束異步操做
*/
public void onDestroy(){
compositeSubscription.unsubscribe();//結束異步請求.
}
/**
* 在V銷燬的時候調用,解除綁定
*/
public void onDetach() {
mView = null;
}
/**
* 容易被回收掉時保存數據
*/
public abstract void onSaveInstanceState(Bundle outState);
}
複製代碼
7 RxBus
沒什麼特別值得提的,用法自行搜索,哈哈,我的在項目中用的也不是不少,某些狀況會用一下,但真心好用.
再附上githubdemo地址,時不時更新.
您的喜歡與回覆是我最大的動力－＿－
相關文章
- 1. MVP實戰心得(一)
- 2. Flutter MVP 封裝
- 3. rxjava+retrofit+mvp封裝
- 4. MVP繼續封裝
- 5. RabbitMQ封裝實戰
- 6. Android MVP架構 完整封裝實例
- 7. Android MVP+Retrofit(封裝)+RxJava實例
- 8. MVP 實戰
- 9. jsoup爬蟲實戰心得
- 10. 實戰心得筆記
- 更多相關文章...
- • C# 封裝 - C#教程
- • 從RedisTemplate中獲得Jedis實例 - Redis教程
- • Docker容器實戰(一) - 封神Server端技術
- • Composer 安裝與使用
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. vs2019運行opencv圖片顯示代碼時，窗口亂碼
- 2. app自動化 - 元素定位不到？別慌，看完你就能解決
- 3. 在Win8下用cisco ××× Client連接時報Reason 422錯誤的解決方法
- 4. eclipse快速補全代碼
- 5. Eclipse中Java/Html/Css/Jsp/JavaScript等代碼的格式化
- 6. idea+spring boot +mabitys(wanglezapin)+mysql (1)
- 7. 勒索病毒發生變種 新文件名將帶有「.UIWIX」後綴
- 8. 【原創】Python 源文件編碼解讀
- 9. iOS9企業部署分發問題深入瞭解與解決
- 10. 安裝pytorch報錯CondaHTTPError：******
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. MVP實戰心得(一)
- 2. Flutter MVP 封裝
- 3. rxjava+retrofit+mvp封裝
- 4. MVP繼續封裝
- 5. RabbitMQ封裝實戰
- 6. Android MVP架構 完整封裝實例
- 7. Android MVP+Retrofit(封裝)+RxJava實例
- 8. MVP 實戰
- 9. jsoup爬蟲實戰心得
- 10. 實戰心得筆記