响应式编程以及反应式编程框架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中(这里还定义了用户角度的业务逻辑)。还拿放水举例,如果我们放水不是为了单纯放水而是造肥宅快乐水。这样就不是一个人接水了,中间加入了原浆,下一个接的人接到了原浆勾兑水,那么这个人充当了最开始的消费者,但是注意他不是最终的消费者。他的下游还有加气儿的。他下游的下游还有罐装操作。到这里整个工艺才算告一段落。这里你也更能看清backpressure(背压)操作的作用,可能开始是大桶,到罐装流程开始小瓶子了。通过背压来控制出水的速率。
最上面揭示了一个最小单元的Reactor流程,源Publisher产生数据。但默认情况下,它只有Subscriber在注册(订阅)之后才会把数据推送给Subscriber执行运算符操作,中间可能伴随者背压处理。其实这些概念更重要的是理解它们。理解了Reactor的特性才能为后面更好的学习java响应式编程打好基础。
转载于:https://my.oschina.net/10000000000/blog/3097949
- 点赞
- 收藏
- 分享
- 文章举报
- Linux C开发 动态链接库以及静态链接库编程简单介绍
- SimpleCommand(一) 框架介绍以及简单使用
- 【COCOS2DX-LUA 脚本开发之六】利用Lua强转函数解决使用CCNode报错或无法正常使用以及简单介绍 quick-cocos2d-x 与 OpenQuick 两款Lua免费开源框架
- 【COCOS2DX-LUA 脚本开发之六】利用Lua强转函数解决使用CCNode报错或无法正常使用以及简单介绍 quick-cocos2d-x 与 OpenQuick 两款Lua免费开源框架
- 【Cuda并行编程之一】二分查找的探究以及Cuda的简单实现&&相关面试题介绍
- IOS学习之 网络编程(10)--简单介绍ASI框架的使用
- J2EE 三大框架的简单介绍以及他们的下载地址
- Python开源抓取框架简单介绍,以及安装(ubuntu)常见问题解决
- 【COCOS2DX-LUA 脚本开发之六】利用Lua强转函数解决使用CCNode报错或无法正常使用以及简单介绍 quick-cocos2d-x 与 OpenQuick 两款Lua免费开源框架
- 【Node.js Koa框架入门】(一)Koa 框架介绍以及环境搭建、简单使用
- 利用Lua强转函数解决使用CCNode报错或无法正常使用以及简单介绍 quick-cocos2d-x 与 OpenQuick 两款Lua免费开源框架
- MVC的简单介绍以及IDEA+Maven 环境下的SSM框架整合
- SSM框架简单介绍以及maven环境搭建
- 操作xml|json|以及框架的简单介绍
- Linux C语言开发 动态链接库以及静态链接库编程简单介绍
- SimpleCommand框架介绍以及简单使用(一)
- 【Cuda并行编程之一】二分查找的探究以及Cuda的简单实现&&相关面试题介绍
- 介绍Struts 1.1 框架基本原理,以及介绍Struts 1.1 安装和一个简单的例子。
- 基于.NET CORE微服务框架 -surging的介绍和简单示例 (开源)
- ActiveMQ简单介绍以及安装