Spring 5 新增全新的reactive web框架：webflux

Spring 5发布了一个非常重要的模块，名字叫做：spring-webflux。该模块平级的就是spring-webmvc。

 

 

具体能做什么呢？自然是mvc不擅长的事情了。自然是人们一直希望实现，但总是比较困难的功能了。

先来看看flux是什么意思？

 

没错，是“流”的意思：stream, flux, rate, class, blast, grade。

具体做什么事情呢？就是webflux可以让你在web应用下也可以体验tcp长连接传输流数据的快感了。这在过去我们都是通过一些奇技淫巧才能实现的能力。

官方说法就是webflux是一个完全的reactive并且非阻塞的web框架。

 

什么是响应式编程？简单点说就是非阻塞，异步的而且是事件驱动的，只需要少量的线程，在一个jvm中垂直扩展而已，而不用通过集群的水平扩展方式。

 

webmvc与webflux

webmvc是servlet stack  based,而webflux是reactive stack based。

 

 

Spring MVC的大名是响当当的，但是可能让你惊奇的是，居然没有给这个名字实际的项目或独立的分配。相反，它是Spring Framework中的一个模块，叫做spring-webmvc。这真的是一个让人觉得略怪的事情。居然不是一个顶级项目，而是在org.springframework.web.servlet下。好了，不纠结这些细节了。

 

Spring reative Web框架，是5.0中的新功能，是一个完全的reactive并且非阻塞的web框架。它适合处理那种event-loop 风格的事情，也就是事件驱动的。它支持Servlet容器（Tomcat，Jetty，Servlet 3.1+），也支持非Servlet的运行时（比如：Netty，Undertow），因为它的基础不是Servlet API，而是构建在Reactive Streams和Reactor项目之上的。

 

在5中，spring-web-reactive模块被改名为spring-webflux 。新模块中的顶级包是org.springframework.web.reactive。

 

哈哈，既然mvc就没有一个顶级的待遇，现在webflux也一样，都在web下，一个叫servlet，一个叫reactive。

 

你可以这样理解：就是servlet和reative是内部的真实情况，而webmvc和webflux则是为了迎合和抢占业界的一些主流概念。一个务实一个务虚。

 

SSE

另外还有一个概念就是SSE。就是Server-sent events的缩写。这是个什么鬼。其实就是个概念。或者是一个标准。就是把数据从web服务端传输到客户端的一种做法。顾名思义：服务端发送给客户端的事件。神奇吧。

 

你就先这么理解吧。一会我们会上代码，而且会具体演示效果。

 

实现和演示

 

铺垫

 

我们会先通过传统的webmvc的方式来实现reactive效果。然后我们会使用spring 5 的 webflux 再来实现一次reactive效果。

 

传统的实现方式

 

先通过spring initializr新建一个普通的spring boot应用。

 

pom

然后在pom中添加一个web依赖和一个integration-file依赖（稍后会用到）：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-file</artifactId> </dependency>

代码

 

/*** @author hezhuofan*/ @SpringBootApplication @RestController public class RegularSseApplication {private final Map<String, SseEmitter> sses = new ConcurrentHashMap<>();@Beanpublic IntegrationFlow inboundFlow(@Value("${input-dir:file://${HOME}/Desktop/in}") File in) {System.out.println(in.getAbsolutePath());return IntegrationFlows.from(Files.inboundAdapter(in).autoCreateDirectory(true), poller -> poller.poller(spec -> spec.fixedRate(1000L))).transform(File.class, File::getAbsolutePath).handle(String.class, (path, map) -> {sses.forEach((key, sse) -> {try {sse.send(path);} catch (Exception ex) {throw new RuntimeException();}});return null;}).channel(filesChannel()).get();}@BeanSubscribableChannel filesChannel() {return MessageChannels.publishSubscribe().get();}@GetMapping("/files/{name}")SseEmitter file(@PathVariable String name) {SseEmitter sseEmitter = new SseEmitter(60 * 1000L);sses.put(name, sseEmitter);return sseEmitter;}public static void main(String[] args) {SpringApplication.run(RegularSseApplication.class, args);} }

 

基本思路

 

就是我们通过intergration file来把本地的一个指定目录作为一个流绑定到指定的url :/files/${name}。

 

我们在桌面新建一个in目录，in目录新建文件。这时候启动的web server端就会向客户端返回 该文件的 绝对路径，相当于通知给客户端。

 

演示

 

 

左边是服务端，右边是客户端。服务端in目录下新建了文件，服务端检测到后，立马把新建的文件的绝对路径发送给了客户端。

 

新建文件命令：

touch fileName

客户端发送请求命令：

curl http://localhost:9995/files/spring

 

webflux 实现

 

pom

之前是web，现在换成了webflux。其他没变。

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

值得注意的是，我们使用的是spring boot 2.0.0-SNAPSHOT版。因为flux是spring 5的内容。

 

<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.0.BUILD-SNAPSHOT</version><relativePath/> <!-- lookup parent from repository --> </parent>

代码

 

@SpringBootApplication @RestController public class SpringSamplesWebfluxApplication {@GetMapping(value="files/{name}",produces = MediaType.TEXT_EVENT_STREAM_VALUE)Flux<String> files(@PathVariable String name) {return Flux.create((FluxSink<String> sink) -> {FluxSink<String> serialize = sink.serialize();MessageHandler handler = msg -> serialize.next(String.class.cast(msg.getPayload()));serialize.setCancellation(() -> filesChannel().unsubscribe(handler));filesChannel().subscribe(handler);});}@Beanpublic IntegrationFlow inboundFlow(@Value("${input-dir:file://${HOME}/Desktop/in}") File in) {System.out.println(in.getAbsolutePath());return IntegrationFlows.from(Files.inboundAdapter(in).autoCreateDirectory(true), poller -> poller.poller(spec -> spec.fixedRate(1000L))).transform(File.class, File::getAbsolutePath).channel(filesChannel()).get();}@BeanSubscribableChannel filesChannel() {return MessageChannels.publishSubscribe().get();}public static void main(String[] args) {SpringApplication.run(SpringSamplesWebfluxApplication.class, args);} }

 

演示

 

为了区分是不同的实现，我们使用了不同的端口。

 

左边是服务端，右边是客户端。服务端in目录下新建了文件，服务端检测到后，立马把新建的文件的绝对路径发送给了客户端。

 

新建文件命令：

touch fileName

 

客户端发送请求命令：

curl http://localhost:8765/files/spring

 

总结

以上只是简单的介绍了下来龙去脉，并且对基于web的sse实现做了演示，以及对基于flux实现的演示。webflux是一个全新的reactive非阻塞web框架。与webmvc在同一个层次。对于微服务下的IO密集型的service来说，webflux也许是一个不错的尝试或选择吧。

总结

以上是生活随笔为你收集整理的Spring 5 新增全新的reactive web框架：webflux的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。