专栏首页青蛙要fly的专栏Android技能树 - Rxjava源码(1) 之 初步结构

Android技能树 - Rxjava源码(1) 之 初步结构

正文

我们还是通过基础的例子来进行讲解,比如你有个快递,你很想知道快递是否已经到小区,你可能想要在快递刚到你的小区的时候就马上知道,然后马上就能享受拆快递所带来的乐趣,毕竟等待快递的时候实在太煎熬了。

那我们有什么方式来确定快递是否到了小区呢?

1. 轮询 和 更新发送

1.1 轮询

我们可以每隔1分钟,就打个电话给快递小哥,问他我的快递是不是已经送到了,这样当快递小哥刚送货到你的小区的时候,你都最多能在不超过一分钟内知道快递已经到小区了。(缺点也很明显,电话费很贵,同时你不怕小哥打死你的话,你也可以用这种方式)

1.2 更新发送

当快递小哥把快递送到你的小区的时候,一般都是二种方式:1. 他可能直接打你的电话通知你下来拿快递;2. 统一放在快递货柜中,然后你会收到货柜的短信通知,根据开柜号码去拿快递。

明显这种数据更新后主动通知的方式,我们更容易接受,大家都开心,小哥也不会打死你。但是上面我们也说了快递小哥通知你的方式有二种:直接通知你/货柜接收快递,货柜再通知你

快递员到了小区后,通知你的二种方式又分别对应了什么模式?

2.观察者模式和发布订阅模式

我们上面已经提到了快递小哥到了你小区,有二种方式通知你,其实这里对应了 观察者模式和发布订阅模式这二种模式。其实我以前也总是把这二个模式弄混,感觉都差不多,所以在和别人讨论的时候都是混着说着这个名词,后来看了网上相关的文章,发现这二者还是有点不同的,正对应了上面你收到快递的信息一样的区别。

2.1 观察者模式

对应的就是我们的快递员把快递送到了小区后,直接打电话给你,说你快下来拿下快递;这时候快递员是直接跟你本人直接沟通的

2.2 发布订阅模式

对应的就是我们的快递员把快递送到小区后,把快递放在快递柜中,然后快递员只要把你的手机号码输入到快递柜,然后把快递放入到具体的某个快递柜的格子中,就可以直接走人了,等会会由快递柜这边通知你快递到了,然后过来取快递。

二者最大的区别是什么?

我直接引用网上的其他文章的内容:两种模式都存在订阅者和发布者(具体观察者可认为是订阅者、具体目标可认为是发布者),但是观察者模式是由具体目标调度的,而发布/订阅模式是统一由调度中心调的,所以观察者模式的订阅者与发布者之间是存在依赖的,而发布/订阅模式则不会。

那RxJava是属于上面的二种的哪一种呢?

我们直接看GitHub上的RxJava介绍:

看不懂的我们直接谷歌翻译走起:

我们可以看到介绍,说是扩展了观察者模式,所以说明我们的Rxjava是直接把观察者注册到了发布者。而没有中间的调度中心。所以也就是我们上面的快递员直接打电话通知你下来拿快递的方式。

3.Rxjava的具体分析

我们使用RxJava最基础的方式是什么?

我们刚开始学如何使用的时候,估计百分之99的都是先学会使用create操作符:

Observable.create(new ObservableOnSubscribe<Object>() {
        @Override
        public void subscribe(ObservableEmitter<Object> emitter) throws Exception {

        }
    }).subscribe(new Observer<Object>() {
        @Override
        public void onSubscribe(Disposable d) {
            
        }

        @Override
        public void onNext(Object o) {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onComplete() {

        }
    });
复制代码

其实这个最基础的了解了后,看其他的什么just,fromArray等就都理解了;当然我们既然是RxJava系列的第一篇初步结构,所以我也不会马上就讲解各种源码,我们可以先模仿一个简单的,比如:

Observable.just(1)
    .subscribe(new Observer<Integer>() {
        @Override
        public void onSubscribe(Disposable d) {
            
        }

        @Override
        public void onNext(Integer integer) {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onComplete() {

        }
    });
复制代码

我们可以这样先模仿这个简单的,写个效果一样的伪代码,了解一下基本的东西即可。

所以如果我们写了一个简单的版本的RxJava应该是这样的:

Observer.java:

public class Observer<T> {

    @Override
    public void onSubscribe(Disposable d) {
    }

    public void onNext(T obj) {
    }

    public void onError(Throwable e) {
    }

    public void onComplete() {
    }
}

复制代码

Observable.java:

public class Observable<T> {

    T value;
    Observer<? super T> observer;
    
    //just传进来的数值,等会要发送给Observer
    public void just(T value) {
        this.value = value;
    }

    public final void subscribe(Observer<? super T> observer) {
        //把Observer注册到Observable中,其实就等于Observable拿了Observer的对象,等会好调用它相应的方法
        this.observer = observer;
        
        //生成Disposable对象,调用observer的onSubscribe方法
        Disposable a = xxxxxxx;
        observer.onSubscribe(a);
        
        //我们已经拿到了Observer对象,可以做相关逻辑了
        start();
    }

    private void start() {
        try {
            //我们把just传进的数值,通过已经拿到的Observer对象,调用onNext把数值给它
            observer.onNext(value);
            //发送完了之后执行onComplete()方法说明结束了。
            observer.onComplete();
        } catch (Exception e) {
            //如果中间出现异常,就调用Observer的onError方法
            observer.onError(e);
        }
    }
}
复制代码

是不是感觉,卧槽,原来这么简单吗?没错,这样看来我们也的确是Observable直接持有了Observer的对象,也的确符合上面我们说的Rxjava使用的是观察者模式,而不是发布订阅模式。

所以现在初步来看RxJava目前来看三步走:

结语

因为只是第一篇初步结构,所以内容也十分简单,后续会具体分析相关的源码内容。

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

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 虐面试官系列Lifecyele篇 - (3)源码分析之注册 & 发送

    虐面试官系列Lifecyele篇 - (2)源码分析之 Event & State

    青蛙要fly
  • 项目需求讨论-Retrofit中文提交及上传头像功能

    很早就开通了掘金上发表文章权限,但一直没有在掘金上写,都是在简书上面写好,然后偷懒在掘金上直接就网址分享链接。O(∩_∩)O~这次就上来写了。

    青蛙要fly
  • Android技能树 — 排序算法基础小结

    现在安卓面试,对于算法的问题也越来越多了,要求也越来越多,特别是排序,基本必考题,而且还动不动就要手写,所以陆续要写算法的文章,也正好当自己学习。o(╥﹏╥)o

    青蛙要fly
  • 【从业余项目中学习1】C# 实现XML存储用户名密码(MD5加密)

      最近在写一个C#的项目,用户需求是实现Winform的多文档界面与Matlab算法程序之间的交互。做了一段时间发现,这既能利用业余时间,实战中也可学习一些技...

    宋凯伦
  • 5年时间,目标跟踪算法的进化史

    第一部分:目标跟踪速览 先跟几个SOTA的tracker混个脸熟,大概了解一下目标跟踪这个方向都有些什么。一切要从2013年的那个数据库说起。。如果你问别人近几...

    BestSDK
  • 计算机视觉中,有哪些比较好的目标跟踪算法?(上)

    相信很多来这里的人和我第一次到这里一样,都是想找一种比较好的目标跟踪算法,或者想对目标跟踪这个领域有比较深入的了解,虽然这个问题是经典目标跟踪算法,但事实上,可...

    AI研习社
  • 关于mysql操作的详细介绍以及实例

    前言:在后台开发中绝对避免不了要关系型数据库管理系统。常见的数据库管理系统有MySql、SQLServer、Oracle等。

    叫我可儿呀
  • 开发 | 计算机视觉中,究竟有哪些好用的目标跟踪算法(上)

    AI科技评论按:本文源自YaqiLYU在知乎问题【计算机视觉中,目前有哪些经典的目标跟踪算法?】下的回答,AI科技评论已获得授权发布。 相信很多来到这里的人和我...

    AI科技评论
  • 腾讯WeTest兼容服务再次升级,支持小程序兼容

    ? WeTest 导读 小程序作为微信内能被便捷地获取和传播的工具,吸引着越来越多的开发者加入其中。无论是小游戏、零售、出行服务还是生活餐饮等,各行各业的小程...

    WeTest质量开放平台团队
  • 消息队列常见的几种使用场景介绍!

    消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题。实现高性能、高可用、可伸缩和最终一致性架构。使用较多的消息队列有Active...

    Spark学习技巧

扫码关注云+社区

领取腾讯云代金券