9章 RxJava混合實戰

時間  2019-11-16
標籤 rxjava 混合 實戰 欄目 Java 简体版
原文   原文鏈接

本篇文章已受權微信公衆號 YYGeeker 獨家發佈轉載請標明出處php

CSDN學院課程地址java

9. RxJava混合開發

9.1 RxJava與Retrofit

添加Retrofit的依賴android

//retrofit
implementation 'com.squareup.retrofit2:retrofit:2.2.0'
implementation 'com.squareup.retrofit2:converter-gson:2.2.0'
//rx+retrofit
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.2.0'
複製代碼

Retrofit是主流的網絡框架，RxJava和Retrofit的使用已經成爲主流的搭配，RxJava能夠經過Retrofit在網絡請求後，對網絡請求的數據進行操做，也能夠配合gson庫進行解析。api

public interface ApiService {
    @GET("/getUserInfo.php")
    Observable<Main2Activity.UserInfo> getUserInfo(@Query("username") String username, @Query("password") String password);

    @GET("/getVipInfo.php")
    Observable<Main2Activity.VipInfo> getVipInfo(@Query("uid") String uid);
}

public void retrofit(View view) {
    //構建Retrofit
    apiService = new Retrofit.Builder()
            .baseUrl("http://172.26.83.19/")
            //rx與Gson混用
            .addConverterFactory(GsonConverterFactory.create())
            //rx與retrofit混用
            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
            .build()
            .create(ApiService.class);

    //構建RxJava
    UserParam param = new UserParam("hensen", "123456");
    //發送param參數
    Observable.just(param)
            .flatMap(new Function<UserParam, ObservableSource<UserInfo>>() {
                @Override
                public ObservableSource<UserInfo> apply(@NonNull UserParam userParam) throws Exception {
                    return apiService.getUserInfo(userParam.param1, userParam.param2);
                }
            })
            .flatMap(new Function<UserInfo, ObservableSource<VipInfo>>() {
                @Override
                public ObservableSource<VipInfo> apply(@NonNull UserInfo userInfo) throws Exception {
                    return apiService.getVipInfo(userInfo.uid);
                }
            })
            .subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Consumer<VipInfo>() {
                @Override
                public void accept(@NonNull VipInfo vipInfo) throws Exception {
                    textView.setText("會員等級：" + vipInfo.vipLevel + "--會員積分：" + vipInfo.vipScore);
                }
            });
}

class UserInfo {
    public String success;
    public String uid;
    public String username;
    public String password;
    public String nikename;
}

class VipInfo {
    public String success;
    public String uid;
    public String vipLevel;
    public String vipScore;
}

class UserParam {
    public String param1;
    public String param2;

    public UserParam(String param1, String param2) {
        this.param1 = param1;
        this.param2 = param2;
    }
}
複製代碼

9.2 RxJava與RxBinding

添加RxBinding的依賴bash

implementation 'com.jakewharton.rxbinding2:rxbinding:2.1.1'
複製代碼

RxBinding是結合RxJava進行綁定View事件的輔助框架。這裏舉例綁定EditText文本變化的監聽事件，當EditText文本變化迅速時，咱們不該當在每次變化的時候去訪問後臺請求，而是等到用戶敲完字以後停下來的半秒纔去請求後臺微信

RxTextView.textChanges(editText)
        //當你敲完字以後停下來的半秒就會執行下面語句
        .debounce(500, TimeUnit.MILLISECONDS)
        //下面這兩個都是數據轉換
        //flatMap：當同時多個網絡請求訪問的時候，前面的網絡數據會覆蓋後面的網絡數據
        //switchMap：當同時多個網絡請求訪問的時候，會以最後一個發送請求爲準，前面網路數據會被最後一個覆蓋
        .switchMap(new Function<CharSequence, ObservableSource<List<String>>>() {
            @Override
            public ObservableSource<List<String>> apply(@NonNull CharSequence charSequence) throws Exception {
                //網絡操做，獲取咱們須要的數據
                List<String> list = new ArrayList<String>();
                list.add("輸入文本變化時，請求網絡次數："+ ++i);
                return Observable.just(list);
            }
        })
        //網絡請求是在子線程的
        .subscribeOn(Schedulers.io())
        //界面更新在主線程
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Consumer<List<String>>() {
            @Override
            public void accept(@NonNull List<String> strings) throws Exception {
                //界面更新
                textView2.setText(strings.toString());
            }
        });
複製代碼

9.3 RxJava與RxLifecycle

添加RxLifecycle的依賴網絡

//rxlifecycle
implementation 'com.trello.rxlifecycle2:rxlifecycle:2.2.1'
implementation 'com.trello.rxlifecycle2:rxlifecycle-components:2.2.1'
implementation 'com.trello.rxlifecycle2:rxlifecycle-android:2.2.1'
implementation 'com.trello.rxlifecycle2:rxlifecycle-android-lifecycle:2.2.1'
複製代碼

RxLifecycle是結合RxJava綁定Activity或者Fragment的生命週期的輔助框架，能夠幫助開發者在綁定的生命週期中自動釋放事件流，從而避免內存泄漏。這裏舉例綁定Activity的onPause事件，當點擊按鈕時跳轉到另外一個Activity時，onPause會被執行，則這個事件將會被釋放，界面將不會再更新對應的文案。RxLifeCycle的使用須要將Activity繼承自RxActivity或是RxFragment等，這些是由RxLifeCycle建立好的並監聽生命週期的組件。經過compose()實現生命週期的綁定架構

public void rxlifecycle() {
    Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> emitter) throws Exception {
            for (int j = 0; j < 20; j++) {
                Thread.sleep(2000);
                emitter.onNext("rxlifecycle " + j);
            }
        }
    })
            .compose(this.bindUntilEvent(ActivityEvent.PAUSE))
            //網絡請求是在子線程的
            .subscribeOn(Schedulers.io())
            //界面更新在主線程
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Consumer<Object>() {
                @Override
                public void accept(@NonNull Object strings) throws Exception {
                    //界面更新
                    textView3.setText(strings.toString());
                }
            });
}

public void rxlifeCycle(View view) {
    startActivity(new Intent(this, Main3Activity.class));
}
複製代碼

9.4 RxJava與Mvp

RxJava與Mvp是在Mvp架構模式下的P層進行數據的處理，其主要的核心思想仍是Mvp，而RxJava在這裏只是在P層作數據的處理，並將處理完的數據在V層進行相對應的UI操做。這裏的Mvp採用當前項目實戰中的真實案例，開發者並不須要關心Mvp層之間的關係，由於這裏已經封裝好了對Mvp的關係綁定，並且對P層也封裝了相對應的生命週期回調，M層的數據模型處理在這裏並無用到實體對象，因此被忽略使用app

9.4.1 封裝基礎層

一、V層框架

只要實現V層的接口，就表示你是V層的一部分

public interface MvpView {

}
複製代碼

二、P層

P層持有V層的實例，且帶有一套P層本身的生命週期，具體是經過Activity生命週期進行回調的

public abstract class MvpPresenter<T extends MvpView> {

    public static final String TAG = "MvpPresenter";

    public T mView;

    public void attach(T view) {
        mView = view;
    }

    /**
     * 對應 activity/fragment onCreate
     */
    protected void onCreate(Bundle savedInstanceState) {
        Log.i(TAG, "onCreate");
    }

    /**
     * 對應 activity/fragment onStart
     */
    protected void onStart() {
        Log.i(TAG, "onStart");
    }

    /**
     * 對應 activity/fragment onResume
     */
    protected void onResume() {
        Log.i(TAG, "onResume");
    }

    /**
     * 對應 activity/fragment onPause
     */
    protected void onPause() {
        Log.i(TAG, "onPause");
    }

    /**
     * 對應 activity/fragment onStop
     */
    protected void onStop() {
        Log.i(TAG, "onStop");
    }

    /**
     * 對應 activity/fragment onDestroy
     */
    protected void onDestroy() {
        Log.i(TAG, "onDestroy");
        if (mView != null) {
            mView = null;
        }
    }
}
複製代碼

三、封裝Activity層

Activity持有P層的實例，且回調P層的生命週期，對外提供建立P層的抽象方法

public abstract class MvpActivity<P extends MvpPresenter> extends AppCompatActivity implements MvpView {

    protected P presenter;

    protected abstract P createPresenter();

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_mvp);

        presenter = createPresenter();
        if (presenter != null) {
            presenter.attach(this);
            presenter.onCreate(savedInstanceState);
        }
    }

    @Override
    protected void onStart() {
        super.onStart();
        if (presenter != null) {
            presenter.onStart();
        }
    }

    @Override
    protected void onResume() {
        super.onResume();
        if (presenter != null) {
            presenter.onResume();
        }
    }

    @Override
    protected void onPause() {
        super.onPause();
        if (presenter != null) {
            presenter.onPause();
        }
    }

    @Override
    protected void onStop() {
        super.onStop();
        if (presenter != null) {
            presenter.onStop();
        }
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        if (presenter != null) {
            presenter.onDestroy();
        }
    }
}
複製代碼

9.4.2 封裝抽象層

一、V層

V層只須要聲明出須要實現的方法

interface CustomView extends MvpView {

    void onLoading(String text);

    void onRefreshData(String text);

    void onError(String text);

    void onComplete(String text);
}
複製代碼

二、P層

P層只須要聲明出須要處理的方法

public abstract class CustomPresenter extends MvpPresenter<CustomView> {

    public CustomPresenter() {
        super();
    }

    abstract void loadData();
}
複製代碼

9.4.3 實現抽象層

一、Activity層

繼承封裝好的Activity，並實現抽象層的方法，在這裏作P層的建立和V層的處理

public class RealView extends MvpActivity<RealPresenter> implements CustomView {

    private TextView textView;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_real_view);
        textView = findViewById(R.id.textView);
    }

    @Override
    protected RealPresenter createPresenter() {
        return new RealPresenter();
    }

    @Override
    public void onLoading(String text) {
        textView.append(text);
    }

    @Override
    public void onRefreshData(String text) {
        textView.append(text);
    }

    @Override
    public void onError(String text) {
        textView.append(text);
    }

    @Override
    public void onComplete(String text) {
        textView.append(text);
    }

    //按鈕點擊事件
    public void bt_get_data(View view) {
        presenter.loadData();
    }
}
複製代碼

二、P層

P層真正的使用RxJava進行數據的處理，並將處理後的數據在UI上更新

public class RealPresenter extends CustomPresenter {

    @Override
    void loadData() {
        Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
                e.onNext("俊俊俊很帥");
                e.onNext("你值得擁有");
                e.onNext("取消關注");
                e.onNext("但仍是要保持微笑");
                e.onComplete();
            }
        })
                .subscribeOn(Schedulers.io())
                //將觀察者切換到主線程  須要在Android環境下運行
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<String>() {
                               @Override
                               public void onSubscribe(Disposable d) {
                                   mView.onLoading("正在加載中...... \n");
                               }

                               @Override
                               public void onNext(String s) {
                                   try {
                                       Thread.sleep(200); //模擬網絡訪問
                                   } catch (InterruptedException e) {
                                       e.printStackTrace();
                                   }
                                   mView.onRefreshData("從網絡上獲取數據：" + s + "\n");
                               }

                               @Override
                               public void onError(Throwable t) {
                                   mView.onError(t.getMessage());
                               }

                               @Override
                               public void onComplete() {
                                   mView.onComplete("加載完成...... \n");
                               }
                           }
                );

    }
}
複製代碼

9.5 小結

一、RxJava與Retrofit

因爲每一個人的項目中不必定有使用Retrofit，可是必定有RxJava，你能夠經過對項目中的網絡請求進行RxJava上的封裝，也能達到和RxJava與Retrofit一樣的效果，我司就是這麼作的

二、RxJava與RxBinding

RxBinding簡化了咱們與View的綁定事件，從RxBinding的RxView源碼中，不難發現其實現的原理就是自定義操做符，能夠翻翻RxView的源碼，模仿自定義操做符的代碼，在本身的項目中去發揮你的想象力，相信在後面的開發，你也能自定義出一套本身的框架

三、RxJava與RxLifecycle

RxLifecycle簡化了咱們對Android生命週期的處理，可是比較惋惜的是須要繼承自RxLifecycle提供的RxActivity或RxFragment等，不少項目都是之前的，並無這個前提，那麼能夠選擇重構RxActivity，或者在原先的Activity中監聽生命週期方法，經過回調來管理RxJava的釋放工做

四、RxJava與Mvp

RxJava在Mvp的模式的使用下，做用顯得更加客觀，由於在P層須要對M層和V層進行處理，不只要從工做線程去獲取M層的數據，還要在UI線程中對V層進行更新，在RxJava中的處理顯得遊刃有餘

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程