函数式编程是一种编程范式。我们常见的编程范式有命令式编程、函数式编程和逻辑式编程。我们常见的面向对象编程是一种命令式编程。命令式编程是面向计算机硬件的抽象，有变量、赋值语句、表达式和控制语句。而函数式编程是面向数学的抽象，将计算描述为一种表达式求值，函数可以在任何地方定义，并且可以对函数进行组合。响应式编程是一种面向数据流和变化传播的编程范式，数据更新是相关联的。把函数式编程里的一套思路和响应式编程合起来就是函数响应式编程。函数响应式编程可以极大地简化项目，特别是处理嵌套回调的异步事件、复杂的列表过滤和变换或者时间相关问题。在Android开发中使用函数响应式编程的主要有两大框架： 一个是 RxJava，另一个是 Goodle 推出的 Agera。本章我们来学习 RxJava。
在很多软件编程任务中，或多或少你都会期望你写的代码能按照编写的顺序，一次一个的顺序执行和完成。但是在ReactiveX中，很多指令可能是并行执行的，之后他们的执行结果才会被观察者捕获，顺序是不确定的。为达到这个目的，你定义一种获取和变换数据的机制，而不是调用一个方法。在这种机制下，存在一个可观察对象(Observable)，观察者(Observer)订阅(Subscribe)它，当数据就绪时，之前定义的机制就会分发数据给一直处于等待状态的观察者哨兵。
这一章将描述反应式编程范式，以及为什么它能很好地适用于带有函数元素的语言。读者将熟悉反应式编程背后的概念。我们将介绍在创建反应式应用时从观察者模式和迭代器模式中使用的元素。这些示例将使用反应式框架和名为 RxJava（版本 2.0）的 Java 实现。
（有数据添加和更新时自动调用之前订阅了的读取函数，达到有数据添加自动更新ui的效果，
在前一篇文章《使用 Kotlin + Spring Boot 进行后端开发》中，曾介绍过尝试使用 Kotlin 来做后端开发。这一次，尝试 WebFlux 以及协程。
比如在调用线程里面异步打日志，为了不让日志打印阻塞调用线程，会把日志设置为异步方式。如图 所示的日志异步化打印，使用一个内存队列把日志打印异步化，然后使用单一消费线程异步处理内存队列中的日志事件，执行具体的日志落盘操作（本质是一个多生产单消费模型），在这种情况下，调用线程把日志任务放入队列后会继续执行其他操作，而不再关心日志任务具体是什么时候入盘的。
最近在做一个项目，获取JDK8 Stream对象后，想要批量消费，不想自己写个集合来做批量处理。而反应式编程实现比如rxjava或者reactor是有丰富的流操作符，所以调研了下如何把JDK8 Stream转换为反应式流。
github 地址：https://github.com/imageprocessor/cv4j
2017年的首篇文章，本次依旧带来一叶飘舟的开年之作，新的一年祝大家事业有成，爱情美满！
上一节里我们学习了只使用Observable如何去解决上下游流速不均衡的问题，之所以学习这个是因为Observable还是有很多它使用的场景，有些朋友自从听说了Flowable之后就觉得得Flowable解决任何问题，甚至有抛弃Observable这种想法，这是万万不可的，它们都有各自的优势和不足。
在上篇文章中讲的是关于Rxjava的基础篇，今天来讲讲多种操作符的具体内容，操作符太多了，大家准备好啊，耐心看~
每个Android开发者，都是爱RxJava的,简洁线程切换和多网络请求合并，再配合Retrofit,简直是APP开发的福音。不知不觉，RxJava一路走来，已经更新到第三大版本了。不像RxJava 2对RxJava 1那么残忍，RxJava 3对RxJava 2的兼容性还是挺好的，目前并没有做出很大的更改。RxJava2到2020年12月31号不再提供支持，错误时同时在2.x和3.x修复，但新功能只会在3.x上添加。
rxjava文档地址https://mcxiaoke.gitbooks.io/rxdocs/content/ 这个是中文版的
这是一篇译文，原文出处(http://alexsderkach.io/comparing-java-8-rxjava-reactor/)。其实很久以前我就看完了这篇文章，只不过个人对响应式编程研究的不够深入，羞于下笔翻译，在加上这类译文加了原创还有争议性，所以一直没有动力。恰逢今天交流群里两个大佬对响应式编程的话题辩得不可开交，趁印象还算深刻，借机把这篇文章翻译一下。说道辩论的点，不妨也在这里抛出来：
RxJava2 发布已经有一段时间了，是对 RxJava 的一次重大的升级，由于我的一个库cv4j使用了 RxJava2 来尝鲜，但是 RxJava2 跟 RxJava1 是不能同时存在于一个项目中的，逼不得已我得把自己所有框架中使用 RxJava 的地方以及 App 中使用 RxJava 的地方都升级到最新版本。所以我整理并记录了一些已经填好的坑。
在上一节中, 我们学习了Flowable的一些基本知识, 同时也挖了许多坑, 这一节就让我们来填坑吧.
您可以通过传递QueryOptions对象来为查询方法指定查询选项。这些选项在实际查询执行之前应用于查询。 QueryOptions被视为非查询参数，不被视为查询参数值。查询选项适用于派生和字符串@Query存储库方法。
Reactor 项目始于 2012 年。 经过长时间的内部孵化，于 2013 年发布 Reactor 1.x 版本。 Reactor 1 在各种架构下都能成功部署，包括开源的(如 Meltdown)和商业的(如 Pivotal RTI)。2014年，通过与一些新兴的响应式数据流规范合作，重新设计并于 2015 年 4 月发布 Reactor 2.0 版本。
反应式编程（Reactive Programming）对有些人来说可能相对陌生一点。反应式编程是一套完整的编程体系，既有其指导思想，又有相应的框架和库的支持，并且在生产环境中有大量实际的应用。在支持度方面，既有大公司参与实践，也有强大的开源社区的支持。 反应式编程出现的时间并不短，不过在最近的一段时间内，它得到了很大的关注。这主要体现在主流编程平台和框架增强了对它的支持，使它得到了更多的受众，同时也反映了其在开发中的价值。 就 Java 平台来说，几个突出的事件包括：Java 9中把反应式流规范以 java
后面三种观察者模式差不多，Maybe/MaybeObserver可以说是Single/SingleObserver和Completable/CompletableObserver的复合体。
在`RxJava 2.0 `中，创建被观察者（`Observable`） & 观察者（Observer）的方式也与`RxJava 1.0 `有些区别：
解决了 因被观察者发送事件速度 与 观察者接收事件速度 不匹配（一般是前者 快于 后者），从而导致观察者无法及时响应 / 处理所有 被观察者发送事件 的问题
本文作者知秋，节选自《Java编程方法论：响应式Spring Reactor 3设计与实现》一书。 -------
Flow 跟 Sequences 之间的区别是 Flow 不会阻塞主线程的运行，而 Sequences 会阻塞主线程的运行。
通常Java开发人员喜欢使用同步代码编写程序,因为这种请求(request)/响应(response)的方式比较简单，并且比较符合编程人员的思维习惯;这种做法很好，直到系统出现性能瓶颈；在同步编程方式时由于每个线程同时只能发起一个请求并同步等待返回，所以为了提高系统性能，此时我们就需要引入更多的线程来实现并行化处理；但是多线程下对共享资源进行访问时，不可避免会引入资源争用和并发问题；另外操作系统层面对线程的个数是有限制的，不可能通过无限的增加线程数来提供系统性能；最后使用同步阻塞的编程方式还会导致浪费资源，比如发起网络IO请求时候，调用线程就会处于同步阻塞等待响应结果的状态，而这时候调用线程明明可以去做其他事情，等网络IO响应结果返回后在对结果进行处理。
各自的职责：Retrofit 负责请求的数据和请求的结果，使用接口的方式呈现；OkHttp 负责请求的过程；RxJava 负责异步，各种线程之间的切换。
为了应对高并发场景下到服务端编程需求，微软最先提出了一种异步编程到方案Reactive Programming，也就是反应式编程。
这篇文章是我介绍Eclipse Vert.x系列的第五篇文章。在上一篇文章中，我们看到了Vert.x如何与数据库交互。我们使用Future对象来驯服Vert.x的异步特性。在这篇文章中，我们将看到另一种管理异步代码的方式：反应式编程。我们将看到Vert.x如何与Reactive eXtensions结合来为您提供巨大的能量。
| 导语 反应式编程是在命令式编程、面向对象编程之后出现的一种新的编程模型，是一种以优雅的方式，通过异步和数据流来构建事务关系的编程模型。本文包括反应式编程的概述和 RxPy 实战，以及怎样去理解反应式编程才能更好的把它融入到我们的编程工作中，把反应式编程变成我们手中的利器。
在RxJava 2.0中，创建被观察者（Observable） & 观察者（Observer）的方式也与RxJava 1.0有些区别：
作者 | 张逸 特别说明：本文包含大量代码片段，若要获得更好阅读观感，请点击文末“阅读原文”或访问我的博客。 响应式编程在前端开发以及Android开发中有颇多运用，然而它的非阻塞异步编程模型以及对消息流的处理模式也在后端得到越来越多的应用。除了Netflix的OSS中大量使用了响应式编程之外，最近阿里也提出Dubbo 3.0版本将全面拥抱响应式编程。 我之前针对某些项目需求也给出了响应式编程的方案，较好地解决了并行编程与异步编程的问题。不过在深入了解响应式编程之后，我也给出了自己的一些实践总结。 响应式编
通常情况下，如果我们想要使用 RxJava 首先会想到的是使用Observable，如果要考虑到Backpressure的情况，在 RxJava2.x 时代我们会使用Flowable。除了Observable和Flowable之外，在 RxJava2.x 中还有三种类型的Observables：Single、Completable、Maybe。
通常而言，Rx如果遇到if条件语句、switch case语句时需要先选择分支条件，然后再进行链式调用。RxCondition产生的目的就是为了在这些情况下也能顺利地使用链式调用。
1、介绍 1.1 什么是响应式编程（Reactive Programming）？ 简单来说，响应式编程是针对异步和事件驱动的非阻塞应用程序，并且需要少量线程来垂直缩放（即在 JVM 内）而不是水平（即通过集群）。 响应式应用的一个关键方面是“背压（backpressure）”的概念，这是确保生产者不会压倒消费者的机制。例如，当HTTP连接太慢时，从数据库延伸到HTTP响应的反应组件的流水线、数据存储库也可以减慢或停止，直到网络容量释放。 响应式编程也导致从命令式到声明异步组合逻辑的重大转变。与使用Java
RxJava 2.0.5 版本新增了 ParallelFlowable API，它允许并行地执行一些运算符，譬如map、filter、concatMap、flatMap、collect、reduce等。
ReactiveX 响应式编程库，这是一个程序库，通过使用可观察的事件序列来构成异步和事件驱动的程序。
前一篇分析了Spring WebFlux的设计及实现原理后，反应式编程又来了，Spring WebFlux其底层还是基于Reactive编程模型的，在java领域中，关于Reactive，有一个框架规范，叫【Reactive Streams】，在java9的ava.util.concurrent.Flow包中已经实现了这个规范。其他的优秀实现还有Reactor和Rxjava。在Spring WebFlux中依赖的就是Reactor。虽然你可能没用过Reactive开发过应用，但是或多会少你接触过异步Servlet，同时又有这么一种论调：异步化非阻塞io并不能增强太多的系统性能，但是也不可否认异步化后并发性能上去了。听到这种结论后在面对是否选择Reactive编程后，是不是非常模棱两可。因为我们不是很了解反应式编程，所以会有这种感觉。没关系，下面看看反应式编程集大者Reactor是怎么阐述反应式编程的。
每个Android开发者，都是爱RxJava的,简洁线程切换和多网络请求合并，再配合Retrofit,简直是APP开发的福音。不知不觉，RxJava一路走来，已经更新到第三大版本了。不像RxJava 2对RxJava 1那么残忍，RxJava 3对RxJava 2的兼容性还是挺好的，目前并没有做出很大的更改。RxJava2到2020年12月31号不再提供支持，错误的会同时在2.x和3.x修复，但新功能只会在3.x上添加。
哈喽，朋友们，之前我们学习了一些 RxJava2.x 的常用操作符，今天我们来继续学习一下RxJava 的并行编程。
2015 年反应式流 (Reactive Stream) 规范诞生，定义了如下四个接口：
好久不见朋友们，最近一段时间在忙工作上的事情，没来得及写文章，这两天正好有点时间，赶紧写下了这篇教程，免得大家说我太监了。
在上一篇文章中，我讲述了怎么在MVVM框架中搭建网络访问框架，并通过一个必应的每日壁纸做了一次请求接口的访问演示，这篇文章就需要来讲述Android端的本地数据库的使用和在MVVM中使用方式了。
Transformer，顾名思义是转换器的意思。早在 RxJava1.x 版本就有了Observable.Transformer、Single.Transformer和Completable.Transformer，在2.x版本中变成了ObservableTransformer、SingleTransformer、CompletableTransformer、FlowableTransformer和MaybeTransformer。其中，FlowableTransformer和MaybeTransformer是新增的。由于 RxJava2 将Observable拆分成 Observable 和 Flowable，所以多了一个FlowableTransformer。同时，Maybe是 RxJava2 新增的一个类型，所以多了MaybeTransformer。
阅读本文需要对Rxjava了解，如果还没有了解或者使用过Rxjava的兄die们，推荐观看 Android Rxjava：图解不一样的诠释 进行学习。
我们知道RxJava是Android项目最重要的库。因此，我们必须正确掌握在Android项目中使用RxJava。
领取专属 10元无门槛券
手把手带您无忧上云
