响应式编程以及反应式编程框架Reactor3的简单介绍

福利

如今关注微信公众号：码农小胖哥， 发送关键字【抽奖】进行抽奖，可有机会获取实体编程书籍。【本次抽奖截止到周末，若是错过之后还有不少机会】

前言

Reactor 3是一个围绕Reactive Streams规范构建的库，它在JVM上引入了响应式编程的一个范例。目前Spring5 引入的Webflux就是reactor 3实现的一个响应式web框架。Spring Cloud Gateway是Webflux的一个网关场景实践。想学好上面这两项技术必须搞明白响应式编程以及Reactor 3。本篇文章中，小胖哥将带你来简单了解响应式编程和Reactor 3。

为何要搞响应式

有这么一个场景，产品提了一个这么需求：商品打折，根据商品的原价来计算商品的折扣价。这个需求不是很简单嘛，按照咱们一般的作法，搞一个以下的方法就搞定了。

可是若是我折扣改了呢，这时有人该说从新计算啊。这样是否是从新走了一次流程呢，咱们须要花精力来维护这种流程逻辑。那么能不能我下游能直接响应上游的变化？就像excel表格计算同样，下游始终监听上游，有点风吹草动，结果就会变化。这种潜在的需求就是响应式。响应式编程正是用某种操做符帮助你构建这种关系，而不是执行某种赋值命令。这种思想其实在前端的一些框架中已经风靡好久了。

响应式的特色

基于以上的一个简单事例。咱们能够看出若是是响应式必定要有一个触发点。就像咱们点击了计算机桌面的QQ图标一只企鹅跳啊跳。咱们点击了迅雷图标有一只飞鸟在扑腾着翅膀。计算机只维护一个点击图标的事件。也就是说响应式编程必定是一个事件触发机制。而且是以异步和非阻塞的方式发送和接收的。不是咱们日常请求-响应的同步模型。事件驱动的系统经过push而不是pull来处理，生产者在有消息时才推送消息给消费者，而不是经过一种浪费资源方式：让 消费者不断地轮询或等待数据。基于这个机制相对高的吞吐量和实时响应也是响应式的特色。事件驱动因为Publisher只用关心数据源，Consumer只用关心对处理结果的消费。彻底是松耦合的。这就给咱们很大的操做空间来定制化咱们的逻辑组合，从而使异步代码更易读和可维护。

Reactor简介

Reactor 3框架是Pivotal（Spring 母公司）基于Reactive Programming思想实现的。它实现了Reactive Streams(该规范由 Netflix、TypeSafe、Pivotal等公司发起的响应式规范)。其余诸如RxJava 2, Akka Streams, Vert.x和Ratpack也都实现了该规范。

Reactor有一个很重要概念的就是backpressure。 因为生产者消费者处理数据的能力不对等，很容易产生下游消费能力过载的问题。这就须要一个backpressure处理，来告诉上游生产者避免过载。打个比方，一我的负责放水，一我的负责接水，若是放水的速度太快，水桶势必会溅出来，接水的人会根据状况来告诉放水的人什么速度最合适，而且在快满的时候告知放水人关闭开关。

Reactor还添加了运算符的概念，这些运算符被连接在一块儿以描述在每一个阶段对数据应用的处理。应用运算符返回一个中间Publisher（实际上，它能够被认为是上游运算符的订阅者和下游的发布者）。数据的最终概括点是在最终Subscriber中（这里还定义了用户角度的业务逻辑）。还拿放水举例，若是咱们放水不是为了单纯放水而是为了制造肥宅快乐水。这样就不是一我的接水了，中间加入了原浆流程，下一个接的人接到的是原浆勾兑水，那么这我的充当了源头的消费者，也充当了他下游的生产者。他的下游还有加气儿的。他下游的下游还有罐装等一系列操做。到最后装箱整个工艺才算告一段落。

上面揭示了一个最小单元的Reactor流程，源Publisher产生数据。但默认状况下，它只有Subscriber在注册（订阅）以后才会把数据推送给Subscriber执行运算符操做，中间可能伴随者背压处理。其实这些概念更重要的是理解它们。理解了Reactor的特性才能为后面更好的学习java响应式编程打好基础。
关注公众号：码农小胖哥 获取更多资讯