简单介绍
Rxjava这个名字,其中java代表java语言,而Rx是什么意思呢?Rx是Reactive Extensions的简写,翻译过来就是,响应式拓展。所以Rxjava的名字的含义就是,对java语言的拓展,让其可以实现对数据的响应式编程。
原理
Rx是Reactive Extensions的缩写的简写,可以使用可观察数据流对编程接口进行异步编程,它结合了观察者模式,迭代器模式和函数式的精华。
Rxjava是一种异步数据处理库,也是一种观察者模式。最早是Netflix公司用于重构当前架构时减少REST调用的次数,参考了Microsoft公司的响应式编程,把Microsoft的Rx库迁移到Java JVM中,其中最有名的就是RxJava。
它的特点主要有以下:
- 支持Java 8 Lambda。
- 支持异步和同步。
- 单一依赖关系。
- 简洁,优雅。
RxAndroid
在开发项目的时候,开发者在使用Rxjava时会搭配RxAndroid,他是针对Rxjava在Android平台使用的一个响应式扩展组件。使用RxAndroid的Schedulers(调度器)可以解决Android主线程问题, 多线程等问题。
操作符
其实RxJava中最重要的操作符,它可以在订阅的过程中进行各种转化,下面以Map操作符为例子来进行说明,Map操作符本身就是一个映射的关系
mText.append("\n 输入参数: 1,2,3,4,5,6 \n");Observable.from(number) //之前提到的创建Observable方法.map(new Func1<Integer, Boolean>() {@Overridepublic Boolean call(Integer integer) {mText.append("\n\n map() Integer--->Boolean");return (integer<3);}}).subscribe(new Action1<Boolean>() {@Overridepublic void call(Boolean aBoolean) {mText.append("\n观察到输出结果:\n");mText.append(aBoolean.toString());}});
这里的Map进行了类型的转换,将int转变成嗯boolean类型的
操作符原理
- (1)首先创建一个代理的观察者
- (2)让外部的Obervable去订阅这个代理的观察者
- (3)外部的观察者发送onNext等事件,都会先传递到代理观察者这里
- (4)在代理观察者的onNext中调用自己创建的Fun1的call方法,进行数据的转化
- (5)当我们在调用obervable的call方法的时候会将真实的观察者传递进来
- (6)调用真实观察者的onNext方法将结果传递出去就可以了
线程调度操作符
这个是异步的关键,用来在主线程和子线程之间进行切换
Observable.create(new Observable.OnSubscribe<Drawable>(){@Overridepublic void call(Subscriber<? super Drawable> subscriber) {sb.append(" Observable.create(): 线程: "+Thread.currentThread().getName()+"\n\n");Drawable dd=getResources().getDrawable(R.mipmap.gril);subscriber.onNext(dd);subscriber.onCompleted();}}).subscribeOn(Schedulers.io()).observeOn(Schedulers.newThread()).map(new Func1<Drawable, ImageView>() {@Overridepublic ImageView call(Drawable drawable) {sb.append("map(): drawable -->imageview 的线程: "+Thread.currentThread().getName()+"\n\n");ImageView img=new ImageView(RxSchuderActivity.this);LinearLayout.LayoutParams params= new LinearLayout.LayoutParams(LinearLayout.LayoutParams.WRAP_CONTENT, LinearLayout.LayoutParams.WRAP_CONTENT);img.setLayoutParams(params);img.setImageDrawable(drawable);return img;}}).observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<ImageView>() {@Overridepublic void call(ImageView imageView) {sb.append("call(): 线程: "+Thread.currentThread().getName()+"\n");mText.setText(sb);mLinearlayout.addView(imageView);}});
实际上线程调度只有subscribeOn()和observeOn()两个方法。对于初学者,只需要掌握两点:
subscribeOn()它指示Observable在一个指定的调度器上创建(只作用于被观察者创建阶段)。只能指定一次,如果指定多次则以第一次为准
observeOn()指定在事件传递(加工变换)和最终被处理(观察者)的发生在哪一个调度器。可指定多次,每次指定完都在下一步生效。
线程调度掌握到这个程度,在入门阶段时绝对够用的了。
Rxjava基本使用
上面这段代码是对Rxjava简单的使用,其中
- Single 发出单个数据的被观察者Observable,只发送一次,只有Success和Error两种状态,没有next,在Rxjava2中新增
- just 被观察者生产的数据,参数类型是一个泛型,这里传进去的是一个String
- subscribe 观察者Observer,这里声明的是SingleObserver,用来对Single中产生的数据进行响应
- SingleObserver
- onSubscribe 订阅成功后就会回调,一般会在此方法中进行一些初始化操作。其参数类型是Disposable,可以通过调用d.dispose() 取消对Observable的监听,并让其停止发送消息。
- onSuccess 接收数据成功后就会回调,只会回调一次,其参数类型和Observable中just方法传入的数据类型一致,这里是String类型
- onError 发生错误时回调,参数是Throwable,包含错误信息。
运行效果
2022-12-18 13:54:12.450 29223-29223/com.hfhuaizhi.rxjavatest E/hftest: onSubscribe
2022-12-18 13:54:12.451 29223-29223/com.hfhuaizhi.rxjavatest E/hftest: onSuccess:hfhuaizhi
可以看到首先onSubscribe被调用,表明注册了观察者。然后接收数据成功,打印出’hfhuaizhi’。 到这里我们就了解了Rxjava最基本的用法,接下来分析一下函数的内部做了什么。有关Android的架构技术进阶可以参考《Android核心技术笔记》点击就可以查看到详细的板块了。