spring react_使用Spring WebFlux构建React性REST API –第2部分

蔚落 2023-02-25 03:48 31阅读 0赞

spring react

在上一篇文章的续篇中，我们将看到[React式流规范][React]及其实现之一，称为[Project Reactor][] 。 React流规范定义了以下接口。 让我们看看这些接口的细节。

*  **发布者→**发布者是潜在数量不受限制的序列元素的提供者，可按其订阅者的要求发布它们

public interface Publisher<T> {
        public void subscribe(Subscriber<? super T> s);
    }

*  **订户→**订户是数量可能不受限制的已排序元素的使用者。

public interface Subscriber<T> {
        public void onSubscribe(Subscription s);
        public void onNext(T t);
        public void onError(Throwable t);
        public void onComplete();
    }

*  **订阅→**订阅代表订阅者订阅发布者的一对一生命周期。

public interface Subscription {
        public void request(long n);
        public void cancel();
    }

*  **处理器→**处理器代表一个处理阶段-既是订户又是发布者，并且服从两者的合同。

React流规格的类图如下。

![format_png][]

React性流规范具有许多实现。 [Project Reactor][]是实现之一。 React堆完全无阻塞，可提供有效的需求管理。 Reactor提供了两个React式和可组合的API，即[Flux \[N\]][Flux _N]和[Mono \[0 | 1\]][Mono _0 _ 1] ，它们广泛实现了[Reactive Extensions][] 。 Reactor提供了用于HTTP（包括Websocket），TCP和UDP的非阻塞，反压就绪的网络引擎。 它非常适合微服务架构。

*  **Flux→**这是具有rx运算符的Reactive Streams [`Publisher`][Publisher] ，它发出0到N个元素，然后完成（成功或有错误）。 助焊剂的大理石图如下所示。

![format_png 1][] 图片来源： [https][Project Reactor] : [//projectreactor.io][Project Reactor]

*  **Mono** **→**它是具有基本rx运算符的Reactive Streams [`Publisher`][Publisher] ，可通过发出0到1元素或出现错误来成功完成。 Mono的大理石图如下所示。

![format_png 2][] 图片来源： [https][Project Reactor] : [//projectreactor.io][Project Reactor]

由于Spring 5.x随Reactor实施一起提供，因此，如果我们要使用带有Spring servlet堆栈的命令式编程来构建REST API，它仍然支持。 下图说明了Spring如何支持React式和servlet堆栈实现。

![format_png 3][] 图片来源：spring.io

在接下来的文章中，我们将看到带有React式API的示例应用程序。 在那之前， ***快乐学习！！***

> 翻译自: [https://www.javacodegeeks.com/2020/06/build-reactive-rest-apis-with-spring-webflux-part2.html][https_www.javacodegeeks.com_2020_06_build-reactive-rest-apis-with-spring-webflux-part2.html]

spring react

[React]: https://www.reactive-streams.org/
[Project Reactor]: https://projectreactor.io/
[format_png]: /images/20230209/9ff9169183e348a3b22655e89b5fb464.png
[Flux _N]: https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html
[Mono _0 _ 1]: https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html
[Reactive Extensions]: http://reactivex.io/
[Publisher]: https://www.reactive-streams.org/reactive-streams-1.0.3-javadoc/org/reactivestreams/Publisher.html?is-external=true
[format_png 1]: /images/20230209/459d37dc8fdd4989b138c480a0112576.png
[format_png 2]: /images/20230209/57d639da94b345578356f296071d5590.png
[format_png 3]: /images/20230209/38f671e681434ab4bf163d40ea1b2820.png
[https_www.javacodegeeks.com_2020_06_build-reactive-rest-apis-with-spring-webflux-part2.html]: https://www.javacodegeeks.com/2020/06/build-reactive-rest-apis-with-spring-webflux-part2.html