Rxjava源码解析笔记 | Rxjava基本用法

Rxjava四要素

  1. 被观察者 在Rxjava当中, 决定什么时候触发事件, 决定触发什么样的事件;
  2. 观察者
    • 决定事件触发的时候将产生什么样的行为;
    • 类似于传统观察者模式观察者会随着被观察者的状态变化而发生相应的操作;
  3. 订阅
    • 区别于传统观察者模式
    • 观察者被观察者需要通过订阅来联系;
    • 通过subscribe()方法完成这个订阅关系;
    • 完成订阅关系后, 即可令被观察者(Observable)在需要的时候, 发出事件来通知观察者(Observer)
  4. 事件
    • 区别于传统观察者模式; (下面详说)

事件

  • 响应式编程中的核心概念
  • 响应式编程乃基于异步数据流概念的编程模式;

理解响应式编程

  • 场景举例:客户端服务端获取到最新的数据时, 需要通知客户端本身相关模块进行更新(如UI变换显示等); 这其实便是一种响应式编程—— 客户端根据服务端的变化做出相应;

生活中的例子

  • 天气冷了我们就要多穿件衣服。 天气冷了,就是一种事件要多穿件衣服,就是基于事件做出响应
  • 饿了要吃饭。 饿了,就是一种事件吃饭,就是基于事件做出响应

代码分析

  • 第一步, (通过create())创建被观察者(Observable),即第一个基本要素, 其中注意OnSubscribe<String>()对象, 记住它是存储在Observable当中的; Observable订阅之后, 它会启动OnSubscribe<String>()对象中的回调方法call() 同时运行call()方法体中写好的反应序列
    //第一步:创建被观察者:create
    Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
        @Override
        public void call(Subscriber<? super String> subscriber) {
            subscriber.onNext("Hello");
            subscriber.onNext("Imooc");
            subscriber.onCompleted();
        }
    });
  • .
    • 其中,其实Subscriber就是我们的观察者; 后面的Rxjava源码阅读中, 我们会发现Observer在源码中也会被转换成Subscriber来进行相应的处理, 所有才说其实Subscriber就是我们的观察者
    • 以上我们可以看到,在create一个被观察者时, 我们new了一个OnSubscribe<String>(), 并在其中实现了回调方法call()回调方法中调用了观察者的方法—— 在创建被观察者时,使用了调用了观察者方法回调方法, 这其实就是一种事件的传递; 最后将这个OnSubscribe<String>()赋给被观察者的创建方法create()如此便跟传统观察者模式联系起来了; (只不过这里Rxjava给我们做好了更好的封装)
  • 以上是创建被观察者的一种方法, 事实上还有其他两种
    • 第二种,通过just()方法创建, 只要把参数放到just()方法中,以逗号分隔开来即可, 而just()其实就是将参数 依次通过事件 发送出来, 这种写法其实是跟上面的两个onNext()、一个onCompleted()的写法是一样的;
    • 第三种,通过from()方法, 类似于第二种方法,只是把传给just参数组合成一个String数组在传给from()这种写法其实是跟上面的两个onNext()、一个onCompleted()的写法是一样的;
  • 以上三种方法其实都是等价的,其最终目的都是创建被观察者
    //通过just方法来创建被观察者
    Observable observableJust = Observable.just("hello", "Imooc");

    //通过from方法来创建被观察者
    String[] parameters = {"hello", "Imooc"};
    Observable observableFrom = Observable.from(parameters);
  • 第二步, 创建观察者Observer/Subscriber,即第二个要素, 1.在传统的观察者模式当中,观察者只有一个update()方法, 在其中根据被观察者状态变化而做出反应/改变
    1. 而在Rxjava中,框架给出了三个方法; 其中onCompleted()onError()两个方法就是对传统观察者模式做出的改变/区别, onNext()其实就是传统观察者模式当中的update()
    • onCompleted():当不再有新的事件通过被观察者 发出的时候回调
    • onError(): 在处理异常框架时回调
    • onNext():同理传统观察者模式当中的update(), 即编写 当被观察者发生状态改变时,观察者的处理逻辑;
   //第二步:创建观察者
    Observer<Object> observer = new Observer<Object>() {

        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onNext(Object s) {

        }
    };

  • 被观察者Observable是用过链式调用来执行的; 为的是让后面的操作符线程控制等能够跟流式OPI来完善, 而不是其他方式观察者去订阅被观察者(非链式)—— 这样从意思上容易理解,但在API调用上很不方便;
  • 链式调用:理解比较绕,但能跟流式OPI来完善,API调用上非常方便
  • 非链式调用:意思上容易理解,但在API调用上很不方便;
  • 第三步,订阅: 前面我们说概念的时候,都是观察者订阅被观察者的, 可是这里代码中, “奇怪”的是“被观察者(Observable)订阅(subscribe)观察者(Observer)”, 这里就是上面说的, 为了后面能够通过流式OPI, 使进行操作符线程控制等操作时能够通过链式调用来完善; 所以这里Rxjava中把订阅设计成“被观察者(Observable)去订阅(subscribe)观察者(Observer)”
    public void doRxjava(){
        //第三步:订阅
        observable.subscribe(observer);
    }
  • 本节完整代码如下:

这里其实只是Rxjava的一种简单的使用, 主要是理解一下Rxjava传统观察者设计模式拓展改进 实际情况当中,其实它还包括了很多操作符 以及Rxjava最核心的线程控制调度 这两部分是Rxjava的核心.

package com.example.jiajiemu.a11.rxjava;

import rx.Observable;
import rx.Observer;
import rx.Subscriber;

/**
 * Created by Mjj on 2017/10/6.
 */

public class RxjavaCreateDemo {

    //第一步:创建被观察者:create
    Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
        @Override
        public void call(Subscriber<? super String> subscriber) {
            subscriber.onNext("Hello");
            subscriber.onNext("Imooc");
            subscriber.onCompleted();
        }
    });

    //通过just方法来创建被观察者
    Observable observableJust = Observable.just("hello", "Imooc");

    //通过from方法来创建被观察者
    String[] parameters = {"hello", "Imooc"};
    Observable observableFrom = Observable.from(parameters);

    //第二步:创建观察者
    Observer<Object> observer = new Observer<Object>() {

        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onNext(Object s) {

        }
    };

    public void doRxjava(){
        //第三步:订阅
        observable.subscribe(observer);
    }

}

参考自 慕课网

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

扫码关注云+社区

领取腾讯云代金券