浅谈Spring5 响应式编程
近年来，响应式编程在开发者社区和客户中很受欢迎，由于其以声明的方式构建应用程序的能力，而不是强制，形成更加敏感和有弹性的应用。Spring5将反应系统纳入其核心框架的事实已经显示出向声明式编程的范式转变。
响应式编程管理数据生产者和消费者之间的异步数据流，它们需要以流畅的方式对数据进行响应。所以，响应式编程都是异步和事件驱动的流畅应用程序，需要少量的线程进行缩放。
响应式编程很难构建基于线程的架构，由于在基于共享可变状态、线程和锁的应用程序扩展过程中涉及到高度复杂性。
在响应式编程的上下文中，“在流中有数据时，所有事物都是流并以流畅方式行为。”
为什么是响应式编程
高层次的抽象与响应式编程导致了代码可读性的提高，因此开发人员可以主要关注定义业务逻辑的事件的相互依存性。
在高度并发的环境中，响应模式自然地适合于消息处理，这是一个常见的企业用例。
由于执行反压力的特性，响应式方法最适合控制生产者和消费者之间的流量，这将有助于避免内存不足。
对于一个或几个线程，IO绑定任务可以通过异步和非阻塞方式执行，而且不阻塞当前线程。
在高交互和实时应用程序或任何操作/事件时，都可能触发多个连接子系统的通知，在这种情况下响应式编程可以更有效的进行管理。
用于响应式编程实现的理想案例
- 大量的交易处理服务，如银行部门。
- 大型在线购物应用程序的通知服务，如亚马逊。
- 股票价格同时变动的股票交易业务。
响应流(ReactiveStreams)
“响应流”定义一个API规范，其中包含一组最小的接口，这些接口公开了定义非阻塞反压力的数据流的操作和实体的方法。
随着反压力的引入，响应流允许用户控制来自出版商的数据交换速率。
响应流APIjava.util.concurrent.flow已正式成为java9的一部分。
响应流主要用作互操作层。
Spring5提供的响应式编程
Spring-Web-Reactive模块和SpringMVC都支持相同的@Controller编程，但Spring-Web-Reactive是在Reactive和非阻塞引擎上执行的。
遵循这个文档，见：
http://docs.spring.io/spring-framework/docs/5.0.0.BUILD-SNAPSHOT/spring-framework-reference/html/web-reactive.html
Spring-Web-Reactive模块和SpringMVC共享许多通用的算法，但Spring-Web-Reactive模块已经重新定义了许多SpringMVC契约，例如HandlerMapping和HandlerAdapter，以使它们变得异步和非阻塞，以及启用响应式HTTP请求和响应（以RouterFunction和HandlerFunction的形式）。
除了现有的RestTemplate外，新的响应式WebClient也在Spring5中引入。
支持响应式编程的HTTP客户端（例如Reactor、Netty、Undertow）已经采用了一系列响应式的ClientHttpRequest和ClientHttpResponse抽象，它们将请求和响应体作为Flux
Spring5Framework引入了Reactor，作为ReactiveStreams规范的实现。
Reactor是用于在JVM上构建非阻塞应用程序的下一代Reactive库。
Reactor扩展了基本的ReactiveStreamsPublisher契约，并定义了Flux和MonoAPI类型，分别为0..N和0..1的数据序列提供声明性操作。
SpringWebReactive使用Servlet3.1提供了非阻塞I/O，并运行在Servlet3.1容器上。
SpringWebFlux提供了两种编程模型可供选择。
- 注解式控制器：这些与SpringMVC相同，在使用一些Spring-Web模块提供的附加注解的情况下。SpringMVC和WebFlux控制器都支持Reactive返回类型。另外，WebFlux还支持Reactive@RequestBody参数。
- 函数式编程模型：基于lambda的轻量级小型库，用于给出路由和处理请求的实用程序。
SpringWebReactivevs.SpringWebMVC
Spring5包含了SpringWebReactive（在spring-web-reactive模块下）和SpringWebMVC（在spring-webmvc模块下）。
虽然SpringWebReactive和SpringWebMVC模块共享了很多算法，但是由于SpringWebReactive能够在响应式的非阻塞ReactiveStreamsHTTP适配器层上运行，因此它们之间不共享代码。
SpringMVC执行需要Servlet容器，而SpringWebReactive也可以在非Servlet运行时上运行，比如在Netty和Undertow上运行。
如果对具有轻量级、函数式的Web框架的非阻塞Web栈的必要要求，并与Java8lambda或Kotlin一起使用，则应该考虑从SpringMVC应用程序切换到SpringWebReactive。
响应式编程的基本结构
这是一个2.0.0M5版本的 pom.xml，依赖于WebFiux。
org.springframework.boot spring-boot-starter-parent 2.0.0.M5 org.springframework.boot spring-boot-starter-webflux
传统方法VS.响应方法
在传统方法中，执行将被阻塞，并将一直等到您的服务执行完成为止。在下面的代码中，在第一个print语句之后，程序执行将被阻塞并等待服务执行完成。在服务执行完成后，将恢复程序执行，并执行第二个print语句。
@GetMapping("/traditional")
publicListgetAllProducts(){
System.out.println("Traditionalwaystarted");
Listproducts=prodService.getProducts("traditional");
System.out.println("Traditionalwaycompleted");
returnproducts;
}
在响应方法中，程序执行将继续，而不用等待服务执行的完成。在下面的代码中，在第一个print语句之后，第二个print语句将以非阻塞的方式执行，而无需等待服务执行的完成。Fluxstream将随着产品数据的可用性而被填充。
@GetMapping(value="/reactive",.TEXT_EVENT_STREAM_VALUE) publicFluxgetAll(){ System.out.println("ReactivewayusingFluxstarted"); Flux fluxProducts=prodService.getProductsStream("Flux"); System.out.println("ReactivewayusingFluxcompleted"); returnfluxProducts; }
ReactiveWebClient
除了现有的RestTemplate之外，Spring5还引入了ReactiveWebClient。
ClientHttpRequest和ClientHttpResponse抽象将请求和响应主体使用Flux
来自SpringCore的编码器和解码器抽象也用在客户端，用于将字节序的Flus序列化或发序列化成类型对象。
下面是一个ReactiveWebClient的示例，它调用终端并接收及处理ReactiveStreamFlux对象。
@GetMapping("/accounts/{id}/alerts")
publicFluxgetAccountAlerts(@PathVariableLongid){
WebClientwebClient=newWebClient(newReactorClientHttpConnector());
returnthis.repository.getAccount(id).flatMap(account->webClient.perform(get("/alerts/{key}",account.getKey())).extract(bodyStream(Alert.class)));
}
Spring5的局限
- 对Reactive应用程序进行故障诊断有点困难，并且你有可能在解决问题的同时，意外地阻塞了已经引入的代码。
- 大多数传统的基于Java的集成库仍然是阻塞的。
- 可用于Reactive数据存储的选项是非常有限的，少数NoSQL数据库（如MongoDB）除外。
- SpringSecurity仍然不被支持。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。