摘要:关于是推出在环境下使用的异步操作库。被观察者使用需要创建,用于发射数据。发射,可以表示发射事件结束。控制的线程,也可以说是控制事件被执行时所在的线程。输出结果操作符表示跳过前几个事件从某一个事件开始发射事件,下标从开始。
关于RxJava
RxJava是ReactiveX推出在Java VM环境下使用的异步操作库。除了在Java环境ReactiveX也为其他编程语言推出Rx库,例如Py、Js、Go等。网上有很多关于对RxJava的介绍和使用,在Android开发中也有很多项目使用RxJava。那为什么还要使用RxJava呢,Android开发也有提供异步操作的方法供开发者使用,我想应该是RxJava比起Handle、AsyncTask简洁优雅。
1 RxJava采用链式调用,在程序逻辑上清晰简洁
2 采用扩展式观察者设计模式
关于观察者模式以及其他RxJava的介绍这个就不做重复,下面内容主要围绕RxJava和RxAndroid使用。对于RxJava官方文档已经有详细介绍,本节是以学习讨论为主,如存在错误的地方希望大家可以指出。
被观察者Observable使用RxJava需要创建Observable,Observable用于发射数据。
如下Observable的create方法需要传入一个OnSubscribe,其继承于Action1
public staticObservable create(OnSubscribe f) { return new Observable (RxJavaHooks.onCreate(f)); }
另外create方法中需要实现接口call,返回subscriber对象。call方法实现在observable订阅后要执行的事件流。
subscriber.onNext发射data,subscriber.onCompleted可以表示发射事件结束。接着调用observable的subscribe方法实现被订阅后执行的事件流。
Observableobservable = Observable .create(new Observable.OnSubscribe () { @Override public void call(Subscriber super String> subscriber) { subscriber.onNext("1"); subscriber.onNext("2"); subscriber.onNext("3"); subscriber.onNext("4"); subscriber.onNext("5"); } }); Subscriber subscriber = new Subscriber () { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(String s) { System.out.print(s + " "); } }; observable.subscribe(subscriber); //输出结果 print: //1 //2 //3 //4 //5
Observable除了使用create方法创建外还可以使用from或者just快速设置发射的事件流,简化了create的步骤。
Observableo = Observable.from("a", "b", "c");
Observable说好的异步操作o = Observable.just("one object");
RxJava的线程由Schedulers调度者控制,通过它来控制具体操作在什么线程中进行。
Schedulers.immediate() 在当前线程中执行
Schedulers.newThread() 为每一个任务开辟线程执行
Schedulers.computation() 计算任务运行的线程
Schedulers.io() IO任务运行的线程
....
AndroidSchedulers.mainThread() Android 主线程运行
对于线程的控制主要由subscribeOn()和observeOn()两个方法控制:
subscribeOn 控制Observable.OnSubscribe所处的线程,等同于Observable create、just、from时所处的线程。
observeOn 控制Subscriber的线程,也可以说是控制事件被执行时所在的线程。
Observable .just(1,2,3) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(Integer integer) { System.out.print(integer + " "); } }); //输出结果 print: //1 //2 //3
写下上面的RxJava链式调用的代码,有没有觉得比以前使用的异步调用清爽许多,对处女座还说这很治愈!
操作符OperatorsReactiveX提供超级多的操作符,每个操作符都具有不同的功能,但目的都是在Observable和Subscribe之间变换和修改发射出去的事件流。这节介绍几个比较常见简单的操作符,之后有机会再写一节操作符篇详细说说每个操作符的作用。附上官方操作符文档看看就知道有多少多了。
Map()
public finalObservable map(Func1 super T, ? extends R> func) { return create(new OnSubscribeMap (this, func)); }
首先先介绍一个操作符map,map实现Func1接口将T类型数据变换为R类型数据,返回R类型数据。例如传入Integer类型的事件队列,经过map加工之后以String类型返回。
Observable .just(1,2,3) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .map(new Func1() { @Override public String call(Integer integer) { return integer + ""; } }) .subscribe(new Subscriber () { ...... @Override public void onNext(String str) { System.out.print(str + " "); } }); //输出结果 print: //1 //2 //3
Filter()
public final Observablefilter(Func1 super T, Boolean> predicate) { return create(new OnSubscribeFilter (this, predicate)); }
filter和map一样实现Func1接口不过它变换之后的类型为boolean,对发射的事件流进行筛选,当变换后的boolean值为true,订阅者才能收到通过筛选的事件,反之该事件不被消费。例如事件流筛选要求当int值可被2整除才能继续传递,所以最后订阅者可消费的事件为2,4,6,8,10。
Observable .just(1,2,3,4,5,6,7,8,9,10) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .filter(new Func1() { @Override public Boolean call(Integer integer) { return integer % 2 == 0; } }) .map(new Func1 () { @Override public String call(Integer integer) { return integer + ""; } }) .subscribe(new Subscriber () { ...... @Override public void onNext(String str) { System.out.print(str + " "); Log.i("subscribe", str); } }); //输出结果 print: //2 //3 //4 //6 //8 //10
Skip()
public final Observableskip(int count) { return lift(new OperatorSkip (count)); }
skip操作符表示跳过前几个事件从某一个事件开始发射事件,下标从0开始。
Observable .just(1,2,3,4,5,6,7,8,9,10) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .skip(3) .map(new Func1() { @Override public String call(Integer integer) { return integer + ""; } }) .subscribe(new Subscriber () { ...... @Override public void onNext(String s) { System.out.print(s + " "); Log.i("subscribe", s); } }); //输出结果 print: //4 //5 //6 //7 //8 //9 //10
Range()
public static Observablerange(int start, int count) { if (count < 0) { throw new IllegalArgumentException("Count can not be negative"); } if (count == 0) { return Observable.empty(); } if (start > Integer.MAX_VALUE - count + 1) { throw new IllegalArgumentException("start + count can not exceed Integer.MAX_VALUE"); } if(count == 1) { return Observable.just(start); } return Observable.create(new OnSubscribeRange(start, start + (count - 1))); }
range操作符可以理解为just,from传递一个连续的int类型待发射数组,n为起始int值,m为Count。例如n = 1,m = 5 int数组就是{1,2,3,4,5}
结尾这节先学习到这,算是对RxJava的初步认识和学习。其实运用RxJava主要还是依赖于对操作符的使用,前面所介绍的操作符属于最最简单基础的,还有很多特别有用的操作符没有介绍。之后再继续介绍一些操作符。RxJava在Android开发中很受欢迎,就是因为它的强大,同时RxJava可以和Retrofit组合使用,更高效处理网络请求回值。另外GitHub GoogleSample上的android-architecture也有使用RxJava框架的TODO项目,可以看看理解RxJava在项目中的实践应用。
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/13341.html
摘要:让你收获满满码个蛋从年月日推送第篇文章一年过去了已累积推文近篇文章,本文为年度精选,共计篇,按照类别整理便于读者主题阅读。本篇文章是今年的最后一篇技术文章,为了让大家在家也能好好学习,特此花了几个小时整理了这些文章。 showImg(https://segmentfault.com/img/remote/1460000013241596); 让你收获满满! 码个蛋从2017年02月20...
摘要:音乐团队分享数据绑定运行机制分析一个项目搞定所有主流架构单元测试一个项目搞定所有主流架构系列的第二个项目。代码开源,展示了的用法,以及如何使用进行测试,还有用框架对的进行单元测试。 Android 常用三方框架的学习 Android 常用三方框架的学习 likfe/eventbus3-intellij-plugin AS 最新可用 eventbus3 插件,欢迎品尝 简单的 MVP 模...
摘要:音乐团队分享数据绑定运行机制分析一个项目搞定所有主流架构单元测试一个项目搞定所有主流架构系列的第二个项目。代码开源,展示了的用法,以及如何使用进行测试,还有用框架对的进行单元测试。 Android 常用三方框架的学习 Android 常用三方框架的学习 likfe/eventbus3-intellij-plugin AS 最新可用 eventbus3 插件,欢迎品尝 简单的 MVP 模...
摘要:系统的架构实现拖拽排序和侧滑删除掘金在平时开发应用的时候,经常会遇到列表排序滑动删除的需求。基于使用与一致掘金,当你的项目中用到了,同时又有跨界面的响应式需求,而又嫌麻烦不想再添加更多的库,则可以使用这个库,使用方法与相同。 Android 优秀文章和开源库推荐(读值得读的) - Android - 掘金文章: 1. Android AOP之字节码插桩详解 文章从AOP的概念出发,介绍...
摘要:瘦身项目实战掘金导语是腾讯海外布局的一个音乐产品,年发布以来已经成为个国家和地区排名第一的音乐。一导入未来的设计师需要知道的个技能设计掘金技术行业的发展步伐正在越来越快。 Android APK 瘦身 - JOOX Music 项目实战 - Android - 掘金导语 JOOX Music是腾讯海外布局的一个音乐产品,2014年发布以来已经成为5个国家和地区排名第一的音乐App。东南...
阅读 1704·2021-11-24 10:45
阅读 1277·2021-11-18 13:15
阅读 4194·2021-09-22 15:47
阅读 3558·2021-09-09 11:36
阅读 1879·2019-08-30 15:44
阅读 2980·2019-08-29 13:05
阅读 2394·2019-08-29 12:54
阅读 1828·2019-08-26 13:47