本文主要是介绍第11章 开发反应式API,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
1. 使用Spring WebFlux
时间轮循机制(event looping)
异步Web框架借助事件轮训机制能够以更少的线程处理更多的请求
非阻塞、异步的Web框架
1.1 Spring WebFlux简介
1.2 编写反应式控制器
返回单个值
使用RxJava类型
Observable
Single
Completable 等价于Reactor中的Mono
Flowable
实现输入的反应式
2.定义函数式请求处理器
使用Spring的函数式编程模型编写API会涉及4个主要的类型:
•RequestPredicate:声明要处理的请求类型。
•RouterFunction:声明如何将请求路由到处理器代码中。
•ServerRequest:代表一个HTTP请求,包括对请求头和请求体的访问。
•ServerResponse:代表一个HTTP响应,包括响应头和响应体信息。
3.测试反应控制器
WebTestClient
3.1 测试GET请求
3.2 测试POST请求
3.3 使用实时服务器进行测试
4.反应式消费REST API
WebClient
可以作为RestTemplate的反应式版本
能够让我们请求外部API时发送和接收反应式类型
有一个流畅(fluent)的构建者风格接口
WebClient的通用使用模式如下:
•创建WebClient实例(或注入WebClient bean);
•指定要发送请求的HTTP方法;
•指定请求中URI和头信息;
•提交请求;
•消费响应。
4.1 获取资源
bodyToMono()
bodyToFlux()
非常重要的一点就是要订阅结果所形成的Flux,否则请求将始终不会发送。
使用基础URI发送请求
因为WebClient已经创建好了,所以我们可以通过get()方法直接使用它。对于URI来说,我们只需要调用uri()指定相对于基础URI的相对路径即可。
对长时间运行的请求进行超时处理
timeout()方法
4.2 发送资源
body()方法
syncBody()
4.3 删除资源
delete()方法
4.4 处理错误
onStatus()
onStatus()接受两个函数:
一个断言函数用来匹配HTTP状态;
另一个函数会得到ClientResponse对象,并返回Mono。
WebClientResponseException最大的问题在于它无法明确指出导致Mono失败的原因是什么
4.5 交换请求
exchange()和retrieve()
差异和相似
5. 保护反应式Web API
Servlet Filter
Spring Security
5.1 配置反应式Web应用的安全性
WebSecurityConfigurerAdapter配置类
@EnableWebSecurity注解
HttpSecurity对象
Ant风格的通配符
@EnableWebFluxSecurity注解
ServerHttpSecurity对象
pathMatchers()
5.2 配置反应式的用户详情服务
这篇关于第11章 开发反应式API的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!