第十九节：学习WebFlux与前端响应式-非阻塞-流式通讯（自学Spring boot 3.x的第四天）

这节记录下如何使用Springboot中的WebFlux的Mono和Flux实现后台向前端的数据传输。

适用场景：需要向某个url请求数据，但是对方url返回的是流式数据，异步的。这个时候传统的restful响应已经不适用了，需要用到webclient来进行处理，而WebFlux刚好集成了webclient。

在webclient中，有2种重要的数据结构，一个是Mono，一个是Flux。

Mono适合一次性数据，而Flux适合多次数据。这样的话，其实就是说：Flux适用于流式数据传输。

为了节省篇幅，本篇主要讲Flux使用方法，Mono和Flux使用方法基本一致。

第一步：

先在pom中集成webflux所需要的依赖库。

 <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-webflux --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId><version>3.3.3</version></dependency>

第二步：

Controller层

/*** 通过返回Flux<String>>实现非阻塞异步请求，优先此方法* 通过此方法向客户端发送字符串* @param messageId* @return* @throws IOException*/@GetMapping("/chatsse")public Flux<String> chatSSE(@RequestParam String messageId) throws IOException {return articleService.sendMessage(content);}

第三步：

Service层：

public Flux<String> sendMessage(String prompt) throws IOException {return webClient.post().uri(xxx).body(BodyInserters.fromValue(jsonStr)).retrieve().bodyToFlux(DataBuffer.class).map(response -> {try {return "测试";} catch (IOException e) {throw new RuntimeException(e);}});}

上面代码可以实现向客户端发送流式数据。

代码分析：

上面的webClient.post返回的是一个Flux<String>对象，如果要实时处理数据的话，可以调用它的subscribe和doNext方法，不过这2个都不会影响真实的数据传输结果，只能作为调试使用。（个人理解，不一定正确）。也就是说不管你在这里面写的天花地坠，传输给前端的数据不会改变。传输的。

仅观察数据，不对数据本身起到影响怎么做？可以用doNext或者订阅方法subscribe。

例如：下面的doNext方法可以用于调试观察数据。

      .map(response -> {try {return extractResponse(response);} catch (IOException e) {throw new RuntimeException(e);}}).doOnNext(s->{System.out.println(s);});

怎么对传输的流数据进行处理？关键看map方法。

如果要进行数据处理，得先告知flux返回的对象，.需要用到bodyToFlux(DataBuffer.class)。

其次再使用map进行数据转换。把DataBuffer转换为了String。下面的response对象跟bodyToFlux(DataBuffer.class)有关系，这里声明的是DataBuffer，所以response在这里实际上是DataBuffer对象。可以在map方法里使用各种各样的方式处理数据流。

      .map(response -> {try {return extractResponse(response);} catch (IOException e) {throw new RuntimeException(e);}});//调用这个函数会自动输出，而且仅执行一次