RxJava入门篇 --（一） 响应式编程

时间：2022-01-31 17:46:02

刚开始学习，不是很明白很多话的道理，学习一门新技术，要经历what，how，why三个步骤。

  • what 这个 RxJava 能做什么？提供什么样的 API

  • how 采用什么样的方式实现，主要有哪些模块。

    • 每个模块有什么方法，怎么实现的
    • 结构，或者说架构怎么搭建的
  • 为什么 Rx 会火，它这样封装后意图？（简洁？逻辑简单？）

带着这些疑问开始 RxJava 学习之路吧，以后写项目时若有新的理解我会继续更新，希望有小伙伴一起进步，1092417123@qq.com ^-^

1. 什么是Rx

  • ReactiveX 是 Reactive Extensions 的缩写。
  • Rx 是一个编程模型，目标是提供一致的编程接口，帮助开发者更方便的处理异步任务流。

目前Rx支持大部分流行的编程语言，eg：Java、C#、PHP…

  • Rx 是一个函数库，让开发者可以利用可观察序列和 LINQ 风格查询操作符来编写异步和基于事件的程序。

  • 可以这样定义：Rx = Observables +LINQ + Schedulers

  • REactiveX不仅仅是编程接口，更是一种编程思想的突破。Rx 还影响了其它程序、框架以及编程语言。

2.Rx 模式 — 观察者模式

  • 创建：Rx 可以方便的创建事件流和数据流
  • 组合：Rx 可以使用查询式的操作符 组合和变换数据流
  • 监听：Rx 可以订阅任何可以观察的数据流并执行操作

3.Rx有点 — 简洁

  • 函数式风格：Rx 可以方便的创建事件流和数据流
  • 简化代码：Rx 的操作符可以将复杂的逻辑简化为很少的几行代码
  • 异步错误处理机制：传统的try/catch 没办法处理异步计算，Rx 提供了合适的错误处理机制；
  • 轻松使用并发：Rx 的 Observable 和 Schedulers 让开发者可以避免底层线程同步和各种并发问题。

4.什么是RxJava？

RxJava 是 ReactiveX 在 JVM 上的一个实现，也就是说 RxJava 就是一种用 Java 语言实现的响应式编程，来创建基于事件的异步程序。

提升开发效率，降低维护成本一直是开发团队永恒不变的宗旨，近一年来国内越来越多的技术团队提到和使用RxJava。RxJava 能帮我们简化代码逻辑，提升代码可读性，这对于提升开发效率，降低维护成本很有帮助。

5.学习RxJava

响应式编程的主要组成部分是 observable，operator 和 subscriber，一般响应式编程的信息流如下所示：

Observable -> Operator1 -> Operator2 -> Operator3 -> Subscriber

也就是说， observable 是事件的产生者， subscriber是事件的最终消费者

因为 subscrible 通常在主线程执行，因此要求设计上代码尽可能简单，只对事情做出响应（不对事件或者数据进行修改），而修改事件的工作全部交由 operator 执行

6. RxJava 的 HelloWord

PS：jar包下载地址

package com.lizi.rxjava;

import rx.Observable;
import rx.Observable.OnSubscribe;
import rx.Observer;
import rx.Subscriber;
import rx.functions.Func1;

public class RxJavaPattern {

public static void main(String[] args) {
        testObservable();
    }

@SuppressWarnings("deprecation")
private static void testObservable() {
// 1.创建被观察者 Observable
        Observable<String> observable = Observable.create(new OnSubscribe<String>() {

@Override
public void call(Subscriber<? super String> subscriber) {

                subscriber.onNext("Hello World！"); // 发送数据
                subscriber.onCompleted();// 最终调用该方法，表示结束
            }

        });

// 2.创建观察者Observer
        Observer<String> observer = new Observer<String>() {

@Override
public void onCompleted() {
                System.out.println("onCompleted");
            }

@Override
public void onError(Throwable arg0) {
                System.out.println("onError");
            }

@Override
public void onNext(String arg0) {
                System.out.println("onNext = " + arg0);
            }
        };

// 3.被观察者订阅观察者
        observable
// 建议在这修改数据
                .map(new Func1<String, String>() {
// 第一个参数决定 call方法类型，第二个参数决定返回值类型
@Override
public String call(String arg0) {
return arg0 + "汤圆";
                    }
                }).subscribe(observer);
    }

}
标签：

相关文章