首页 > 其他分享> 文章详细

0009 - WebFlux

2019-02-28 17:02:59 阅读：260 来源： 互联网

标签：spring Spring WebFlux 0009 springframework org import

1、概述

　　大多数场景使用MVC都是阻塞式的，WebFlux使用的场景是异步非阻塞的

　　响应式编程是基于异步和事件驱动的非阻塞程序，只是垂直通过在JVM内启动少量线程扩展，而不是水平通过集群扩展。

　　Spring Boot2.x 包含了一个新的spring-webflux模块，该模块包含对响应式HTTP和webSocket交互等程序的支持。

2、优势

微服务架构越来越火，Spring Boot是一大趋势，所以Spring Cloud是基于Spring Boot的，所以学好Spring Boot WebFlux会受益匪浅
从编程来讲，虽然阻塞式编程是避免不了的，但是Reactive编程在大多数场景，能够提高资源利用率。所以，学习WebFlux，尤其某些IO密集型场景很刚需

3、前置概念

　　3.1、Reactive Streams（响应式流） JVM中面向流库标准和规范

处理可能午线数量的元素
按顺序处理
组件之间异步传递
强制性非阻塞背压

　　一般由以下组成

发布者：发布元素到订阅者
订阅者：消费元素
订阅：在发布者中，订阅被创建时，将与订阅者共享
处理器：发布者和订阅者之间的处理数据

　　3.2、Backpressure 背压

　　背压是一种常用策略，使得发布者拥有无限制的缓冲区存储元素，用于确保发布者发布元素太快时，不会去压制订阅者。

4、响应式编程

　　有了ReactiveStreams这种标准和规范，利用规范可以进行响应式编程。那再了解下什么是ReactiveProgramming响应式编程。响应式编程是基于异步和事件驱动的非阻塞程序，只是垂直通过再JVM内启动少量线程扩展，而不是水平通过集团扩展。这就是一个编程范例，具体项目中如何体现呢？

　　响应式项目编程实战中，通过基于Reactive Streams规范实现的框架Reactor去实战。Reactor一共提供两种响应式API：

Mono：实现发布者，并返回0或1个元素
Flux：实现发布者，并返回N个元素

　　Spring Boot WebFlux就是基于Reactor实现的。Spring Boot 2.0包括一个新的spring-webflux模块。该模块包含对响应式HTTP和WebSocket客户端的支持，以及对REST，HTML和WebSocket交互式程序的支持。一般来说，SpringMVC用于同步处理，Spring WebFlux用于异步处理。

　　Spring Boot WebFlux由两种编程方式，一种类似Spring MVC注解方式，另一种是使用其功能性端点方式

5、特性

响应式API

　　　　Reactor框架是Spring Boot WebFlux响应库依赖，通过Reactive Streams并与其他响应库交互。提供两种响应式API：Mono、Flux。一般是将Publisher作为输入，在框架内部转换成Reactor类型并处理逻辑，然后返回Flux和Mono作为输出。

编程模型

　　Spring 5 Web模块包含了Spring webFlux的HTTP抽象。类似Servlet API，WebFlux提供WebHandler API去定义非阻塞API抽象接口。可以选择以下两种编程模型实现。

注解控制层：和Spring MVC 保持一致，WebFlux也支持响应式@RequestBody注解。
功能性端点：基于Lambda轻量级编程模型，用来路由和处理清楚的小工具。和上面最大的区别就是，这种模型，全程控制了请求-响应的生命流程。

适用性

　　一图就很明确了，WebFlux 和 MVC 有交集，方便大家迁移。但是注意：

　　MVC 能满足场景的，就不需要更改为 WebFlux。
　　要注意容器的支持，可以看看下面内嵌容器的支持。
　　微服务体系结构，WebFlux 和 MVC 可以混合使用。尤其开发 IO 密集型服务的时候，选择 WebFlux 去实现。

内嵌容器

　　跟Spring Boot大框架一样启动应用，但WebFlux默认是通过Netty启动，并且自动设置了默认端口为8080.另外还提供了对Jetty、Undertow等容器的支持。开发者自行在添加对应的容器Starter组件依赖，即可配置并使用对应内嵌容器实例。

Starter组件

　　Spring Boot WebFlux提供了很多“开箱即用”的Starter组件。Starter组件是被加载在应用中的Maven依赖项。只需要在Maven配置中添加对应的依赖配置，即可使用对应的Starter组件，例如：添加spring-boot-starter-webflux依赖，就可以用于构建响应式API服务，其包含了Web Flux和Tomcat内嵌容易等。

6、组件

　　Spring Boot WebFlux官方提供了很多的Starter组件，每一个模块会有多种技术实现选型支持，来实现各种复杂的业务需求

web：spring WebFlux
模板引擎：Thymeleaf
存储：Redis、MongoDB、Cassandra
内嵌容器：Tomcat、Jetty、Undertow

7、HelloWorld

7.1、新建maven 工程，配置POM依赖

<dependencies>
　　<dependency>
　　　　<groupId>org.springframework.boot</groupId>
　　　　<artifactId>spring-boot-starter-webflux</artifactId>
　　</dependency>

　　<dependency>
　　　　<groupId>org.springframework.boot</groupId>
　　　　<artifactId>spring-boot-starter-test</artifactId>
　　　　<scope>test</scope>
　　</dependency>
　　<dependency>
　　　　<groupId>io.projectreactor</groupId>
　　　　<artifactId>reactor-test</artifactId>
　　　　<scope>test</scope>
　　</dependency>
</dependencies>

spring-boot-starter-webflux 依赖，是我们核心需要学习 webflux 的包，里面默认包含了 spring-boot-starter-reactor-netty 、spring 5 webflux 包。也就是说默认是通过 netty 启动的。

reactor-test、spring-boot-starter-test 两个依赖搭配是用于单元测试。

spring-boot-maven-plugin 是 Spring Boot Maven 插件，可以运行、编译等调用。

7.2、编写处理器类 Handler

新建包 org.spring.springboot.handler ，作为编写功能处理类。新建城市（City）例子的处理类 CityHandler，代码如下：

import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;

@Component
public class CityHandler {

　　public Mono<ServerResponse> helloCity(ServerRequest request) {
　　　　return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
　　　　　　.body(BodyInserters.fromObject("Hello, City!"));
　　}
}

ServerResponse 是对响应的封装，可以设置响应状态，响应头，响应正文。比如 ok 代表的是 200 响应码、MediaType 枚举是代表这文本内容类型、返回的是 String 的对象。

这里用 Mono 作为返回对象，是因为返回包含了一个 ServerResponse 对象，而不是多个元素。

7.3、编写路由器类 Router

新建 org.spring.springboot.router 包，作为编写路由器类。新建城市（City）例子的路由类 CityRouter，代码如下：

import org.spring.springboot.handler.CityHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.server.RequestPredicates;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerResponse;

@Configuration
public class CityRouter {

@Bean
public RouterFunction<ServerResponse> routeCity(CityHandler cityHandler) {
　　return RouterFunctions
　　　　.route(RequestPredicates.GET("/hello")
　　　　　　.and(RequestPredicates.accept(MediaType.TEXT_PLAIN)),
　　　　　　cityHandler::helloCity);
　　}

}

RouterFunctions 对请求路由处理类，即将请求路由到处理器。这里将一个 GET 请求 /hello 路由到处理器 cityHandler 的 helloCity 方法上。跟 Spring MVC 模式下的 HandleMapping 的作用类似。

RouterFunctions.route(RequestPredicate, HandlerFunction) 方法，对应的入参是请求参数和处理函数，如果请求匹配，就调用对应的处理器函数。

7.4、启动运行项目，输入http://localhost:8080/hello

标签：spring,Spring,WebFlux,0009,springframework,org,import
来源： https://www.cnblogs.com/Pibaosi/p/10451379.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

0009 - WebFlux