Rxjava原理分析之使用与手写(一)

随着Rxjava 在Android中的应用越来越广泛，面试中难免会被问到关于Rxjava的内容，本文就来手写一下Rxjava的简单实现，通过手写简单的Rxjava 再去了解Rxjava的实现原理会更加容易理解Rxjava 为什么这么实现。Rxjava虽然说是基于观察者模式写的，但在我看来更像是基于责任链模式；

在了解Rxjava之前首先要知道java中的泛型使用，泛型使用本文不讨论

项目 app 模块的集成，只使用原生Rxjava，RxAndroid 只是拓展了Rxjava的内容

implementation "io.reactivex.rxjava3:rxjava:3.1.4"

使用：

 public void testRx() {
        Obserable.create(new ObservableOnSubscribe() {
            @Override
            public void subscribe(Observer observer) {
                observer.onNext("lingtao");
            }
        }).subscrible(new Observer() {
            @Override
            public void onNext(String bitmap) {
				Log.e("YulianActivity_LOG", "onNext: "+s);
            }
        });
    }

Rxjava的使用还是很简单的，上面只是给了Rxjava使用的简单例子，下面就参照它的api调用链来手写一个简单的Rxjava；

在手写之前大概了解一下各个类的作用，Obserable、ObservableOnSubscribe、Observer；我们把Obserable 当作是个老板，ObservableOnSubscribe 就相当于项目经理，Observer 就是个员工。

比如现在有个例子：老板现在想做一个项目，他又不知道具体做什么类型项目，所以他让项目经理来确定具体项目，现在项目经理确定了要做一个Android项目，并通知员工干活

Obserable：老板（被观察者），他比较懒，什么都不做，只会招员工

ObservableOnSubscribe：项目经理，由项目经理去通知员工干活，并把资料给员工；

Observer：员工（观察者），收到项目经理给的资料具体干活的对象;

首先需要一个被观察者类Obserable，里面有个create与subscrible 方法，这个Obserable肯定是个泛型类，这个泛型T具体类型由项目经理来确定

public class Obserable {

    ObservableOnSubscribe onSubscribe;
    
    private Obserable(ObservableOnSubscribe onSubscribe) {
        this.onSubscribe = onSubscribe;
    }

    
    public static  Obserable create(ObservableOnSubscribe onSubscribe) {
        return new Obserable(onSubscribe);
    }
	
    
    public void subscrible(Observer observer) {
        onSubscribe.subscribe(observer);
    }

}

Obserable 还是很简单的，Obserable需要持有一个ObservableOnSubscribe项目经理。通过create() 方法创建一个老板，create就一个作用，创建老板；subscrible() 方法就是通知手下干活了，这个通知谁做，当然是项目经理去通知了，所以里面调用了项目经理的subscribe() 方法；

public interface ObservableOnSubscribe{

    // 通知员工的方法
    void subscribe(Observer t);

}

ObservableOnSubscribe很简单，只有一个通知员工的方法，参数中的这个员工是老板给的，在方法里面项目经理把Android资料交给员工

public abstract class Observer {
	
    //员工收到资料干活的方法
    public abstract void onNext(T t);

}

Observer类也很简单，只有一个onNext() 方法，员工收到项目经理给的资料就开始干活了；

到此，一个简单的Rxjava就完成了，当然真正的Rxjava里的Observer 还有其他方法，onError() ,onComplete(),这里就先不写入进来，这里只分析一个简单的Rxjava流程；下面来开始使用

//create 创建一个老板
Obserable.create(new ObservableOnSubscribe() {
    @Override
    public void subscribe(Observer t) {// 项目经理通知员工干活的方法
        //项目经理把Android资料给到员工
        t.onNext("Android资料");
    }
}).subscrible(new Observer() {//老板招员工
    @Override
    public void onNext(String s) {//员工收到资料的方法
         Log.e("MainActivity_LOG", "onNext: 收到资料开始干活了:" + s);
    }
});

手写简单的Rxjava 到此结束，可以去试试打印能不能出来，下篇继续手写，加入一个map操作符

Rxjava原理分析之手写map操作符(二)