RxJava構(gòu)建流基本原理示例解析

更新時間：2022年12月30日 16:29:51 作者：itbird01

這篇文章主要為大家介紹了RxJava構(gòu)建流基本原理示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

正文

本節(jié)，我們從Rxjava使用代碼入手，去結(jié)合自己已有的知識體系，加查閱部分源碼驗證的方式，來一起探索一下Rxjava實現(xiàn)的基本原理。

為了本文原理分析環(huán)節(jié)，可以被更多的人理解、學(xué)習(xí)，所以小編從初學(xué)者的角度，從使用入手，一點點的分析了其中的源碼細(xì)節(jié)、思想，建議大家隨著本文的章節(jié)步驟，一步一步的來閱讀，才能更快、更好的理解Rxjava的真正的思想精髓，也為我們之后的實踐課程留一個好的底子。

1.構(gòu)建流

大家一定郁悶，怎么突然跑出來構(gòu)建流的詞匯，小編你之前也沒講到過呀？大家先別急，我們一步一步來。首先從一個最簡單的，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");
                }
            });
}

從上面的樣例代碼分析、分解，我們明面上看到四個步驟，暫且列下來：

第一步：just調(diào)用
第二步：map調(diào)用
第三步：subscribeOn、observeOn調(diào)用
第四步：subscribe調(diào)用

這里運行一下，我們看到日志打印

大家看一下這里幾個關(guān)鍵的函數(shù)對象

Observable 被觀察者，subscribe訂閱的意思，Observer觀察者的意思，just是僅僅輸入url，subscribeOn和observeOn是線程切換功能，map是中間的一個操作符。接下來，我們就這些看到的操作符、關(guān)鍵字，進(jìn)行解讀。

1.1 just的解讀

從整體鏈?zhǔn)秸{(diào)用的代碼形式上，我們大概可以猜測到，just、subscribeOn、observeOn、map等中間操作符，必定都是基于同一個對象的變形的builder模式，也就是說，他們應(yīng)該都是同一個類內(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對象。而just的調(diào)用，返回的依然是一個Observable被觀察者對象。我們看一下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抽象類實現(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方法僅僅是一個方法而已，并未調(diào)用到，所以我們暫時不予理睬，后面調(diào)用到，我們再去分析。

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");
                }
            });
}

從這個使用代碼來看，map是just與subscribe之前的一個操作符，起到承上啟下的作用。

我們看到首先是just返回的對象，可以直接調(diào)用map方法，我們之前分析、實現(xiàn)過just，知道just實際上返回的就是一個Observable，所以map方法就是Observable里面的一個方法。

再往下看，map返回后的對象，直接調(diào)用了subscribe方法，我們之前設(shè)計實現(xiàn)響應(yīng)式功能代碼的時候知道，subscribe是Observable里面的一個方法，那么這里也就知道了，map方法肯定也是返回一個Observable對象。

從上面分析，我們看到一個流向圖

大家發(fā)現(xiàn)，這個流。只做了一件事情，每個操作符，都是對上一層的Observable進(jìn)行了一層包裝代理而已。這時我們提出一個概念，這個流，我們命名為構(gòu)建流。

同理，subscribeOn、observeOn是否也是這樣的呢？我們通過源碼驗證一下。

1.3 subscribeOn、observeOn

有了上面map的經(jīng)驗，我們猜測，subscribeOn、observeOn順序調(diào)用的時候，應(yīng)該也僅僅是對上一層的Observable進(jìn)行了一層包裝代理而已。我們看一下subscribeOn、observeOn的源碼

    @CheckReturnValue
    @SchedulerSupport(SchedulerSupport.CUSTOM)
    @NonNull
    public final Observable&lt;T&gt; subscribeOn(@NonNull Scheduler scheduler) {
        Objects.requireNonNull(scheduler, "scheduler is null");
        //果然這里包裝為了ObservableSubscribeOn對象
        return RxJavaPlugins.onAssembly(new ObservableSubscribeOn&lt;&gt;(this, scheduler));
    }
    public final Observable&lt;T&gt; observeOn(@NonNull Scheduler scheduler, boolean delayError, int bufferSize) {
        Objects.requireNonNull(scheduler, "scheduler is null");
        ObjectHelper.verifyPositive(bufferSize, "bufferSize");
        return RxJavaPlugins.onAssembly(new ObservableObserveOn&lt;&gt;(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í)行一個操作而已，即每個操作符，都是對上一層的Observable進(jìn)行了一層包裝代理而已。

這就是構(gòu)建流，構(gòu)建流的作用就是，從開始操作符到訂閱為止，從左往右執(zhí)行，期間每個操作符，都是對上一層的Observable進(jìn)行了一層包裝代理而已。如圖：

以上就是RxJava構(gòu)建流基本原理示例解析的詳細(xì)內(nèi)容，更多關(guān)于RxJava構(gòu)建流基本原理的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章:

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

RxJava構(gòu)建流基本原理示例解析

目錄

正文

1.構(gòu)建流

1.1 just的解讀

1.2 map的解讀

1.3 subscribeOn、observeOn

1.4 小結(jié)

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

RxJava構(gòu)建流基本原理示例解析

目錄

正文

1.構(gòu)建流

1.1 just的解讀

1.2 map的解讀

1.3 subscribeOn、observeOn

1.4 小結(jié)

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

1.3 subscribeOn、observeOn