本文共 10169 字，大约阅读时间需要 33 分钟。

Rx系列当前用的比较广泛，链式调度，方便整理逻辑和书写规范。便于阅读。用的人越来越多，那么既然用了，总是想要去一探rxjava的究竟。这里简单的记录一下学习过程和分享一下学习经验。其实谈不上解析rxjava。哈哈~~这里给一些想要学习rxjava的链接，我觉得写得很好的，一个是抛物线的rxjava介绍，相当详细。

Rxjava git的地址：

抛物线的给Android开发者的

rxjava：

---

Rxjava浅析

那么来浏览一遍rxjava源码的调用过程。

Observable.create(new Observable.OnSubscribe
   
    () {            @Override            public void call(Subscriber
     subscriber) {                subscriber.onNext("Observable.create call");            }        }).map(new Func1
    
     () {            @Override            public Bitmap call(String s) {                Log.i("tag","map call "+s);                Bitmap  bitmap = BitmapFactory.decodeResource(MainActivity.this.getResources(),R.mipmap.ic_launcher);                return bitmap;            }        }).subscribe(new Subscriber
     
      () {            @Override            public void onCompleted() {            }            @Override            public void onError(Throwable e) {            }            @Override            public void onNext(Bitmap bitmap) {                main_title_iv.setImageBitmap(bitmap);            }        });
     
    
   

这是最简单的使用范例。我们创建了一个OnSubscrible，那么看看OnSubscribe。

OnSubscribe是一个接口，继承于Action1。

以一个内部类传入OnSubscribe，重写call具体操作。回到Observable的create方法。

create静态方法返回了一个Observable。回到代码中，继续调用了map来进行转换。

map参数中传入的是一个Func1接口内部类。

Func1的作用就是将一个参数T转换为另一个参数R，并返回。具体转换的操作就交给了用户去实现。这里的泛型和通配符，限定符是java的基础，可以在网上搜一搜，等我有空也总结一下泛型的知识，大概说说就是PECS原则和？ 通配符，extends，super限定符的使用。在回到map函数中，将func传入方法lift中。

lift中传入了OperatorMap。

这里做了具体的参数转换操作，transfomer是Func1，调用call（t），就会调用外部用户自己定义的call参数。返回了参数R，这里O是一个订阅者，参数为 （? super R） ，那么在onNext( T t）这个函数中，调用了O的onNext( R r)；也就是被观察者通知观察者更新。

Operator接口继承于Func1，将Subscriber(R)转换为Subscriber(T),并返回。那么在回到lift（Operator）这个函数，返回了一个Observable。

在第一步的时候，hook.onLift返回一个operator，调用call。这里就是回调OperatorMap中的call的逻辑。获得了一个新的Subscriber，其中的onNext就是订阅者的具体逻辑。第二步中的onSubscribe，就是Observabe的create中传入的onSubscribe。就会调用外部实现的call逻辑。也就是这个call。

new Observable.OnSubscribe
   
    () {            @Override            public void call(Subscriber
     subscriber) {                subscriber.onNext("Observable.create call");            }        }
   

那么该函数的参数subscriber是经过中间Operator变换的到的新的Subscriber，那么onNext中有具体参数变换，Func1和真正订阅者引用。这里的Subscriber就是OperatorMap中call返回的。

这里的transformer就是外部实现的call方法，而这里的O就是真正的订阅者。

transfomer就是以下代码。

new Func1
   
    () {            @Override            public Bitmap call(String s) {                Log.i("tag","map call "+s);                Bitmap  bitmap = BitmapFactory.decodeResource(MainActivity.this.getResources(),R.mipmap.ic_launcher);                return bitmap;            }        }
   

O就是以下代码。

new Subscriber
   
    () {            @Override            public void onCompleted() {            }            @Override            public void onError(Throwable e) {            }            @Override            public void onNext(Bitmap bitmap) {                main_title_iv.setImageBitmap(bitmap);            }        }
   

那么回到Obervable的链式调度，最后调用的是subscribe方法订阅。使订阅者和观察者获得联系。

箭头所指的地方就是所有调用的起点， hook.onSubscribeStart(observable, observable.onSubscribe)返回一个Onsubscribe，最后调用call。最后开启链式调度。整个过程中有两个Onsubscribe。第一个是create的时候外部传入的，第二个是在map中lift方法返回的Observabe传入的。也就是最后调用call的OnSubscribe。

最后在大概讲一下这里的变换逻辑。

1. 先调用Observable的create，传入一个OnSubscribe。 2.map方法，调用一个lift，传入一个Operator，返回一个Observable,Observabe传入一个OnSubscribe。 3.最后调用subscribe，传入一个观察者subscriber。最后在subscribe方法中调用了第二步中传入的onsubscribe的call方法。链式调度启动了。 看看时序图，不过建议自己去整理一下，不然还是很难理清楚逻辑。

---

手写Rxjava

上面的解析没有涉及线程变换和flatMap等等，那些底层涉及比较复杂，如果感兴趣的就自己去看看源码吧，这里就不写出来了，先来个简单的，不调用map转换函数。

首先，我们需要一个Action1接口。Action1.java

/** * Created by ShuWen on 2017/4/11. */public interface Action1
   
     {    void call(T t);}
   

然后在需要一个Subscriber接口。

/** * Created by ShuWen on 2017/4/14. */public interface Subscriber
   
     {    void onNext(T t);}
   

那么在来一个OnSubscribe，接收Subscriber。这里使用了通配符，作为参数使用?和super限定。

/** * Created by ShuWen on 2017/4/14. */public interface OnSubscribe
   
     extends Action1
    
     > {
   }
    
   

那么最重要的Observable类

/** * Created by ShuWen on 2017/4/14. */public class Observable
   
     {    private OnSubscribe
    
       onSubscribe;    private Observable (OnSubscribe
     
       onSubscribe){        this.onSubscribe = onSubscribe;    }    public static 
      
        Observable
       
         create(OnSubscribe
        
          onSubscribe){ return new Observable<>(onSubscribe); } public void subcribe(Subscriber
          subscriber){ onSubscribe.call(subscriber); }}
        
       
      
     
    
   

那么简单的rxjava就已经完成了。在MainActivity使用。

import android.support.v7.app.AppCompatActivity;import android.os.Bundle;import android.util.Log;import android.widget.ImageView;import com.example.administrator.rxjavademo.simple.Observable;import com.example.administrator.rxjavademo.simple.OnSubscribe;import com.example.administrator.rxjavademo.simple.Subscriber;public class MainActivity extends AppCompatActivity {
       ImageView imageView;    @Override    protected void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentView(R.layout.activity_main);        imageView = (ImageView) findViewById(R.id.imageView2);        Observable.create(new OnSubscribe
   
    () {            @Override            public void call(Subscriber
     subscriber) {                Log.i("tag00","图片地址");                subscriber.onNext("图片地址");            }        }).subcribe(new Subscriber
    
     () {            @Override            public void onNext(String s) {                Log.i("tag00","onNext:"+s);            }        });    }}
    
   

运行结果：

04-14 17:08:39.916 26243-26243/? I/tag00: 图片地址04-14 17:08:39.916 26243-26243/? I/tag00: onNext:图片地址

是不是很简单，把它核心逻辑抽出来，没有添加枝叶，看这逻辑就简单明了了很多。那么再把map函数加进去。需要一个转换函数func1

/** * Created by ShuWen on 2017/4/14. */public interface Func1
   
     {    R call(T t);}
   

再来一个Operator，继承Func1。

/** * Created by ShuWen on 2017/4/14. */public interface Operator
   
     extends Func1
    
     ,Subscriber
     > {
   }
    
   

在来一个OperatorMap，实现Operator接口，onNext方法中写具体逻辑。

/** * Created by ShuWen on 2017/4/14. */public class OperatorMap
   
     implements Operator
    
      {
       private Func1
      transform;    public OperatorMap(Func1
      transform) {        this.transform = transform;    }    @Override    public Subscriber
      call(final Subscriber
      subscriber) {        return new Subscriber
     
      () {            @Override            public void onNext(T t) {                R r = transform.call(t);                subscriber.onNext(r);            }        };    }}
     
    
   

在源码中，lift返回的时候，直接返回了一个内部类。这里我把内部类提出来。建一个OnSubscribeLift中间类。

/** * Created by ShuWen on 2017/4/14. */public class OnSubscribeLift
   
     implements OnSubscribe
    
      {
       private Operator
      operator;    private OnSubscribe
     
       onSubscribe;    public OnSubscribeLift(Operator
       operator, OnSubscribe
      
        onSubscribe) {        this.operator = operator;        this.onSubscribe = onSubscribe;    }    @Override    public void call(Subscriber
        subscriber) {        Subscriber
        st = operator.call(subscriber);        onSubscribe.call(st);    }}
      
     
    
   

那么在Observable中添加一些新的方法。

/** * Created by ShuWen on 2017/4/14. */public class Observable
   
     {    private OnSubscribe
    
       onSubscribe;    private Observable (OnSubscribe
     
       onSubscribe){        this.onSubscribe = onSubscribe;    }    public static 
      
        Observable
       
         create(OnSubscribe
        
          onSubscribe){ return new Observable<>(onSubscribe); } public void subcribe(Subscriber
          subscriber){ onSubscribe.call(subscriber); } public 
         
           Observable
          
            map(Func1
            func1){ return lift(new OperatorMap<>(func1)); } private 
           
             Observable
            
              lift(OperatorMap
             
               trOperatorMap) { return new Observable<>(new OnSubscribeLift<>(trOperatorMap,onSubscribe)); }}
             
            
           
          
         
        
       
      
     
    
   

那么在MainActivity中使用。

import android.graphics.Bitmap;import android.graphics.BitmapFactory;import android.support.v7.app.AppCompatActivity;import android.os.Bundle;import android.util.Log;import android.widget.ImageView;import com.example.administrator.rxjavademo.simple.Func1;import com.example.administrator.rxjavademo.simple.Observable;import com.example.administrator.rxjavademo.simple.OnSubscribe;import com.example.administrator.rxjavademo.simple.Subscriber;public class MainActivity extends AppCompatActivity {
       ImageView imageView;    @Override    protected void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentView(R.layout.activity_main);        imageView = (ImageView) findViewById(R.id.imageView2);        Observable.create(new OnSubscribe
   
    () {            @Override            public void call(Subscriber
     subscriber) {                Log.i("tag00","图片地址");                subscriber.onNext("图片地址");            }        }).subcribe(new Subscriber
    
     () {            @Override            public void onNext(String s) {                Log.i("tag00","onNext:"+s);            }        });        Observable.create(new OnSubscribe
     
      () {            @Override            public void call(Subscriber
       subscriber) {                Log.i("tag00","图片下载地址");                subscriber.onNext("http://write.blog.csdn.net/mdeditor");            }        }).map(new Func1
      
       () {            @Override            public Bitmap call(String s) {                Log.i("tag00","map 拿到的图片地址："+s);                Bitmap bitmap = BitmapFactory.decodeResource(MainActivity.this.getResources(),R.mipmap.ic_launcher);                return bitmap;            }        }).subcribe(new Subscriber
       
        () {            @Override            public void onNext(Bitmap bitmap) {                imageView.setImageBitmap(bitmap);            }        });    }}
       
      
     
    
   

运行结果：

com.example.administrator.rxjavademo I/tag00: 图片地址com.example.administrator.rxjavademo I/tag00: onNext:图片地址com.example.administrator.rxjavademo I/tag00: 图片下载地址com.example.administrator.rxjavademo I/tag00: map 拿到的图片地址：http://write.blog.csdn.net/mdeditor

怎么样？自己写一遍是不是感觉不错？这个手写的Rxjava有点简单。只是利用了一点原生rxjava的原理。不过对于rx系列的理解。是一个不错的提升。rxjava其他方法就不写了。抛砖引玉嘛，喜欢看源码的猿友就自己去取经了。

敲字也有点累呀~觉得有用呢，大家觉得有用点个赞，谢谢。