响应式编程以及 Spring Boot Webflux 快速入门

什么是响应式编程

在计算机中，响应式编程或反应式编程（英语：Reactive programming）是一种面向数据流和变化传播的编程范式。这意味着可以在编程语言中很方便地表达静态或动态的数据流，而相关的计算模型会自动将变化的值通过数据流进行传播。

例如，在命令式编程环境中，a=b+c表示将表达式的结果赋给a，而之后改变b或c的值不会影响a。但在响应式编程中，a的值会随着b或c的更新而更新。

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

设想一个场景，从底层数据库驱动，经过持久层、服务层、MVC层中的model，到用户的前端界面的元素，全部都采用声明式的编程范式，从而搭建一条能够传递变化的管道，这样我们只要更新一下数据库中的数据，用户的界面上就相应的发生变化，从而无需前端轮询才能获取到最新的数据。

简单来讲，我们以前写的程序是阻塞式的，当一个请求任务过来时，线程会阻塞，等到这个任务完成后再返回出去。而响应式编程则是一个请求任务过来时，会有其他的线程去做处理，当任务执行结束后再异步的通知回去。

为什么要使用响应式编程

在如今互联网时代的大背景下，Web应用通常要面对高并发、海量数据的挑战，性能从来都是必须要考量的核心因素。

阻塞便是性能杀手之一。

多数人不认为阻塞是一个比较大的问题，至少觉得除了网络I/O之外，读写文件和数据库还是很快的，许多人也一直在写阻塞的代码。

那么 I/O 操作具体有多慢？

CPU眼中的时间

CPU绝对称得上是“闪电侠”，因为它们做事都有自己的一套时钟。我们故事的主人公是一个主频为2.5GHz的CPU，如果它的世界也有“秒”的概念，并且它的时钟跳一下为一秒，那么在CPU（CPU的一个核心）眼中的时间概念是啥样的呢？

CPU先生所在的组是硬件部计算组。对它来说，与其一起紧密合作的几个小伙伴还能跟的上它的节奏：

• CPU先生很利索，只需要一秒就可以完成一个指令，复杂的动作可能需要多个指令。
• 好在“贴身秘书”一级缓存反应比较快，能够秒懂CPU先生的意思。
• 来自“秘书组”的二级缓存虽然要十几秒才能“get”到CPU先生的点，但也不算太迟钝。
• 和内存组的合作已经习以为常了，跟内存请求的数据通常要4-5分钟才能找到（内存寻址），不过也还好啦，毕竟一级缓存那里能拿到80%想要的数据，其余的二级缓存也能搞定一大部分，不怎么耽误事儿。

CPU先生是典型的工作狂，任务多的时候，通宵达旦也毫无怨言，但是有什么事情让它等，那简直要他命了。恰恰一起共事的其他组（尤其是I/O组的磁盘和网卡）相对来说那效率是低的离谱啊：

• 关于I/O组的同事，CPU先生已经抱怨很久了，每次找SSD要东西，都要花费4-5天才能找到（寻址），等到数据传送过来，几周都过去了。机械磁盘更是过分地离谱，跟他要个数据，竟然要平均花费10个月才能找到，如果要读取1M的数据，竟然要20个月！这种员工怎么还不下岗？！
• 关于网卡，CPU先生知道它们也尽力了，毕竟万兆网络成本颇高。与机房内的其他小伙伴们用千兆网络互相沟通也算顺畅，给另一台机器的CPU朋友发送1K的书信，最快七八个小时就可以送过去了。但是1K的书信经过层层包裹，实际也写不了多少话。更要命的是，网卡们的沟通手续繁杂，每次网络沟通前的 “你好能听到我吗？——我能听到，你那边能听到我吗？——我也能听到你，那我们开始吧！” 这样的握手确认都要花掉很长的时间，不过不能当面沟通，也只能这样了。这还好，最恐怖的是与其他城市的小伙伴沟通，有时候传递消息要花费好几年呢！

由此可见，对于CPU先生来说，想要让工作充实起来实在不容易，不过多亏了内存组的小伙伴帮忙分批缓存往返于I/O组的数据，矛盾才有所缓解。

这个图只能明显看出涉及I/O的时间条，我们转换成对数刻度的图看一下：

这个图并不是直观的比例，横轴上每个刻度是一个数量级，可见I/O的速度与CPU和内存相比是要差几个数量级的。由此可见，对于大型高并发场景下的Web应用，缓存有多重要，更高的缓存命中率就意味着性能。

• 并行化：使用更多的线程和硬件资源
• 异步化：基于现有的资源来提高执行效率

基础概念

在介绍主题之前先普及几个概念：

Backpressure（背压）

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

Reactive Streams（响应式流）

一般由以下组成：

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

Mono 和 Flux

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

Spring Webflux

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

Spring Boot Webflux有两种编程模型实现，一种类似Spring MVC注解方式，另一种是使用其功能性端点方式。

适用性

一图就很明确了，WebFlux和MVC有交集。但是注意：

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

内嵌容器

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

但是要注意，必须是Servlet 3.1+容器，如Tomcat、Jetty；或者非Servlet容器，如Netty和Undertow。

数据库

支持reactive编程的数据库只有MongoDB, Redis, Cassandra, Couchbase

快速上手

工程依赖

代码清单：spring-boot-webflux/pom.xml

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

Service类

代码清单：spring-boot-webflux/src/main/java/com/springboot/springbootwebflux/service/impl/UserServiceImpl.java

@Service
public class UserServiceImpl implements UserSerivice {

    private static Map<Long, User> map = new HashMap<>();

    static {
        map.put(1L, new User(1L, "www.appblog.cn", 18));
        map.put(2L, new User(2L, "APP开发技术博客", 28));
    }

    @Override
    public Mono<User> getUserById(Long id) {
        return Mono.just(map.get(id));
    }
}

Controller类

代码清单：spring-boot-webflux/src/main/java/com/springboot/springbootwebflux/controller/UserController.java

@RestController
public class UserController {

    @Autowired
    UserSerivice userSerivice;

    @GetMapping("/getUserById/{id}")
    public Mono<User> getUserById(@PathVariable Long id) {
        return userSerivice.getUserById(id);
    }
}

通过上面的示例可以发现，开发模式和之前Spring MVC的模式差别不是很大，只是在方法的返回值上有所区别。