spring servlet websocket和spring webflux-websocket的不同

大家好，欢迎来到IT知识分享网。

背景

在读最新的spring5文档，会发现websocket分布在两个不同的模块：

Web Servlet模块

web Reactive模块

同一个东西为什么在两个模块都有呢？

最初怀疑是不是spring的bug，于是就针对两个不同模块的websocket进行研读，发现也不是很清晰，那么怎么弄懂他们的区别呢？

分析

因websocket是cs结构，那么我们分别从client和server端来分析，就容易看出他们的差异了。

• Web Servlet模块的 WebSocket Client

WebSocketClient client =new WebSocketClient();      

• Web Reactive模块的websocket client

       WebSocketClient client = new ReactorNettyWebSocketClient();

• Web Servlet模块的 WebSocket Server

import org.springframework.web.socket.WebSocketHandler; import org.springframework.web.socket.WebSocketSession; import org.springframework.web.socket.TextMessage; public class MyHandler extends TextWebSocketHandler { @Override public void handleTextMessage(WebSocketSession session, TextMessage message) { // ... } }

• Web Reactive模块的websocket server

class ExampleHandler implements WebSocketHandler { @Override public Mono<Void> handle(WebSocketSession session) { Flux<WebSocketMessage> output = session.receive() .doOnNext(message -> { // ... }) .concatMap(message -> { // ... }) .map(value -> session.textMessage("Echo " + value)); return session.send(output); } }

从上面可以看到，

Web Servlet模块的 WebSocket的client使用的是普通的WebSocketClient，

而Web Reactive模块的websocket的client利用了ReactorNettyWebSocketClient的Reactive特性。

Web Servlet模块的 WebSocket的server使用的是普通的WebSocketHandler，

而Web Reactive模块的websocket的server利用了Flux的Reactive特性。

总结

Web Servlet模块的 WebSocket的client和server使用的是阻塞式的。

Web Reactive模块的websocket的client和server使用的是非阻塞式的。