RxJava構(gòu)建流基本原理示例解析
正文
本節(jié)，我們從Rxjava使用代碼入手，去結(jié)合自己已有的知識(shí)體系，加查閱部分源碼驗(yàn)證的方式，來一起探索一下Rxjava實(shí)現(xiàn)的基本原理。
為了本文原理分析環(huán)節(jié)，可以被更多的人理解、學(xué)習(xí)，所以小編從初學(xué)者的角度，從使用入手，一點(diǎn)點(diǎn)的分析了其中的源碼細(xì)節(jié)、思想，建議大家隨著本文的章節(jié)步驟，一步一步的來閱讀，才能更快、更好的理解Rxjava的真正的思想精髓，也為我們之后的實(shí)踐課程留一個(gè)好的底子。
1.構(gòu)建流
大家一定郁悶，怎么突然跑出來構(gòu)建流的詞匯，小編你之前也沒講到過呀？大家先別急，我們一步一步來。 首先從一個(gè)最簡(jiǎn)單的，RxJava的樣例使用代碼，我們?nèi)シ纸?，打上步驟
private void test() {
//第一步：just調(diào)用
Observable.just("https://img-blog.csdn.net/20160903083319668")
//第二步：map調(diào)用
.map(new Function<String, Bitmap>() {
@Override
public Bitmap apply(String s) throws Exception {
//Bitmap bitmap = downloadImage(s);
return null;
}
})
//第三步：subscribeOn、observeOn調(diào)用
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
//第四步：subscribe調(diào)用
.subscribe(new Observer<Bitmap>() {
@Override
public void onSubscribe() {
Log.d(TAG, "onSubscribe");
}
@Override
public void onNext(Bitmap s) {
Log.d(TAG, "onNext s = " + s);
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "onError ", e);
}
@Override
public void onComplete() {
Log.d(TAG, "onComplete");
}
});
}
從上面的樣例代碼分析、分解，我們明面上看到四個(gè)步驟，暫且列下來：
- 第一步：just調(diào)用
- 第二步：map調(diào)用
- 第三步：subscribeOn、observeOn調(diào)用
- 第四步：subscribe調(diào)用
這里運(yùn)行一下，我們看到日志打印
大家看一下這里幾個(gè)關(guān)鍵的函數(shù)對(duì)象
Observable 被觀察者，subscribe訂閱的意思，Observer觀察者的意思，just是僅僅輸入url，subscribeOn和observeOn是線程切換功能，map是中間的一個(gè)操作符。接下來，我們就這些看到的操作符、關(guān)鍵字，進(jìn)行解讀。
1.1 just的解讀
從整體鏈?zhǔn)秸{(diào)用的代碼形式上，我們大概可以猜測(cè)到，just、subscribeOn、observeOn、map等中間操作符，必定都是基于同一個(gè)對(duì)象的變形的builder模式，也就是說，他們應(yīng)該都是同一個(gè)類內(nèi)部的方法。
我們看一下的Observable的just源碼
@CheckReturnValue
@NonNull
@SchedulerSupport(SchedulerSupport.NONE)
public static <T> Observable<T> just(T item) {
ObjectHelper.requireNonNull(item, "item is null");
return RxJavaPlugins.onAssembly(new ObservableJust<T>(item));
}
可以看到這里，僅僅是將傳入的T 也就是我們上面樣例中的urlString，包裝為了ObservableJust對(duì)象。而just的調(diào)用，返回的依然是一個(gè)Observable被觀察者對(duì)象。 我們看一下ObservableJust類代碼
public final class ObservableJust<T> extends Observable<T> implements ScalarCallable<T> {
private final T value;
public ObservableJust(final T value) {
this.value = value;
}
@Override
protected void subscribeActual(Observer<? super T> observer) {
ScalarDisposable<T> sd = new ScalarDisposable<T>(observer, value);
observer.onSubscribe(sd);
sd.run();
}
@Override
public T call() {
return value;
}
}
從上面看到，ObservableJust僅僅是將傳入的T封裝了一層而已，它繼承與Observable抽象類，而Observable抽象類實(shí)現(xiàn)了ObservableSource接口
public abstract class Observable<T> implements ObservableSource<T> {
而ObservableSource接口，就是我們外界調(diào)用的subscribe訂閱方法的源頭
public interface ObservableSource<T> {
/**
* Subscribes the given Observer to this ObservableSource instance.
* @param observer the Observer, not null
* @throws NullPointerException if {@code observer} is null
*/
void subscribe(@NonNull Observer<? super T> observer);
}
好了，just講到這里，我們繼續(xù)map，到目前為止，ObservableJust的subscribe方法僅僅是一個(gè)方法而已，并未調(diào)用到，所以我們暫時(shí)不予理睬，后面調(diào)用到，我們?cè)偃シ治觥?/p>
1.2 map的解讀
private void test() {
//第一步：just調(diào)用
Observable.just("https://img-blog.csdn.net/20160903083319668")
//第二步：map調(diào)用
.map(new Function<String, Bitmap>() {
@Override
public Bitmap apply(String s) throws Exception {
//Bitmap bitmap = downloadImage(s);
return null;
}
})
//第三步：subscribeOn、observeOn調(diào)用
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
//第四步：subscribe調(diào)用
.subscribe(new Observer<Bitmap>() {
@Override
public void onSubscribe() {
Log.d(TAG, "onSubscribe");
}
@Override
public void onNext(Bitmap s) {
Log.d(TAG, "onNext s = " + s);
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "onError ", e);
}
@Override
public void onComplete() {
Log.d(TAG, "onComplete");
}
});
}
從這個(gè)使用代碼來看，map是just與subscribe之前的一個(gè)操作符，起到承上啟下的作用。
我們看到首先是just返回的對(duì)象，可以直接調(diào)用map方法，我們之前分析、實(shí)現(xiàn)過just，知道just實(shí)際上返回的就是一個(gè)Observable，所以map方法就是Observable里面的一個(gè)方法。
再往下看，map返回后的對(duì)象，直接調(diào)用了subscribe方法，我們之前設(shè)計(jì)實(shí)現(xiàn)響應(yīng)式功能代碼的時(shí)候知道，subscribe是Observable里面的一個(gè)方法，那么這里也就知道了，map方法肯定也是返回一個(gè)Observable對(duì)象。
從上面分析，我們看到一個(gè)流向圖
大家發(fā)現(xiàn)，這個(gè)流。只做了一件事情，每個(gè)操作符，都是對(duì)上一層的Observable進(jìn)行了一層包裝代理而已。這時(shí)我們提出一個(gè)概念，這個(gè)流，我們命名為構(gòu)建流。
同理，subscribeOn、observeOn是否也是這樣的呢？我們通過源碼驗(yàn)證一下。
1.3 subscribeOn、observeOn
有了上面map的經(jīng)驗(yàn)，我們猜測(cè)，subscribeOn、observeOn順序調(diào)用的時(shí)候，應(yīng)該也僅僅是對(duì)上一層的Observable進(jìn)行了一層包裝代理而已。我們看一下subscribeOn、observeOn的源碼
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.CUSTOM)
@NonNull
public final Observable<T> subscribeOn(@NonNull Scheduler scheduler) {
Objects.requireNonNull(scheduler, "scheduler is null");
//果然這里包裝為了ObservableSubscribeOn對(duì)象
return RxJavaPlugins.onAssembly(new ObservableSubscribeOn<>(this, scheduler));
}
public final Observable<T> observeOn(@NonNull Scheduler scheduler, boolean delayError, int bufferSize) {
Objects.requireNonNull(scheduler, "scheduler is null");
ObjectHelper.verifyPositive(bufferSize, "bufferSize");
return RxJavaPlugins.onAssembly(new ObservableObserveOn<>(this, scheduler, delayError, bufferSize));
}
我們繼續(xù)看一下ObservableSubscribeOn、ObservableObserveOn類的源碼
public final class ObservableSubscribeOn<T> extends AbstractObservableWithUpstream<T, T> {
final Scheduler scheduler;
public ObservableSubscribeOn(ObservableSource<T> source, Scheduler scheduler) {
super(source);
this.scheduler = scheduler;
}
//...省略若干
}
public final class ObservableObserveOn<T> extends AbstractObservableWithUpstream<T, T> {
final Scheduler scheduler;
final boolean delayError;
final int bufferSize;
public ObservableObserveOn(ObservableSource<T> source, Scheduler scheduler, boolean delayError, int bufferSize) {
super(source);
this.scheduler = scheduler;
this.delayError = delayError;
this.bufferSize = bufferSize;
}
}
而AbstractObservableWithUpstream本身就是繼承與Observable
abstract class AbstractObservableWithUpstream<T, U> extends Observable<U> implements HasUpstreamObservableSource<T> {}
1.4 小結(jié)
從上面可以看到，也就是到目前為止，just、map、subscribeOn、observeOn一系列調(diào)用下來，依然都是執(zhí)行一個(gè)操作而已，即每個(gè)操作符，都是對(duì)上一層的Observable進(jìn)行了一層包裝代理而已。
這就是構(gòu)建流，構(gòu)建流的作用就是，從開始操作符到訂閱為止，從左往右執(zhí)行，期間每個(gè)操作符，都是對(duì)上一層的Observable進(jìn)行了一層包裝代理而已。如圖：
以上就是RxJava構(gòu)建流基本原理示例解析的詳細(xì)內(nèi)容，更多關(guān)于RxJava構(gòu)建流基本原理的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
Android獲取手機(jī)SIM卡運(yùn)營(yíng)商信息的方法
這篇文章主要介紹了Android獲取手機(jī)SIM卡運(yùn)營(yíng)商信息的方法,可獲得手機(jī)的型號(hào)、運(yùn)營(yíng)商信息及系統(tǒng)版本等,需要的朋友可以參考下2014-09-09
Android中使用OkHttp包處理HTTP的get和post請(qǐng)求的方法
OkHttp包為安卓開發(fā)中的HTTP協(xié)議網(wǎng)絡(luò)編程帶來了很大的便利,這里我們就來看一下最基本的、Android中使用OkHttp包處理HTTP的get和post請(qǐng)求的方法:2016-07-07
Android使用ViewPager實(shí)現(xiàn)圖片滑動(dòng)預(yù)覽效果
這篇文章主要為大家詳細(xì)介紹了Android使用ViewPager實(shí)現(xiàn)圖片滑動(dòng)預(yù)覽效果，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-07-07
AsyncTask是Android本身提供的一種輕量級(jí)的異步任務(wù)類。它可以在線程池中執(zhí)行后臺(tái)任務(wù)，然后把執(zhí)行的進(jìn)度和最終的結(jié)果傳遞給主線程更新UI。本文將介紹Android中AsyncTask的工作原理。2021-06-06
本文詳細(xì)講解了Android對(duì)話框AlertDialog的實(shí)現(xiàn)方式，文中通過示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-12-12
Android開發(fā)實(shí)現(xiàn)ImageView加載攝像頭拍攝的大圖功能
這篇文章主要介紹了Android開發(fā)實(shí)現(xiàn)ImageView加載攝像頭拍攝的大圖功能,涉及Android基于ImageView的攝像頭拍攝圖片加載、保存及權(quán)限控制等相關(guān)操作技巧,需要的朋友可以參考下2017-11-11
Android自定義WaveView實(shí)現(xiàn)波浪進(jìn)度效果
最近注意到百度外賣以及淘寶個(gè)人中心，都用到了類似水波起伏的效果，于是就參照網(wǎng)上的資料然后自己整改，自定義了一個(gè)waveView來實(shí)現(xiàn)這個(gè)效果，文中給出來詳細(xì)的實(shí)現(xiàn)原理及實(shí)例代碼，有需要的朋友們可以參考借鑒，下面來一起看看吧。2017-01-01
屏蔽RecyclerView單邊滑動(dòng)到頭陰影(fadingEdge)的方法
這篇文章主要給大家介紹了如何屏蔽RecyclerView單邊滑動(dòng)到頭陰影(fadingEdge)的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2018-04-04
android實(shí)現(xiàn)可拖動(dòng)的浮動(dòng)view
這篇文章主要為大家詳細(xì)介紹了android實(shí)現(xiàn)可拖動(dòng)的浮動(dòng)view，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-04-04
Android 自定義圓形帶刻度漸變色的進(jìn)度條樣式實(shí)例代碼
這篇文章主要介紹了Android 自定義圓形帶刻度漸變色的進(jìn)度條的實(shí)例代碼,非常不錯(cuò)，具有參考借鑒價(jià)值，需要的朋友可以參考下2016-11-11