注意Rxjava配合Retrofit進行網絡請求進行了更新,對Rxjava生命周期處理更加合理,詳情請看Demo

最近看了許多關于Rxjava2.0,Retrofit及MVP相關的文章,收貨頗多,于是忍不住想自己將這幾天所學的東西整理一遍,便于以后看到這篇文章的人能很方便的去使用.如果這些知識還不了解的可以去看以下幾篇文章:

MVP介紹

優(yōu)點

模型與視圖完全分離，我們可以修改視圖而不影響模型；
可以更高效地使用模型，因為所有的交互都發(fā)生在一個地方——Presenter內部；
我們可以將一個Presenter用于多個視圖，而不需要改變Presenter的邏輯。這個特性非常的有用，因為視圖的變化總是比模型的變化頻繁；
如果我們把邏輯放在Presenter中，那么我們就可以脫離用戶接口來測試這些邏輯（單元測試）。

如下圖:

MVP與MVC對比圖

MVP實際操作

介紹兩種不同的MVP的分包方式,區(qū)別就是一種相對簡單一種相對復雜

相對使用簡單的

分包方式如下圖:

MVP架構圖

common,一般存放一些APP常量,公用的東西
http,一般存放自己封裝的網絡請求庫
mvp,存放,model層,presenter層和view層
presentation,UI展示層,一般會在這個包下在細分activity包,fragment包及自定義view包等等
util,App常用的一些工具類

步驟介紹

第一步 編寫B(tài)asePreseter,IBaseView,及BaseActivity等基類,代碼如下
BasePresenter

 public abstract class BasePresenter<V extends IBaseView> {

//Presenter持有的View
protected V mView;
//上下文
protected Context mContext;

//構造方法讓Presenter層持有View層的引用
public BasePresenter(Context context,V view){
    this.mContext = context;
    this.mView = view;
    }
}

IBaseView,這里我是空實現(xiàn),你也可以將一些公用的方法放進去

 public interface IBaseView {  }

ITestView這里邊我寫了一個start()方法

public interface ITestView extends IBaseView{
          void start();
}

BaseActivity

 public abstract class BaseActivity<P extends BasePresenter> extends AppCompatActivity {
  
 protected P mPresenter;

@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(getLayoutId());

  initPresenter();
  initView();
}

protected abstract void initView();

protected abstract void initPresenter();

protected abstract int getLayoutId();
}

第二步 編寫測試的TestActivity,及TestPreseter
TestActivity代碼很簡單,就是實現(xiàn)ITestView以及BaseActivity的一些重寫的方法

public class TestActivity extends BaseActivity<TestPresenter> implements ITestView{
private Context mContext;

@Override
protected void initView() {
    mPresenter.testPresenter();
}

public void testActivity(){
    Log.d("print", "擁有ITestView的引用");
}

@Override
protected void initPresenter() {
    mContext = this;
    mPresenter = new TestPresenter(mContext,this);
}


@Override
protected int getLayoutId() {
    return R.layout.activity_test;
}

@Override
public void start() {
    testActivity();
}
}

TestPresenter

 public class TestPresenter extends BasePresenter<ITestView>{

public TestPresenter(Context mContext, ITestView mView) {
    super(mContext, mView);
}

public void testPresenter(){
    Log.d("print", "擁有TestPresenter的引用");
    mView.start();
}

}

運行后的效果圖如下:

效果圖

邏輯梳理

以上代碼就是一個很簡單的MVP模式,View層含有Presenter層的引用,Presenter層同時含有View層的引用,model層如涉及到一些服務,數(shù)據(jù)庫等等的操作,或者從服務器獲取到的數(shù)據(jù),就可以將他的邏輯寫到Presenter層里面,這里我就沒演示了,這樣的話,就實現(xiàn)了View層和model層的分離,他們都是通過Presenter層來建立聯(lián)系的.

相對復雜的

傳送門

Rxjava+Retrofit+Okhttp封裝

導入以下幾個包

implementation 'io.reactivex.rxjava2:rxjava:2.1.5'
implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'
implementation 'com.squareup.retrofit2:retrofit:2.3.0'
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
implementation 'com.squareup.retrofit2:converter-scalars:2.3.0'
implementation 'com.squareup.retrofit2:converter-gson:2.3.0'
implementation 'com.squareup.okhttp3:okhttp:3.9.0'
implementation 'com.squareup.okhttp3:logging-interceptor:3.9.0'
//Cookie持久化管理(推薦)
implementation 'com.github.franmontiel:PersistentCookieJar:v1.0.1'

第一步

創(chuàng)建工具類：RetrofitServiceManager

RetrofitServiceManager特性
RetrofitHelper特性：
單例形式創(chuàng)建Retrofit實例；

使用okhttp3作為請求客戶端；

使用gson作為數(shù)據(jù)轉換器；

添加各種攔截器,如日志攔截,請求頭攔截,請求參數(shù)攔截等等

開啟數(shù)據(jù)緩存，無網絡時可從緩存讀取數(shù)據(jù)；

輔助類靜態(tài)方法獲取RetrofitServiceManager實例。

//看代碼

public class RetrofitServiceManager {
private static final int DEFAULT_TIME_OUT = 10;//超時時間5s
private static final int DEFAULT_READ_TIME_OUT = 10;//讀取時間
private static final int DEFAULT_WRITE_TIME_OUT = 10;//讀取時間
private Retrofit mRetrofit;


private RetrofitServiceManager(){
    //OkHttpClient配置
    OkHttpClient.Builder builder = new OkHttpClient.Builder();
    builder.connectTimeout(DEFAULT_TIME_OUT, TimeUnit.SECONDS);
    builder.readTimeout(DEFAULT_READ_TIME_OUT, TimeUnit.SECONDS);
    builder.writeTimeout(DEFAULT_WRITE_TIME_OUT,TimeUnit.SECONDS);
    builder.cache(new Cache(new File(Environment.getExternalStorageDirectory() + "/RxJavaDemo"),1024*1024*10));
    //cookie持久化管理
    builder.cookieJar(new PersistentCookieJar(new SetCookieCache(),new SharedPrefsCookiePersistor(App.getInstance())));

    addInterceptor(builder);


    mRetrofit = new Retrofit.Builder()
            .client(builder.build())
            .baseUrl(ApiService.BASR_URL)
            .addConverterFactory(ScalarsConverterFactory.create())
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
            .build();
}

/**
 * 添加各種攔截器
 * @param builder
 */
private void addInterceptor(OkHttpClient.Builder builder) {
    // 添加日志攔截器
    HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor();
    loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);

    HttpHeaderInterceptor httpHeaderInterceptor = new HttpHeaderInterceptor.Builder().build();
    //日志攔截 
    builder.addInterceptor(loggingInterceptor);
    //頭部參數(shù)攔截
    builder.addInterceptor(httpHeaderInterceptor);
    //緩存攔截
    builder.addInterceptor(new HttpCacheInterceptor());
    //請求參數(shù)攔截
    builder.addInterceptor(new CommonParamsInterceptor());
}

//單例 餓漢模式
private static class SingletonHolder{
    private static RetrofitServiceManager retrofitServiceManager = new RetrofitServiceManager();
}

public static RetrofitServiceManager getInstance(){
    return SingletonHolder.retrofitServiceManager;
}

//獲取Service實例
public <T> T creat(Class<T> tClass){
    return mRetrofit.create(tClass);
}

}

第二步

RxJava封裝,再Retrofit中使用RxJava，需要封裝的地方僅有2個地方，

切換線程操作

響應結果處理：onComplete()方法可選，通用錯誤響應，保留onSuccess()供用戶調用

假設我們的Api返回結果如下

{
  "code": 0 //0代表成功 非0均為失敗
  "msg": ""
  "model":{}
}

為此,我們創(chuàng)建響應結果的基類:BaseResponse

public class BaseResponse<T> {
private int code;
private String msg;
private T model;

public T getData() {
    return model;
}

public void setData(T model) {
    this.model = model;
}

public void setCode(int code) {
    this.code = code;
}

public int getCode() {
    return code;
}

public String getMsg() {
    return msg;
}

public void setMsg(String msg) {
    this.msg = msg;

}

public boolean isSuccess(){
    return code == 0;
}

}

基于以上響應實體類，我們創(chuàng)建RxJava訂閱者的封裝基類:RxSubcriber

public  abstract class RxSubcriber<T> implements Observer<BaseResponse<T>> {

private ProgressDialog mProgressDialog;
private Disposable disposable;
private BaseActivity context;
private String errorMsg;

public RxSubcriber(BaseActivity context){
    this.context = context;
}


@Override
public void onSubscribe(Disposable d) {
    disposable = new CompositeDisposable();
    showLoading();
}

@Override
public void onNext(BaseResponse<T> value) {
    if(!value.isSuccess()){
        ApiException apiException = new ApiException(value.getCode(),value.getMsg());
        onError(apiException);
        return;
    }
    onSuccess(value.getData());
}


@Override
public void onError(Throwable e) {
    if (e instanceof IOException) {
        /** 沒有網絡 */
        errorMsg = "Please check your network status";
    } else if (e instanceof HttpException) {
        /** 網絡異常，http 請求失敗，即 http 狀態(tài)碼不在 [200, 300) 之間, such as: "server internal error". */
        errorMsg = ((HttpException) e).response().message();
    } else if (e instanceof ApiException) {
        /** 網絡正常，http 請求成功，服務器返回邏輯錯誤 */
        errorMsg = ((ApiException)e).getMsg();
    } else {
        /** 其他未知錯誤 */
        errorMsg = !TextUtils.isEmpty(e.getMessage()) ? e.getMessage() : "unknown error";
    }


   dismissLoading();

    new AlertDialog.Builder(context)
            .setTitle("提示")
            .setMessage(errorMsg)
            .setPositiveButton("確定", new DialogInterface.OnClickListener() {
                @Override
                public void onClick(DialogInterface dialogInterface, int i) {
                    dialogInterface.dismiss();
                    if(!disposable.isDisposed()){
                        disposable.dispose();
                    }
                }
            }).show();
}

@Override
public void onComplete() {
    dismissLoading();
    Log.d("print", "-->執(zhí)行了完成的方法");
}

public abstract void onSuccess(T t);

private void showLoading(){
    if(mProgressDialog == null){
        mProgressDialog = new ProgressDialog(context);
        mProgressDialog.setMessage("正在加載中...");
        mProgressDialog.show();
    }
}

private void dismissLoading(){
    if(mProgressDialog != null){
        mProgressDialog.dismiss();
    }
}
}

這里主要處理了返回的數(shù)據(jù),錯誤異常的統(tǒng)一處理,以及Dialog加載框的處理.

接下來，對線程切換操作再做一個封裝：RxJavaHelper

public class RxjavaHelper {

/**
 * 切換線程操作
 * @return Observable轉換器
 */
public static <T> ObservableTransformer<T, T> observeOnMainThread() {
    return new ObservableTransformer<T, T>() {

        @Override
        public ObservableSource<T> apply(Observable<T> upstream) {
            return upstream.subscribeOn(Schedulers.io())
                    .unsubscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread());
        }
    };
}


}

基本封裝完畢,現(xiàn)在Api的請求如下:

 RetrofitServiceManager.getInstance().creat(ApiService.class)
                    .getHome()
                    .compose(RxjavaHelper.<BaseResponse<List<RecommendEntity>>>observeOnMainThread())
                    .subscribe(new RxSubcriber<List<RecommendEntity>>(this) {
                        @Override
                        public void onSuccess(List<RecommendEntity> o) {
                            Log.d("print", "--->" + o);
                        }
                    });

現(xiàn)在看看請求結果:

image.png

OK，還可以，Retrofit + RxJava2.0 封裝就暫時這樣了。如果使用過程有什么問題再修改修改?。?br> 最后附上項目Demo

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九欧美,1769亚洲,黄色成人av

Rxjava2.0+Retrofit+Okhttp(封裝使用)+MVP框架搭建

Rxjava2.0+Retrofit+Okhttp(封裝使用)+MVP框架搭建

MVP介紹

MVP實際操作

相對使用簡單的

步驟介紹

邏輯梳理

相對復雜的

Rxjava+Retrofit+Okhttp封裝

第一步

第二步

如果大家喜歡的話,請為我點贊,謝謝!

相關閱讀更多精彩內容

友情鏈接更多精彩內容

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九 欧美,1769亚洲,黄色成人av

Rxjava2.0+Retrofit+Okhttp(封裝使用)+MVP框架搭建

MVP介紹

MVP實際操作

相對使用簡單的

步驟介紹

邏輯梳理

相對復雜的

Rxjava+Retrofit+Okhttp封裝

第一步

第二步

如果大家喜歡的話,請為我點贊,謝謝!

相關閱讀更多精彩內容

友情鏈接更多精彩內容

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九欧美,1769亚洲,黄色成人av