关键词：
1. 概念
Reactive 非常适合低延迟、高吞吐量的工作负载。
Reactive Processing 是一种范式（规范），它使开发人员能够构建非阻塞的、异步的应用程序，这些应用程序能够处理背压（流控制）
Reactive Streams 为无阻塞背压的异步流处理提供标准。
Reactor 是基于Reactive Streams规范的第四代响应库，用于在JVM上构建非阻塞的应用程序。
Project Reactor 是一个完全无阻塞的基础，其中包括背压支持。它是Spring生态系统中的响应式堆栈的基础，并且在诸如Spring WebFlux，Spring Data和Spring Cloud Gateway等项目中都有它的身影。利用Project Reactor可以高效的响应式系统。刚才说Reactive Streams是规范，那么Project Reactor就是实现。
2. 响应式编程
响应式编程是一种异步编程风格，它关注数据流和变化的传播。
响应式编程是一种与数据流和变化传播相关的声明式编程范式。使用此范例，可以轻松地表示静态(例如，数组)或动态(例如，事件发射器)数据流，并且还可以表示关联执行模型中的推断出的依赖关系，这有助于更改数据流的自动传播。
reactive programming （响应式编程）
imperative programming（命令式编程）
在命令式编程中，a:=b+c意味着将b+c的结果赋值给a，并且此后b或c的值发生变化不会影响到a的值。而在响应式编程中，a的值会随着b或c的改变而自动更新，并且不需要重新执行a:=b+c来确定当前分配给a的值。（PS：是不是很像angularjs、vuejs这种MVVM框架，视图绑定模型，模型变了，视图自动就跟着变了）
例如，在 model–view–controller (MVC) 架构中，响应式编程可以促进基础模型中的更改，这些更改会自动反映在关联的视图中。
响应式编程与面向对象编程中通常使用的观察者模式具有很多相似之处。
如果从推拉的角度来看的话，响应式编程是“推”，它主动将变化推送给它的订阅者。Publisher-Subscriber是两个非常重要的概念。
想象一下，数据流从源出发，经过一个一个节点的处理，最终达到目的地。节点就相当于操作符，处理完了以后就将流发射出去，到下一个节点再执行再发射。
我总觉得这个流程很眼熟，很像 Apache Storm 的处理方式。在一个拓扑结构中，数据流从Spout发出，经过若干bolt的处理，最终汇集到某个地方。
还有一种理解，我觉得也很不错，说响应式编程是一种通过异步和数据流来构建事务关系的编程模型。事物可以理解程一次处理过程，一次执行过程。响应式编程就是要构建关系，事务和事务之间的关系。而数据流就像是一个桥梁一样，数据流从一个事务流向下一个事务。
想象一下，长江流经宜宾、泸州、重庆、涪陵、万州、宜昌、荆州、武汉、黄石、鄂州、九江、安庆、铜陵、芜湖、南京、上海，最终汇入东海。
就像CompleteFuture把Future进行编排一样。
本质来讲，响应式编程上是对数据流或某种变化所作出的反应，但是这个变化什么时候发生是未知的，所以他是一种基于异步、回调的方式在处理问题
3. NIO
NIO（Non-Blocking I/O）
BIO（Blocking I/O）
在经典的线程模型中，socket.accept()、socket.read()、socket.write()三个主要函数都是同步阻塞的，当一个连接在处理I/O的时候，系统是阻塞的，如果使用单线程的话就阻塞在那里了，但CPU是并没有阻塞，如果用多线程的话，就可以让CPU去处理更多的事情。其实这也是所有使用多线程的本质： 当I/O阻塞系统，但CPU空闲的时候，可以利用多线程使用CPU资源。然而，线程的创建、销毁、切换成本都是很高的。
事实上，所有的系统I/O都分为两个阶段：等待就绪和操作。举例来说，读函数，分为等待系统可读和真正的读；同理，写函数分为等待网卡可以写和真正的写。
需要说明的是等待就绪的阻塞是不使用CPU的，是在“空等”；而真正的读写操作的阻塞是使用CPU的，真正在”干活”。
以socket.read()为例子：
传统的BIO里面socket.read()，如果TCP RecvBuffer里没有数据，函数会一直阻塞，直到收到数据，返回读到的数据。
对于NIO，如果TCP RecvBuffer有数据，就把数据从网卡读到内存，并且返回给用户；反之则直接返回0，永远不会阻塞。
在BIO模型中，没有办法知道到底能不能写、能不能读，只能”傻等”。而在NIO模型中，如果一个连接不能读写（socket.read()返回0或者socket.write()返回0），我们可以把这件事记下来，记录的方式通常是在Selector上注册标记位，然后切换到其它就绪的连接（channel）继续进行读写。
NIO的主要事件有几个：读就绪、写就绪、有新连接到来。那么，首先需要注册当这几个事件到来的时候所对应的处理器，然后在合适的时机告诉事件选择器：我对这个事件感兴趣，最后用一个死循环选择就绪的事件。select是阻塞的，所以你可以放心大胆地在一个while(true)里面调用这个函数而不用担心CPU空转。
总结起来就是：注册所有感兴趣的事件处理器，单线程轮询选择就绪事件，执行事件处理器。
我们大概可以总结出NIO是怎么解决掉线程的瓶颈并处理海量连接的：
NIO由原来的阻塞读写（占用线程）变成了单线程轮询事件，找到可以进行读写的网络描述符进行读写。除了事件的轮询是阻塞的（没有可干的事情必须要阻塞），剩余的I/O操作都是纯CPU操作，没有必要开启多线程。
NIO由原来的阻塞读写（占用线程）变成了单线程轮询事件，找到可以进行读写的网络描述符进行读写。除了事件的轮询是阻塞的（没有可干的事情必须要阻塞），剩余的I/O操作都是纯CPU操作，没有必要开启多线程。并且由于线程的节约，连接数大的时候因为线程切换带来的问题也随之解决，进而为处理海量连接提供了可能。单线程处理I/O的效率确实非常高，没有线程切换，只是拼命的读、写、选择事件。但现在的服务器，一般都是多核处理器，如果能够利用多核心进行I/O，无疑对效率会有更大的提高。
Buffer（缓冲区）
在NIO中，所有数据都是用缓冲区处理的。在读取数据时，它是直接读到缓冲区中的；在写入数据时，它也是写入到缓冲区中的。
Channel（通道）
通道是一个对象，通过它可以读取和写入数据，当然了所有数据都通过Buffer对象来处理。我们永远不会将字节直接写入通道中，相反是将数据写入包含一个或者多个字节的缓冲区。同样不会直接从通道中读取字节，而是将数据从通道读入缓冲区，再从缓冲区获取这个字节。
Selector（选择器）
Selector类是NIO的核心类，Selector（选择器）选择器提供了选择已经就绪的任务的能力。Selector会不断的轮询注册在上面的所有channel，如果某个channel为读写等事件做好准备，那么就处于就绪状态，通过Selector可以不断轮询发现出就绪的channel，进行后续的IO操作。一个Selector能够同时轮询多个channel。这样，一个单独的线程就可以管理多个channel，从而管理多个网络连接。这样就不用为每一个连接都创建一个线程，同时也避免了多线程之间上下文切换导致的开销。
参考：
https://www.jianshu.com/p/d47835316016
https://www.cnblogs.com/haimishasha/p/10756448.html
https://tech.meituan.com/2016/11/04/nio.html
vue3.0源码系列响应式原理-reactivity(代码片段)
...比较长，如果不想看文字可直接转到这里看脑图简介reactivity是vuenext里面通过proxy+reflect实现的响应式模块。源码路径：packages/reactivity入口文件&# 查看详情
springboot加载reactive程序过程
spring-boot通过判断含org.springframework.web.reactive.DispatcherHandler类就肯定程序类型是REACTIVE，然后加载上下文类org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext，看下面代码priva 查看详情
无法解析 spring-web-reactive 的依赖项
】无法解析spring-web-reactive的依赖项【英文标题】：Couldnotresolvedependenciesforspring-web-reactive【发布时间】：2018-12-1211:06:43【问题描述】：我在我的SpringBoot应用程序中使用Reactive方法进行异步流处理。我有这6个用于SpringFramework的导入... 查看详情
在 System.Reactive 的订阅中处理异常
】在System.Reactive的订阅中处理异常【英文标题】：HandlingexceptionsinSystem.Reactive\'sSubscribe【发布时间】：2022-01-0914:58:34【问题描述】：我想使用System.Reactive显示以下所有订阅的例外情况。下面一小段代码，你可以看到我试过了，但... 查看详情
System.Reactive - 一次处理未知数量的订阅
】System.Reactive-一次处理未知数量的订阅【英文标题】：System.Reactive-Disposingunknownamountofsubscriptionsatonce【发布时间】：2022-01-0818:03:02【问题描述】：我有未知数量的订阅想要立即处理，因为它们可能会变得很多。有没有使用System.Re... 查看详情
vue3—reactive如何更改属性
参考技术Avue3新增了响应性API，其中数据有两种，ref和reactive。reactive支持非原始对象，基础类型不能使用（Number,Boolean等）例1例2遇到这样的情况，需要单独赋值例3或者使用Object.assign例4案例地址 查看详情
闪亮：reactive() 检查 read.csv
】闪亮：reactive()检查read.csv【英文标题】：Shiny:reactive()checkonread.csv【发布时间】：2017-08-1700:11:58【问题描述】：我正在编写一个闪亮的服务器脚本，我希望reactive()首先检查我的c驱动器上的数据，如果它在那里，那么很好，否则... 查看详情
reactive_forms Flutter - 创建和渲染组
】reactive_formsFlutter-创建和渲染组【英文标题】：reactive_formsFlutter-creatingandrenderingGroups【发布时间】：2021-02-1115:27:26【问题描述】：难以确定如何将组作为示例呈现(https://github.com/joanpablo/reactive_forms#groups-of-groups-grin)：finalform=FormGr... 查看详情
vue使用reactive动态改变属性(代码片段)
Vue使用reactive动态改变属性1.目的我们的目的是根据某些事件来改变某些属性，从而动态的展示在页面上。这里如果把属性直接定义为ref是不行的，需要定义为reactive才行。2.使用constcount=ref(1)constobj=reactive(count)//ref会... 查看详情
《reactive_mircservice_architecture》脑图
Reactive_MircService_ArchitectureLightbendCTO的50页的小册子，对响应式系统以及微服务架构介绍非常全面，整理了一个脑图来先。 查看详情
Spring 5 Reactive - WebExceptionHandler 没有被调用
】Spring5Reactive-WebExceptionHandler没有被调用【英文标题】：Spring5Reactive-WebExceptionHandlerisnotgettingcalled【发布时间】：2018-05-1719:02:27【问题描述】：我已经尝试了whatistherightwaytohandleerrorsinspring-webflux中建议的所有3种解决方案，但WebExcep... 查看详情
Reactive.NET - 从 .Subscribe 返回通用对象
】Reactive.NET-从.Subscribe返回通用对象【英文标题】：Reactive.NET-returninggenericobjectoutof.Subscribe【发布时间】：2022-01-0515:00:20【问题描述】：有一个组合的网络套接字流wss://stream.binance.com:9443/stream?streams=bnbusdt@ticker/dogeusdt@depth5，我需... 查看详情
vue.reactive 不是函数
】vue.reactive不是函数【英文标题】：vue.reactiveisnotafunction【发布时间】：2021-10-0308:09:04【问题描述】：我尝试将一个vue项目迁移到一个nuxt项目。问题在于使用store/index.js文件。我将原始文件复制到存储文件夹中，并发生此错误。... 查看详情
#yyds干货盘点#vue3的reactive
最近一阶段在学习Vue3，Vue3中用 reactive、ref 等方法将数据转化为响应式数据，在获取时使用 track 往 effect 中收集依赖，在值改变时，使用 trigger 触发依... 查看详情
从子 React Reactive Form 更新父状态变量
】从子ReactReactiveForm更新父状态变量【英文标题】：UpdateparentstatevariablefromchildReactReactiveForm【发布时间】：2020-12-1911:49:22【问题描述】：我正在尝试使用next框架探索react库。由于我是angular开发人员，我喜欢将我的一些reactive-form... 查看详情
Vue 3 组件重置不会重置 reactive() 对象数据
】Vue3组件重置不会重置reactive()对象数据【英文标题】：Vue3componentresetdoesnotresetreactive()objectdata【发布时间】：2021-09-1302:28:56【问题描述】：使用Vue3、打字稿、组合API和FireStore数据，当尝试通过键值更改重置表单时，所有reactive()... 查看详情
springwebflux-02reactive介绍
文章目录Pre官网ReactiveReactive的几个项目ProjectReactorReactiveMicroservicesReactiveMicroservicesWithSpringBootIntegrationwithcommontechnologies附：反应式宣言反应式系统的特质PreSpringWebflux-01MVC的困境中我们提到了通过Servlet异步的方式 查看详情
springwebflux-02reactive介绍
文章目录Pre官网ReactiveReactive的几个项目ProjectReactorReactiveMicroservicesReactiveMicroservicesWithSpringBootIntegrationwithcommontechnologies附：反应式宣言反应式系统的特质PreSpringWebflux-01MVC的困境中我们提到了通过Servlet异步的方式 查看详情