Android框架系列 - 手写,浅析Rxjava
2017-04-14 20:41
405 查看
Rx系列当前用的比较广泛,链式调度,方便整理逻辑和书写规范。便于阅读。用的人越来越多,那么既然用了,总是想要去一探rxjava的究竟。这里简单的记录一下学习过程和分享一下学习经验。其实谈不上解析rxjava。哈哈~~这里给一些想要学习rxjava的链接,我觉得写得很好的,一个是抛物线的rxjava介绍,相当详细。
Rxjava git的地址:https://github.com/ReactiveX/RxJava
抛物线的给Android开发者的
rxjava:http://gank.io/post/560e15be2dca930e00da1083
![](http://img.blog.csdn.net/20170414150125484?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
这是最简单的使用范例。我们创建了一个OnSubscrible,那么看看OnSubscribe。
![](http://img.blog.csdn.net/20170414151726005?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
OnSubscribe是一个接口,继承于Action1。
![](http://img.blog.csdn.net/20170414151829303?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
以一个内部类传入OnSubscribe,重写call具体操作。回到Observable的create方法。
![](http://img.blog.csdn.net/20170414152116632?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
create静态方法返回了一个Observable。回到代码中,继续调用了map来进行转换。
![](http://img.blog.csdn.net/20170414152244867?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
map参数中传入的是一个Func1接口内部类。
![](http://img.blog.csdn.net/20170414152645697?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
Func1的作用就是将一个参数T转换为另一个参数R,并返回。具体转换的操作就交给了用户去实现。这里的泛型和通配符,限定符是java的基础,可以在网上搜一搜,等我有空也总结一下泛型的知识,大概说说就是PECS原则和? 通配符,extends,super限定符的使用。在回到map函数中,将func传入方法lift中。
![](http://img.blog.csdn.net/20170414153319139?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
lift中传入了OperatorMap。
![](http://img.blog.csdn.net/20170414153445031?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
这里做了具体的参数转换操作,transfomer是Func1,调用call(t),就会调用外部用户自己定义的call参数。返回了参数R,这里O是一个订阅者,参数为 (? super R) ,那么在onNext( T t)这个函数中,调用了O的onNext( R r);也就是被观察者通知观察者更新。
![](http://img.blog.csdn.net/20170414153853750?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
Operator接口继承于Func1,将Subscriber(R)转换为Subscriber(T),并返回。那么在回到lift(Operator)这个函数,返回了一个Observable。
![](http://img.blog.csdn.net/20170414154628639?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
在第一步的时候,hook.onLift返回一个operator,调用call。这里就是回调OperatorMap中的call的逻辑。获得了一个新的Subscriber,其中的onNext就是订阅者的具体逻辑。第二步中的onSubscribe,就是Observabe的create中传入的onSubscribe。就会调用外部实现的call逻辑。也就是这个call。
那么该函数的参数subscriber是经过中间Operator变换的到的新的Subscriber,那么onNext中有具体参数变换,Func1和真正订阅者引用。这里的Subscriber就是OperatorMap中call返回的。
![](http://img.blog.csdn.net/20170414155502496?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
这里的transformer就是外部实现的call方法,而这里的O就是真正的订阅者。
transfomer就是以下代码。
O就是以下代码。
那么回到Obervable的链式调度,最后调用的是subscribe方法订阅。使订阅者和观察者获得联系。
![](http://img.blog.csdn.net/20170414160025871?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
箭头所指的地方就是所有调用的起点, 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方法。链式调度启动了。
看看时序图,不过建议自己去整理一下,不然还是很难理清楚逻辑。
![](http://img.blog.csdn.net/20170414162138580?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvc3c1MTMxODk5/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
首先,我们需要一个Action1接口。Action1.java
然后在需要一个Subscriber接口。
那么在来一个OnSubscribe,接收Subscriber。这里使用了通配符,作为参数使用?和super限定。
那么最重要的Observable类
那么简单的rxjava就已经完成了。在MainActivity使用。
运行结果:
是不是很简单,把它核心逻辑抽出来,没有添加枝叶,看这逻辑就简单明了了很多。那么再把map函数加进去。需要一个转换函数func1
再来一个Operator,继承Func1。
在来一个OperatorMap,实现Operator接口,onNext方法中写具体逻辑。
在源码中,lift返回的时候,直接返回了一个内部类。这里我把内部类提出来。建一个OnSubscribeLift中间类。
那么在Observable中添加一些新的方法。
那么在MainActivity中使用。
运行结果:
怎么样?自己写一遍是不是感觉不错?这个手写的Rxjava有点简单。只是利用了一点原生rxjava的原理。不过对于rx系列的理解。是一个不错的提升。rxjava其他方法就不写了。抛砖引玉嘛,喜欢看源码的猿友就自己去取经了。
敲字也有点累呀~觉得有用呢,大家觉得有用点个赞,谢谢。
Rxjava git的地址:https://github.com/ReactiveX/RxJava
抛物线的给Android开发者的
rxjava:http://gank.io/post/560e15be2dca930e00da1083
Rxjava浅析
那么来浏览一遍rxjava源码的调用过程。Observable.create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { subscriber.onNext("Observable.create call"); } }).map(new Func1<String, Bitmap>() { @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<Bitmap>() { @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<String>() { @Override public void call(Subscriber<? super String> subscriber) { subscriber.onNext("Observable.create call"); } }
那么该函数的参数subscriber是经过中间Operator变换的到的新的Subscriber,那么onNext中有具体参数变换,Func1和真正订阅者引用。这里的Subscriber就是OperatorMap中call返回的。
这里的transformer就是外部实现的call方法,而这里的O就是真正的订阅者。
transfomer就是以下代码。
new Func1<String, Bitmap>() { @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<Bitmap>() { @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<T> { void call(T t); }
然后在需要一个Subscriber接口。
/** * Created by ShuWen on 2017/4/14. */ public interface Subscriber<T> { void onNext(T t); }
那么在来一个OnSubscribe,接收Subscriber。这里使用了通配符,作为参数使用?和super限定。
/** * Created by ShuWen on 2017/4/14. */ public interface OnSubscribe<T> extends Action1<Subscriber<? super T>> { }
那么最重要的Observable类
/** * Created by ShuWen on 2017/4/14. */ public class Observable<T> { private OnSubscribe<T> onSubscribe; private Observable (OnSubscribe<T> onSubscribe){ this.onSubscribe = onSubscribe; } public static <T> Observable<T> create(OnSubscribe<T> onSubscribe){ return new Observable<>(onSubscribe); } public void subcribe(Subscriber<? super T> 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<String>() { @Override public void call(Subscriber<? super String> subscriber) { Log.i("tag00","图片地址"); subscriber.onNext("图片地址"); } }).subcribe(new Subscriber<String>() { @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<T,R> { R call(T t); }
再来一个Operator,继承Func1。
/** * Created by ShuWen on 2017/4/14. */ public interface Operator<T,R> extends Func1<Subscriber<? super T>,Subscriber<? extends R>> { }
在来一个OperatorMap,实现Operator接口,onNext方法中写具体逻辑。
/** * Created by ShuWen on 2017/4/14. */ public class OperatorMap<T,R> implements Operator<R,T> { private Func1<? super T,? extends R> transform; public OperatorMap(Func1<? super T, ? extends R> transform) { this.transform = transform; } @Override public Subscriber<? extends T> call(final Subscriber<? super R> subscriber) { return new Subscriber<T>() { @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<T,R> implements OnSubscribe<R> { private Operator<? extends R,? super T> operator; private OnSubscribe<T> onSubscribe; public OnSubscribeLift(Operator<? extends R,? super T> operator, OnSubscribe<T> onSubscribe) { this.operator = operator; this.onSubscribe = onSubscribe; } @Override public void call(Subscriber<? super R> subscriber) { Subscriber<? super T> st = operator.call(subscriber); onSubscribe.call(st); } }
那么在Observable中添加一些新的方法。
/** * Created by ShuWen on 2017/4/14. */ public class Observable<T> { private OnSubscribe<T> onSubscribe; private Observable (OnSubscribe<T> onSubscribe){ this.onSubscribe = onSubscribe; } public static <T> Observable<T> create(OnSubscribe<T> onSubscribe){ return new Observable<>(onSubscribe); } public void subcribe(Subscriber<? super T> subscriber){ onSubscribe.call(subscriber); } public <R> Observable<R> map(Func1<? super T,? extends R> func1){ return lift(new OperatorMap<>(func1)); } private <R> Observable<R> lift(OperatorMap<T, R> 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<String>() { @Override public void call(Subscriber<? super String> subscriber) { Log.i("tag00","图片地址"); subscriber.onNext("图片地址"); } }).subcribe(new Subscriber<String>() { @Override public void onNext(String s) { Log.i("tag00","onNext:"+s); } }); Observable.create(new OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { Log.i("tag00","图片下载地址"); subscriber.onNext("http://write.blog.csdn.net/mdeditor"); } }).map(new Func1<String, Bitmap>() { @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<Bitmap>() { @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其他方法就不写了。抛砖引玉嘛,喜欢看源码的猿友就自己去取经了。
敲字也有点累呀~觉得有用呢,大家觉得有用点个赞,谢谢。
相关文章推荐
- Android从零开搞系列:网络框架系列(4)Retrofit+RxJava+MVP(中-上)RxJava篇(上)
- Android进阶系列-手写高并发图片加载框架
- Android从零开搞系列:网络框架系列(5)Retrofit+RxJava+MVP(中-下)RxJava篇(下)
- Android进阶系列-手写数据库框架
- 浅析MVP中model层设计【从零开始搭建android框架系列(7)】
- Android进阶系列-手写高并发网络访问框架
- Android从零开搞系列:网络框架系列(6)Retrofit+RxJava+MVP(下)MVP
- Android进阶系列8-编译时注解框架ButterKnife浅析
- Android从零开搞系列:网络框架系列(3)Retrofit+RxJava+MVP(上)Retrofit
- Android数据库ORMlite框架翻译系列(第一章)
- Android框架浅析之锁屏(Keyguard)机制原理
- Androidpn的框架浅析
- Android框架浅析之锁屏(Keyguard)机制原理
- Android框架浅析之锁屏(Keyguard)机制原理 .
- Android框架浅析之锁屏(Keyguard)机制原理
- Android框架浅析之锁屏(Keyguard)机制原理
- Android框架浅析之锁屏(Keyguard)机制原理
- Android框架浅析之锁屏(Keyguard)机制原理(转)
- Android框架浅析之锁屏(Keyguard)机制原理 .
- Android数据库ORMlite框架翻译系列(第二章:part 2)