Android Rxjava：图解不同的诠释

1.前言

• Rxjava， 具备链式调用、使用简单&事件与结果松耦合的特色。

• Rxjava， 之因此深受欢迎它包含 很是多操做符，能经过 【链式形】 优雅整洁的代码几乎能实现全部的功能需求。

• 本文特色：图多字少、逻辑简单。

• 以前面试中被问了不少Rxjava的知识，今天献一份不同诠释，但愿你们喜欢。

2.目录

3.简介

4.原理浅析

• Rxjava，扩展自观察者模式。

4.1 生活例子

• 经过手机叫外卖例子，分析一下rxjava的原理。

• 叫外卖流程

• 涉及的角色与对应流程

4.2 例子结合Rxjava

• Rxjava，包含观察者、被观察者、订阅行为&事件，与例子对应以下图：

• 对应Rxjava基本使用代码：

public void create(){
      Observable.create(new ObservableOnSubscribe<String>() {
          @Override
          public void subscribe(ObservableEmitter<String> e) throws Exception {
              e.onNext("烤鸡一份");
              e.onNext("薯条一份");
              e.onNext("可乐一杯");
// e.onError(new NullPointerException());
              e.onComplete();
          }
      }).subscribe(new Observer<String>() {
          @Override
          public void onSubscribe(Disposable d) {
              Log.e(TAG,"onSubscribe : 订阅成功");
          }

          @Override
          public void onNext(String s) {
              Log.e(TAG,"onNext : 接收事件 "+s);
              //按顺序获得：烤鸡一份、薯条一份、可乐一杯
          }

          @Override
          public void onError(Throwable e) {
              Log.e(TAG,"onError : 事件异常 "+e.toString());
          }

          @Override
          public void onComplete() {
              Log.e(TAG,"onComplete : 事件执行完毕 ");
          }
      });
  }
复制代码

总结：
被观察者（Observable）：经过订阅行为（subscribe()）把事件按顺序发送到 观察者（Observer）。 观察者（Observer）：按顺序接收到事件&作出响应反馈。

5.操做符

5.1建立操做符

• 做用 ：被观察者把事件发送至观察者。

• 应用 ：

5.2变换操做符

• 做用 ：被观察者把序列事件加工为其余序列事件(变换)。

• 原理 ：结合叫外卖的例子（更改菜式）。

• 应用 ：

5.3合拼操做符

• 做用 ：将多个被观察组合 & 将它们须要发送的事件合拼。

• 应用 ：

5.4过滤操做符

• 做用 ：过滤/筛选 被观察者发送的事件。

• 应用 ：

5.5条件操做符

• 做用 ：经过指定条件，判断是否接收被观察者发送的事件。

• 应用 ：

5.6其余功能操做符

• 做用 ：被观察者发送事件时，进行功能性拓展。

• 应用 ：

6.框架设计思想

7.总结

• Rxjava 如此好用、简单、优雅的链式任务框架库，你还等什么？

• 到此，基本完成了rxjava相关介绍与使用，但愿你们喜欢个人文章。

• 但愿该文章能帮助准备面试、准备使用Rxjava的兄die们。

写技术文章初心

• 技术知识积累

• 技术知识巩固

• 技术知识分享

• 技术知识交流

• 
  
  
  

+qq群457848807：。获取以上高清技术思惟图，以及相关技术的免费视频学习资料