一文搞懂响应式编程

哈喽，大家好，我是指北君。,相信响应式编程经常会在各种地方被提到。本篇就为大家从函数式编程一直到Spring WeFlux做一次简单的讲解，并给出一些示例，希望大家可以更好的理解响应式编程，可以在合适的时机运用到实际项目中。,了解响应式编程，首先我们需要了解函数式操作和Stream的操作，下面我们简单的复习一下喽。,函数式接口中,我们先来回顾一下Java中的函数式接口。常见的有以下几种,上面的简单函数式接口示例如下：,其执行结果如下：,对Stream进行操作，主要有几个关键点：,创建流的示例：,简单的流处理示例：,响应式编程会用到一个发布者和一个订阅者，然后通过订阅关系完成数据流的传输。订阅关系中可以处理一些背压问题，即调节消费者与生产者之间的供需平衡，让整个程序达到最大效率。,,Java9中java.util.concurrent.Flow接口提供响应式流编程类似的功能。,下面我们实现一个基于Java 响应式编程的示例：,其中有三个简单步骤：,消费者全部代码如下：,其中onSubscribe方法表示建立订阅关系,onNext接受数据，并请求生产者的数据。,onError，onComplete则是error或者完成之后的处理方法。,带有中间处理器的响应式流,Reactive Stream 通常会基于如下的模型：,,下面我们实现一个带有中间处理功能的响应式模型：,下面的Processor 既有发布者，又有订阅者：,如上中间处理器订阅发布者， 同时消费者再订阅中间处理器。中间处理器也可以调节发布订阅的生产消费速率。,通过上述生产者-> 中间处理器->消费者， 可以将生产者生产的数据全部变成大写，然后再发送给最终的消费者。,以上式Java中的reactive 编程示例。Java会不同线程来分别处理消费者与生产者的消息处理,Reactor中两个比较关键的对象式Flux和Mono， 整个Spring的响应式编程均式基于projectreactor项目。Reactor是响应式编程的依赖，主要是基于JVM构建非阻塞程序。,根据Reactor的介绍，此类响应式编程的的三方库（Reactor）主要是解决一些JVM经典异步编程中的一些缺点，并且还可以专注于一些新的特性，如下：,其中有这么一段解释，可以形象的说明响应式编程。,Reactive的程序可以想象成车间的流水线，reactor既是流水线上的传送带，又是处理工作站。原料从一个原始的生产者出发，最终成为产品被推总给消费者。,下面我们介绍一下Flux和Mono。,在Reactor中Flux和Mono均是Publisher，即生产者。两者也有不同。Flux对象表示0到N个异步的响应序列，而Mono只代表0个（empty）或者1个结果。,Reactor官网上介绍的Flux示意如下：,,Mono示意如下：,,我们也可以单独引用其依赖。,使用maven依赖,Mono创建,分别创建空Mono和一个包含一个String的Mono，并由消费者消费打印。,Flux创建,Flux创建有如下的一些方法，,下面式一些Java代码示例,我们再举一个generate的例子,如上代码所示，generate需要一个Callable参数，而且是supplier （即没有输入值，只有一个输出）,另一个参数是BiFunction （前面我们也介绍过，需要两个输入值，一个输出值）。BiFunction中的其中一个输入值是SynchronousSink，下面我们给出一个generate创建Flux的示例。,下面我们在看一个Flux嵌套处理示例：,需求：将字符串去空格，并去重，然后排序输出。,以上就是Flux和Mono的一些简单介绍，同时Ractor也支持JDK中的FlowPubliser 和FlowSubscriber与 Reactor中的publisher, subscriber的适配等.,SpringBoot 2之后支持的Reactive响应式编程。,关于Reactive技术栈和经典的Servlet技术栈对比，Spring官网的这张图比较清晰。,,Spring响应式编程主要依赖于Reactor第三方库，即上面讲的Flux和Mono的库。,WebFlux主要有以下几个要点：,Spring WebFlux示例,下面我们给出几个SpringBoot 的响应式web示例。,可以去https://start.spring.io/ 新建webflux的项目也可以。,项目中的主要依赖就是spring-boot-starter-webflux,基于注解的WebFlux：,以下是一个最简单的基于注解的WebFlux,基于函数式编程的WebFlux:,创建RouterFunction，将其注入到Spring中即可。,Flux与Mono的响应式编程延迟示例,下面我们编写一段返回Mono的响应式Web服务。,使用postman请求如下， 5秒钟后返回数据。后台却在5秒中之前已经处理完整个方法。,,后台打印日志：,,再看一组Flux,此次使用谷歌浏览器请求此服务：,可以发现每隔一秒就会有一条消息被生产出来。,,后台完成时间同样是在一开始就完成整个方法：,,通过上述对Flux 与 Mono的例子，可以好好体会一下响应式编程。,本篇回顾了函数式编程，Stream操作等，然后再举例讲了Java中的Reactive编程示例， 同时也给处理Reactor三方库的Flux于Mono的示例。,最后使用了SpringBoot WebFlux 创建简单的响应式web服务。希望能让大家更好的理解响应式编程。