Gradle 项目中 , 在 build.gradle 构建脚本中 , 添加如下依赖 ;
RxJava 通过 组合调用 / 链式调用 被观察者 / 观察者 / 订阅 / 操作符 要素 ;
RxJava是使用Java实现的响应式编程库，RxJava即 Reactive Extensions Java。目前有两个版本RxJava1和RxJava2,推荐使用RxJava2,RxJava1已经停止支持了
2016年学习过一阵子RxJava的操作符也做过一些笔记，我们项目的网络请求框架也替换成了Okhttp+Retrofit，所以使用RxJava做线程间切换就非常好用。
之前写了四篇从Demo到源码、从表现到内部实现原理，通过源码的分析初步学习了RxJava2.X的一些基本操作及原理，有如下几点 1、Observable与Observer是如何发生订阅关系的 2、onNext、onComplete、onError被调用的次数限制及实现流程 3、onSubscribe方法为何会第一个被调用？及如何控制Disposable来取消订阅事件 4、分两篇分析了RxJava2.X切换订阅线程和观察者线程的源码
在今年（2021 年）的 Google I/O 大会中的 Jetpack Q&A 环节，Android 团队被问了一个很有意思的问题：LiveData 是要被废弃了吗？
现在很多项目都在使用Rxjava了，对于RxJava的使用，估计都很熟悉了，但是很多人在使用RxJava的时候容易产生内存泄漏问题，比如我们在用RxJava配合Retrofit的时候，发出请求出去，拿到数据后我们可能会去刷新界面，但是如果这时候网络比较差，返回比较慢，而我们的Activity这时候关闭了，那RxJava当拿到返回的数据的时候去刷新界面就会报空指针异常了。所以我们当Activity关闭的时候，我们这时候如果RxJava还没执行完，我们应该取消订阅。
在Spring Cloud框架中涉及的Ribbon和Hystrix两个重要的组件都使用了RxJava响应式编程框架，其作为重要的编程基础知识，特开辟一章对RxJava的使用进行详细的介绍。
如今的Android社区，人人都在讨论RxJava以及为什么我们应该在项目中使用RxJava。当我们开始在Android项目中使用RxJava的时候，就已经意识到了，我们的代码库可以不再需要Otto了（或其他事件总线类库）。
前言 最近经常看到RxJava这个字眼，也看到很多人在博客中推荐使用RxJava。好奇的我怎么能错过，于是Google了一下，说RxJava好用的和说RxJava难用的都有，于是自己也亲自尝试了一下（感觉不容易上手）。写博客记录下学习的过程，一方面作为巩固，另一方面希望能帮助到初学者。 （第一篇只介绍了RxJava的基本用法，暂时还无法看出RxJava的优势。切莫着急，随着慢慢深入就能体会到RxJava带来的方便了） 参考：给 Android 开发者的 RxJava 详解 （本文部分内容引用自该博客）
我们在前面的 RxJava2.0使用详解（一）初步分析了RxJava从创建到执行的流程。RxJava2.0使用详解（二) 中分析了RxJava的随意终止Reactive流的能力的来源；也明白了RxJava的onComplete();与onError(t);只有一个会被执行的秘密。RxJava2.X 源码分析（三）中探索了RxJava2调用subscribeOn切换被观察者线程的原理。
可以看到，Observer的onSubscribe是最先被调用的，这个用什么用呢？我们后面会讲到。
ReactiveX 的全称为Reactive Extension，一般缩写为 Rx，即我们平常所说的反应式编程。其设计原理主要使用了观察者模式，区分数据的生产者和消费者，通过事件流的方式进行数据的异步处理。
最近跳槽到了一家新的公司, 居然发现这家公司的项目大量使用了RxJava3相关的技术, 这让我这个Rx系列轻度使用者有些无所适从.
1.RxJava概述 ReactiveX与RxJava 在讲到RxJava之前我们首先要了解什么是ReactiveX，因为RxJava是ReactiveX的一种Java实现。 ReactiveX是Reactive Extensions的缩写，一般简写为Rx，微软给的定义是，Rx是一个函数库，让开发者可以利用可观察序列和LINQ风格查询操作符来编写异步和基于事件的程序，开发者可以用Observables表示异步数据流，用LINQ操作符查询异步数据流， 用Schedulers参数化异步数据流的并发处理，Rx可
哈喽，朋友们，好久不见了，有段时间没推文了。从今天开始，我将计划更新 RxJava2.x 系列的文章，RxJava 是什么东西，我想也不用给大家介绍了吧。
Rxjava四要素 被观察者 在Rxjava当中， 决定什么时候触发事件， 决定触发什么样的事件； 观察者 决定事件触发的时候将产生什么样的行为； 类似于传统观察者模式， 观察者会随着被观察者的状态变化而发生相应的操作； 订阅 区别于传统观察者模式； 观察者和被观察者需要通过订阅来联系； 通过subscribe()方法完成这个订阅关系； 完成订阅关系后， 即可令被观察者（Observable）在需要的时候， 发出事件来通知观察者（Observer） 事件 区别于传统观察者模式；
然后开始提问题了，Rxjava涉及的内容很多，我还是会以三个问题为单位，从易到难，一篇篇的说下去，今天的三问是：
原文作者：Carson_Ho 原文地址：http://www.jianshu.com/p/a406b94f3188 特别声明：本文为Carson_Ho原创并授权发布，未经原作者允许请勿转载，转载请联系
步骤1：创建被观察者(Observable)& 定义需发送的事件 步骤2：创建观察者(Observer) & 定义响应事件的行为 步骤3：通过订阅（subscribe）连接观察者和被观察者
即RxJava原理可总结为：被观察者 （Observable） 通过 订阅（Subscribe） 按顺序发送事件 给观察者 （Observer）， 观察者（Observer） 按顺序接收事件 & 作出对应的响应动作。具体如下图：
Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。
为了准备春招，整理了some流行技术,大概是去年5，6月份开始在知乎上看到，后面了解到google早在github上开源了Android开发三种开发模式：MVC ，MVP，MVVM，其中关于这三种对于具体需求来说有不同变体。(吼吼~~有不对的地方请指出==) 现在要介绍的是MVP+RxJava+Retrofit这种开发模式，那进入正题前，需要了解下前面的三个技术。别着急，一个一个来说？ MVP模式介绍： 很明显它与MVC模式只有一字之差，如果想快速了解一样东西，比较其特征是最好的方式了。接下来，
RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-based programs by using observable sequences. 简单来说，rxJava 是一种 基于事件的，使用了可被观察序列 的异步 响应 扩展 的类库。
本文介绍了RxJava的基本组件，包括创建Observer和Observable的方法，以及使用更少的代码创建不同Observable的操作符。此外，还介绍了如何根据文章内容撰写文章的摘要总结。
概述 RxJava是一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库。更重要的是：使用RxJava在代码逻辑上会非常简洁明了，尤其是在复杂的逻辑上。告别迷之缩进。 RxAnd
我们还是通过基础的例子来进行讲解，比如你有个快递，你很想知道快递是否已经到小区，你可能想要在快递刚到你的小区的时候就马上知道，然后马上就能享受拆快递所带来的乐趣，毕竟等待快递的时候实在太煎熬了。
总的来说，EventBus是一款针对Android优化的发布/订阅事件总线，主要功能是替代Intent,Handler,BroadCast在Fragment，Activity，Service，线程之间传递消息。而Rxjava则是一种基于异步数据流的处理方案。如果一个订阅者需要注册多个事件的时候，Rxjava需要一个个单独的注册，而EventBus则可以实现一个订阅者订阅多个事件，和一个事件对应多个订阅者。
在`RxJava 2.0 `中，创建被观察者（`Observable`） & 观察者（Observer）的方式也与`RxJava 1.0 `有些区别：
前言 Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。 今天，carson今天将采用 图文的方式 解析 Rxjava的基本原理，希望大家会喜欢。 Carson带你学RxJava系列文章，包括 原理、操作符、应用场景、背压等等，请看文章：Android：这是一份全面 & 详细的RxJava学习指南 目录 1. 定义 RxJava 在 GitHub 的介绍： RxJava：a library for composing asynchr
前言 Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。 如果还不了解RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rx
在RxJava 2.0中，创建被观察者（Observable） & 观察者（Observer）的方式也与RxJava 1.0有些区别：
2、如果读者还没学习过Rxjava 1.0也没关系，因为Rxjava 2.0只是在Rxjava 1.0上增加了一些新特性，本质原理 & 使用基本相同
在 Android 应用开发中，异步编程是不可避免的，而 Kotlin Flow 是一个强大的库，能够使异步操作更加优雅和易于管理。本文将深入探讨 Kotlin Flow 的使用方法，同时也会解析其背后的实现原理，帮助你更好地理解这一技术。
更重要的是，随着程序逻辑的复杂性提高，它依然能够保持简洁 & 优雅。所以，一般建议使用这种基于事件流的链式调用方式实现RxJava。
最近在Android编程领域，RxJava这个框架的技术热度相当的高。团队对使用RxJava改进目前的项目代码也表示很有兴趣，所以我特地和团队伙伴一起对这套框架做了一下调研。现在就把目前对RxJava的一些理解和粗浅的分析做一下分享，欢迎大家拍砖。 1.什么是RxJava 要了解什么是RxJava，先需要了解一下它的理念来源：ReactiveX。 ReactiveX是Reactive Extensions的缩写，一般简写为Rx，最初是LINQ的一个扩展，由微软的架构师Erik Meijer领导的团队开发
链接：https://juejin.cn/post/6943037393893064734#heading-13
本篇文章是阅读 官方文档 的笔记。 作者：shixinzhang RxJava 也用了有段时间，那么多操作符总不想去记，遇到了才去查一下，查的次数多了感觉效率太低，还不如先过一遍官方文档。 因此接下
RxJava的编程思想已经在Android开发者中变得越来越流行。有个不好的点就是上手不太容易，尤其是大部分人之前都是使用命令式编程语言。
我从去年开始使用 RxJava ，到现在一年多了。今年加入了 Flipboard 后，看到 Flipboard 的 Android 项目也在使用 RxJava ，并且使用的场景越来越多 。而最近这几个月，我也发现国内越来越多的人开始提及 RxJava 。有人说『RxJava 真是太好用了』，有人说『RxJava 真是太难用了』，另外更多的人表示：我真的百度了也谷歌了，但我还是想问： RxJava 到底是什么？
我们知道，subscribeOn() 方法通过接收一个 Scheduler 参数，来指定对数据的处理运行在特定的线程调度器 Scheduler 上。若多次执行 subscribeOn() 方法，则只有最初的一次起作用。
目前大多数开发者使用EventBus或者Otto作为事件总线通信库，对于RxJava使用者来说，RxJava也可以轻松实现事件总线，因为它们都依据于观察者模式。
Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。本文主要讲解的是： 线程控制（也称为调度 / 切换），即讲解功能性操作符中的：subscribeOn（） & observeOn（）
本文介绍了RxJava和Agera的基本调用流程，通过一个简单的示例展示了它们在实际使用中的便捷性。同时，也探讨了它们在实际使用中可能遇到的问题和解决方案。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
