點擊查看官網(wǎng)
- Spring-webflux官網(wǎng)界面
注意官網(wǎng)這樣的一段話：
Reactor is the reactive library of choice for Spring WebFlux. It provides the Mono and Flux API types to work on data sequences of 0..1 (Mono) and 0..N (Flux) through a rich set of operators aligned with the ReactiveX vocabulary of operators. Reactor is a Reactive Streams library and, therefore, all of its operators support non-blocking back pressure. Reactor has a strong focus on server-side Java. It is developed in close collaboration with Spring.
1. Spring WebFlux 和 Spring MVC
我們其實可以像使用SpringMVC一樣使用著WebFlux
2. WebFlux 的接口
WebFlux使用的響應(yīng)式流并不是用JDK9平臺的，而是一個叫做Reactor響應(yīng)式流庫。
Reactor是一個響應(yīng)式流，它也有對應(yīng)的發(fā)布者（Publisher），Reactor的發(fā)布者用兩個類來表示：
- Mono （返回0或1個元素）
- Flux （返回0 - n 個元素）
Spring本身作為消費者存在
3. 例子
-
創(chuàng)建一個SpringBoot項目，創(chuàng)建選擇的內(nèi)容具體如下所示：
第一步
然后正常往下繼續(xù)操作即可
- 創(chuàng)建一個Controller
package cn.lazyfennec.webfluxdemo.controller;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.util.stream.IntStream;
/**
* @Author: Neco
* @Description:
* @Date: create in 2022/7/25 22:13
*/
@RestController
@Slf4j
public class UserController {
@RequestMapping("/index1")
public String index() {
log.info("mvc index start。。。");
String result = getData();
log.info("mvc index end。。。。");
return result;
}
@RequestMapping("/index2")
public Mono<String> index2() {
log.info("flux index start。。。");
Mono<String> result = Mono.fromSupplier(()->getData());
log.info("flux index end。。。。");
return result;
}
@RequestMapping(value = "/index3")
public Flux<String> index3() {
log.info("flux index start。。。");
Flux<String> result = Flux.fromStream(IntStream.range(1,5).mapToObj( i -> {
return "flux item " + i;
}));
log.info("flux index end。。。。");
return result;
}
@RequestMapping(value = "/index4", produces = MediaType.TEXT_EVENT_STREAM_VALUE) // 像流一樣，一個一個的返回
public Flux<String> index4() {
log.info("flux index start。。。");
Flux<String> result = Flux.fromStream(IntStream.range(1,5).mapToObj( i -> {
return "flux item " + i;
}));
log.info("flux index end。。。。");
return result;
}
@RequestMapping(value = "/index5", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<String> index5() {
log.info("flux index start。。。");
Flux<String> result = Flux.fromStream(IntStream.range(1,5).mapToObj( i -> {
try {
Thread.sleep(1000);// 模擬休眠1秒
} catch (InterruptedException e) {
e.printStackTrace();
}
return "flux item " + i;
}));
log.info("flux index end。。。。");
return result;
}
// 獲取數(shù)據(jù)
public String getData() {
try {
// 模擬延遲獲取數(shù)據(jù)
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "hello world from get data method!";
}
}
閱讀以上代碼：
- 首先看index1和index2，其實這兩個的返回效果在前端都很一致，都是三秒后前端展示對應(yīng)的結(jié)果，如下所示：
區(qū)別在于，前者要等待執(zhí)行結(jié)束后才會繼續(xù)往下走，而后者直接返回相關(guān)結(jié)果（即實現(xiàn)了異步返回）：
2022-07-25 22:54:18.849 INFO 10700 --- [ctor-http-nio-2] c.l.w.controller.UserController : mvc index start。。。
2022-07-25 22:54:21.859 INFO 10700 --- [ctor-http-nio-2] c.l.w.controller.UserController : mvc index end。。。。
2022-07-25 22:54:33.865 INFO 10700 --- [ctor-http-nio-2] c.l.w.controller.UserController : flux index start。。。
2022-07-25 22:54:33.866 INFO 10700 --- [ctor-http-nio-2] c.l.w.controller.UserController : flux index end。。。。
-
然后看到 index3 , 主要的區(qū)別在于返回了多個結(jié)果，內(nèi)容如下：
index3 -
而對于index4，區(qū)別則在于
produces = MediaType.TEXT_EVENT_STREAM_VALUE，其實內(nèi)容與index3 類似，只是返回的結(jié)果是一個一個的返回。
index4 對于index5，這里展示不是很好展示，執(zhí)行結(jié)束后的結(jié)果如index4 類似，只是結(jié)果不是同一個時間返回的，而是每一個item之間間隔了1秒，像動畫一樣一個一個出現(xiàn)的。
對于以上例子中Flux中的各種可以使用的方法，其實可以不用太多余糾結(jié)哪個方法是怎么用的，實際用的時候，可以進行一些查看，而且我們其實本身用的也不是特別多。
4. WebFlux要點
可以使用SpringMvc的方式進行開發(fā)
構(gòu)建WebFlux環(huán)境啟動時，應(yīng)用服務(wù)器默認(rèn)是Netty
從調(diào)用方來看，沒有變化，但是服務(wù)端是異步返回的
WebFlux對象還支持服務(wù)器推送
如果覺得有收獲就點個贊吧，更多知識，請點擊關(guān)注查看我的主頁信息哦~
