Rxjava实战笔记 | Rxjava的基本使用解析(同步结合示例)

本文涉及的产品
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
简介: Rxjava实战笔记 | Rxjava的基本使用解析(同步结合示例)
本系列为实战笔记(基于Rxjava2),基于之前的 源码解析笔记(基于Rxjava1)系列进行拓展,
效率起见,之前讲过的内容这里简单带过,
有兴趣的朋友可以点击前往阅读,感谢大家的支持 ~

官网

**RxJava: https://github.com/ReactiveX/RxJava

RxAndroid : https://github.com/ReactiveX/RxAndroid**

添加依赖

compile 'io.reactivex.rxjava2:rxjava:2.0.0-RC5'
compile 'io.reactivex.rxjava2:rxandroid:2.0.0-RC1'

基理

ObservableObserver通过subscribe()方法实现订阅关系
**Rxjava中是自动发送事件的,

一旦订阅就开始发送;**

基本使用三个步骤

  • 第一步,创建Observable

Emitter发射器的意思,
subscribe方法中不断调用发射器的方法;
总共有onNext()、onComplete()、onError()三个方法;
用法参考Rxjava1:

  • 第二步,创建Observer

总共有onNext()、onComplete()、onError()、onSubscribe()四个方法;

其中,onNext()、onComplete()、onError()三个方法分别对应着第一步中ObservableonNext()、onComplete()、onError()三个方法,
**只要Observable发出(调用)对应的方法,
Observer对应的方法就会被调用;**

  • onError()onComplete是互斥的,一次只能调用一个;
  • 第三步,订阅,

observable.subscribe(observer);


下面开始实战内容

  • 在app/build.gradle中添加依赖:
dependencies {
    implementation fileTree(dir: 'libs', include: ['*.jar'])

    implementation 'com.android.support:appcompat-v7:28.0.0'
    implementation 'io.reactivex.rxjava2:rxjava:2.0.0-RC5'
    implementation 'io.reactivex.rxjava2:rxandroid:2.0.0-RC1'
    implementation 'com.squareup.retrofit2:retrofit:2.1.0'
    implementation 'com.squareup.retrofit2:converter-gson:2.1.0'
//    compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'

//    compile 'com.jakewharton.rxbinding:rxbinding:0.4.0'
}

activity_main.xml:

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout
    xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:id="@+id/activity_main"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:paddingBottom="@dimen/activity_vertical_margin"
    android:paddingLeft="@dimen/activity_horizontal_margin"
    android:paddingRight="@dimen/activity_horizontal_margin"
    android:paddingTop="@dimen/activity_vertical_margin"
    android:orientation="vertical"
    tools:context="com.cniao5.cniao5rxjava2demo.MainActivity">


    <Button
                android:layout_height="wrap_content"
                android:layout_width="match_parent"
                android:text="test"
                android:onClick="click"/>

    <TextView
        android:id="@+id/text"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:layout_marginTop="10dp"
        />
</LinearLayout>

MainActivity,java:
**第一步,通过create()创建Observable(模拟对象:程序员),
通过onNext()发送数据:**

    public Observable<String> getObservable() {
        return Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
                e.onNext("奏笛");
                e.onNext("泡吧");
                e.onComplete();
            }
        });
    }

**第二步,创建Observer(模拟对象:程序员女朋友),
创建的方法是直接new:**

    public Observer<String>  getObserver(){
        return   new Observer<String>() {

            @Override
            public void onSubscribe(Disposable d) {
                Log.d("MainActivity","onSubscribe");
            }

            @Override
            public void onNext(String value) {
                Log.d("MainActivity","onNext");
            }

            @Override
            public void onError(Throwable e) {
                Log.d("MainActivity","onError");
            }

            @Override
            public void onComplete() {
                Log.d("MainActivity","onComplete");
            }
        };
    }

**第三步,在click()中,
getObservableobserver
实现订阅:**

    public void click(View view) {

        Observable<String> observale = getObservable();
        Observer<String> observer = getObserver();
        observale.subscribe(observer);
    }

以上便完成了一个最基本的使用;
运行效果:
点击按钮后打印日志:

**由此可以应证,
Rxjava中是自动发送 事件的,
一旦 Observable 被 observer 订阅了(observale.subscribe(observer);)
Observable就开始发送;
Observable通过自身 ObservableOnSubscribe中的 subscribe()中的
onNext()等方法自动发出信息,
observer接收到信息后执行对应的 onNext()等方法;**

**在订阅之后, Observer中,
onSubscribe()每次接收数据之前必须要调用的方法;
onNext()则是对应 Observable调用的次数去调用相应的次数;
onComplete()onError()对应完成/异常状态时候调用;**
  @Override
            public void onSubscribe(Disposable d) {
                Log.d("MainActivity","onSubscribe");
            }

接下来关注一下Observer构造方法中的onSubscribe()方法;

其中注意参数Disposable d

Disposable 一次性的意思;
其主要有以下两个方法:
用法示例
(用于监听Observable发送的数据,
如果Observable发送的数据等于某个值,
就断绝订阅关系):

更改Observable代码:

    public Observable<String> getObservable() {
        return Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
                e.onNext("奏笛");
                e.onNext("泡吧");
                e.onNext("酗酒");
                e.onComplete();
            }
        });
    }

运行示例,点击按钮:
可以发现已经没有onComplete()方法的打印信息了,
因为在onNext()中途已经断绝订阅关系了;

另外还有省略observer的简洁写法

    public void click(View view) {

        Observable<String> observale = getObservable();
        observale.subscribe(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                if(s.equals("奏笛")){
                    Log.d("MainActivity","收到奏笛!!这里类似于Observer的onNext()");
                }
                if(s.equals("吟诗")){
                    Log.d("MainActivity","收到吟诗!!这里类似于Observer的onNext()");
                }
                if(s.equals("酗酒")){
                    Log.d("MainActivity","收到酗酒!!这里类似于Observer的onNext()");
                }
            }
        }, new Consumer<Throwable>() {
            @Override
            public void accept(Throwable throwable) throws Exception {
                Log.d("MainActivity","这里类似于Observer的onError()");
            }
        }, new Action() {
            @Override
            public void run() throws Exception {
                Log.d("MainActivity","这里类似于Observer的onComplete()");
            }
        });

    }

    public Observable<String> getObservable() {
        return Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
                e.onNext("奏笛");
                e.onNext("吟诗");
                e.onNext("酗酒");
                e.onComplete();
            }
        });
    }

运行示例,点击按钮:

更改上面代码,

Observable.just()创建Observable对象,

效果也是一样的;
运行示例,点击按钮,打印日志同上:

    public Observable<String> getObservable() {
        Observable observable = Observable.just("奏笛","吟诗","酗酒");
        return  observable;
    }


或者显示在TextView上:

Observable.fromArray()创建Observable对象,

Observable observable = Observable.fromArray("奏笛","泡吧","吟诗");
**其实用法跟just()是一样的;
just()源码如下,
里面最终也是调用fromArray()实现的:**

Observable.fromCallable()创建Observable对象,

特点:只能返回一个数据;

本节笔记Activity全文(注意io.reactivex包的引用):

package com.cniao5.cniao5rxjava2demo;

import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.TextView;

import java.util.concurrent.Callable;

import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Action;
import io.reactivex.functions.Consumer;


public class MainActivity extends AppCompatActivity {

    private TextView textView;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        textView = (TextView) findViewById(R.id.text);
    }

    public void click(View view) {

        Observable<String> observale = getObservable();
//        Observer<String> observer = getObserver();
//
//        observale.subscribe(observer);
//        observale.subscribe(new Consumer<String>() {
//            @Override
//            public void accept(String s) throws Exception {
//                Log.d("MainActivity","accept="+s);
//
//                textView.append(s);
//                textView.append("//n");
//            }
//        });
        observale.subscribe(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                if(s.equals("奏笛")){
                    Log.d("MainActivity","收到奏笛!!这里类似于Observer的onNext()");
                }
                if(s.equals("吟诗")){
                    Log.d("MainActivity","收到吟诗!!这里类似于Observer的onNext()");
                }
                if(s.equals("酗酒")){
                    Log.d("MainActivity","收到酗酒!!这里类似于Observer的onNext()");
                }
                textView.append(s);
                textView.append("\n");
            }
        }, new Consumer<Throwable>() {
            @Override
            public void accept(Throwable throwable) throws Exception {
                Log.d("MainActivity","这里类似于Observer的onError()");
            }
        }, new Action() {
            @Override
            public void run() throws Exception {
                Log.d("MainActivity","这里类似于Observer的onComplete()");
            }
        });

    }



    public Observable<String> getObservable() {
//        Observable observable = Observable.just("奏笛","吟诗","酗酒");
//        Observable observable = Observable.fromArray("奏笛","泡吧","吟诗");
       return  Observable.fromCallable(new Callable<String>() {
            @Override
            public String call() throws Exception {
                return "奏笛";
            }
        });
//        return  observable;

//        return Observable.create(new ObservableOnSubscribe<String>() {
//            @Override
//            public void subscribe(ObservableEmitter<String> e) throws Exception {
//                e.onNext("奏笛");
//                e.onNext("吟诗");
//                e.onNext("酗酒");
//                e.onComplete();
////                e.onError(new);
//
//            }
//        });
    }

    public Observer<String>  getObserver(){
        return   new Observer<String>() {
              Disposable dd =null;//定义一个变量局部变量

            @Override
            public void onSubscribe(Disposable d) {
                dd = d;//把这段订阅关系的Disposable变量拿下来
                Log.d("MainActivity","onSubscribe");
            }

            @Override
            public void onNext(String value) {
                Log.d("MainActivity","onNext");

                if(value.equals("酗酒")){
                    dd.dispose();//如果发送的数据等于某个值,就断绝关系
                    Log.d("MainActivity","你的小可爱已经不想理你了!!!");
                }
            }

            @Override
            public void onError(Throwable e) {
                Log.d("MainActivity","onError");
            }

            @Override
            public void onComplete() {
                Log.d("MainActivity","onComplete");
            }
        };
    }
}





参考自 菜鸟窝

相关文章
|
28天前
|
自然语言处理 编译器 Linux
|
1月前
|
UED
<大厂实战经验> Flutter&鸿蒙next 中使用 initState 和 mounted 处理异步请求的详细解析
在 Flutter 开发中,处理异步请求是常见需求。本文详细介绍了如何在 `initState` 中触发异步请求,并使用 `mounted` 属性确保在适当时机更新 UI。通过示例代码,展示了如何安全地进行异步操作和处理异常,避免在组件卸载后更新 UI 的问题。希望本文能帮助你更好地理解和应用 Flutter 中的异步处理。
64 3
|
1月前
|
JavaScript API 开发工具
<大厂实战场景> ~ Flutter&鸿蒙next 解析后端返回的 HTML 数据详解
本文介绍了如何在 Flutter 中解析后端返回的 HTML 数据。首先解释了 HTML 解析的概念,然后详细介绍了使用 `http` 和 `html` 库的步骤,包括添加依赖、获取 HTML 数据、解析 HTML 内容和在 Flutter UI 中显示解析结果。通过具体的代码示例,展示了如何从 URL 获取 HTML 并提取特定信息,如链接列表。希望本文能帮助你在 Flutter 应用中更好地处理 HTML 数据。
106 1
|
23天前
|
前端开发 中间件 PHP
PHP框架深度解析:Laravel的魔力与实战应用####
【10月更文挑战第31天】 本文作为一篇技术深度好文,旨在揭开PHP领域璀璨明星——Laravel框架的神秘面纱。不同于常规摘要的概括性介绍,本文将直接以一段引人入胜的技术剖析开场,随后通过具体代码示例和实战案例,逐步引导读者领略Laravel在简化开发流程、提升代码质量及促进团队协作方面的卓越能力。无论你是PHP初学者渴望深入了解现代开发范式,还是经验丰富的开发者寻求优化项目架构的灵感,本文都将为你提供宝贵的见解与实践指导。 ####
|
27天前
|
前端开发 JavaScript
JavaScript新纪元:ES6+特性深度解析与实战应用
【10月更文挑战第29天】本文深入解析ES6+的核心特性,包括箭头函数、模板字符串、解构赋值、Promise、模块化和类等,结合实战应用,展示如何利用这些新特性编写更加高效和优雅的代码。
42 0
|
16天前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
45 2
|
2月前
|
缓存 Java 程序员
Map - LinkedHashSet&Map源码解析
Map - LinkedHashSet&Map源码解析
70 0
|
2月前
|
算法 Java 容器
Map - HashSet & HashMap 源码解析
Map - HashSet & HashMap 源码解析
57 0
|
2月前
|
存储 Java C++
Collection-PriorityQueue源码解析
Collection-PriorityQueue源码解析
64 0
|
2月前
|
安全 Java 程序员
Collection-Stack&Queue源码解析
Collection-Stack&Queue源码解析
85 0

推荐镜像

更多