锟斤拷锟斤拷位锟矫ｏ拷锟斤拷页 > 锟斤拷锟斤拷锟教筹拷 > 锟教筹拷 > 锟斤拷瘸锟斤拷慕锟斤拷锟絊pringWebFlux锟斤拷应式锟斤拷锟�15锟斤拷锟斤拷锟斤拷锟斤拷锟皆达拷锟�
锟斤拷锟斤拷锟斤拷Spring WebFlux 锟斤拷芎锟斤拷锟斤拷锟斤拷锟斤拷全锟斤拷锟斤拷锟斤拷锟剿ｏ拷希锟斤拷锟斤拷锟皆帮拷锟斤拷锟斤拷全锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟� WebFlux锟斤拷原锟斤拷锟斤拷锟斤拷注锟斤拷锟斤拷锟界爱锟斤拷獭锟斤拷锟斤拷锟揭筹拷锟缴查看V锟斤拷每锟斤拷锟斤拷碌锟皆拷锟斤拷锟斤拷锟斤拷锟斤拷荩锟斤拷锟斤拷锟斤拷锟揭伙拷锟缴筹拷锟斤拷
Spring WebFlux 锟斤拷 Spring Framework 5.0 锟芥本锟斤拷锟斤拷锟揭伙拷锟斤拷锟接κ� Web 锟斤拷埽锟斤拷锟斤拷锟� Spring MVC 锟斤拷锟芥，锟结供锟斤拷一锟斤拷全锟铰的憋拷谭锟绞斤拷锟街э拷锟斤拷觳斤拷锟斤拷锟斤拷锟斤拷锟� Web 应锟矫匡拷锟斤拷锟斤拷WebFlux 锟斤拷全锟斤拷锟斤拷锟斤拷应式锟斤拷锟侥ｏ拷停锟街э拷锟� Reactive Streams 锟芥范锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 Netty锟斤拷Undertow 锟皆硷拷 Servlet 3.1+ 锟斤拷锟斤拷锟斤拷锟斤拷锟叫★拷
WebFlux 锟侥猴拷锟侥匡拷锟斤拷锟斤拷锟斤拷 DispatcherHandler锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 Spring MVC 锟叫碉拷 DispatcherServlet锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷址锟斤拷锟斤拷锟接︼拷拇锟斤拷锟斤拷锟斤拷锟紻ispatcherHandler 通锟斤拷锟斤拷锟斤拷 Spring 锟斤拷锟斤拷锟叫碉拷 HandlerMapping锟斤拷HandlerAdapter 锟斤拷 HandlerResultHandler 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷 WebFlux 锟叫ｏ拷Flux 锟斤拷 Mono 锟斤拷 Reactor 锟斤拷锟叫碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟筋，锟街憋拷锟斤拷锟节憋拷示锟斤拷锟斤拷 0 锟斤拷 N 锟斤拷元锟截猴拷 0 锟斤拷 1 锟斤拷元锟截碉拷锟届步锟斤拷锟叫★拷Flux 锟斤拷锟斤拷锟斤拷锟节憋拷示一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟接κ皆拷氐锟斤拷锟斤拷锟斤拷锟� Mono 锟斤拷锟节憋拷示锟斤拷锟斤拷元锟截碉拷锟斤拷应式锟斤拷锟斤拷
Spring WebFlux 支锟街讹拷锟街憋拷锟侥Ｊ斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟阶拷锟侥匡拷锟斤拷锟斤拷锟酵猴拷锟斤拷式锟剿点。锟斤拷锟斤拷锟竭匡拷锟斤拷使锟斤拷 @RestController 注锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应式锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 @GetMapping锟斤拷@PostMapping 锟斤拷注锟斤拷锟斤拷锟斤拷锟斤拷 HTTP 锟斤拷锟斤拷同时锟斤拷WebFlux 也支锟斤拷使锟斤拷 WebClient 锟斤拷为锟斤拷锟斤拷锟斤拷锟斤拷 HTTP 锟酵伙拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵拷拧锟�
WebFlux 锟侥诧拷锟斤拷模锟斤拷锟诫传统锟斤拷 Spring MVC 锟斤拷锟斤拷锟斤拷锟斤拷同锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟竭筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟皆★拷锟斤拷锟斤拷锟斤拷锟斤拷 Netty 锟斤拷锟斤拷锟斤拷锟斤拷时锟斤拷WebFlux 使锟斤拷锟铰硷拷循锟斤拷锟竭筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟襟，憋拷锟斤拷锟剿达拷统 Servlet 锟斤拷锟斤拷锟斤拷每锟斤拷锟斤拷锟斤拷锟斤拷要一锟斤拷锟竭程碉拷模锟酵★拷
Spring WebFlux 锟斤拷锟斤拷锟矫筹拷锟斤拷锟斤拷要锟斤拷 IO 锟杰硷拷锟酵碉拷应锟矫ｏ拷锟斤拷锟斤拷微锟斤拷锟斤拷锟斤拷锟截ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟轿凤拷锟斤拷转锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷然锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷械锟� Spring MVC 应锟斤拷锟杰癸拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟襟，诧拷锟斤拷锟斤拷目锟斤拷使锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟� Servlet 锟竭筹拷模锟酵的库，锟斤拷么锟斤拷锟斤拷没锟叫憋拷要迁锟狡碉拷 WebFlux锟斤拷
源锟斤拷锟斤拷妫琒pring WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟芥及锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 Netty 锟斤拷锟斤拷锟斤拷锟侥筹拷始锟斤拷锟斤拷锟斤拷锟斤拷慕锟斤拷铡锟紻ispatcherHandler 锟斤拷锟斤拷锟斤拷址锟斤拷锟斤拷约锟斤拷锟斤拷盏锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟� Netty 锟斤拷锟斤拷锟斤拷锟叫ｏ拷锟斤拷锟斤拷锟斤拷锟芥及锟斤拷 ChannelHandler锟斤拷ConnectionObserver锟斤拷锟皆硷拷 HttpHandler 锟饺讹拷锟斤拷锟斤拷锟斤拷锟斤拷些锟斤拷锟叫拷锟斤拷锟斤拷锟绞碉拷锟斤拷锟� WebFlux 锟侥凤拷锟斤拷锟斤拷锟斤拷锟斤拷应式锟斤拷锟皆★拷
Spring WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟角癸拷同锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应式 Web 应锟矫匡拷堋锟斤拷锟斤拷锟斤拷锟揭恍╋拷锟揭拷暮锟斤拷锟斤拷锟斤拷锟斤拷
DispatcherHandler锟斤拷锟斤拷锟斤拷 WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟� Spring MVC 锟叫碉拷 DispatcherServlet锟斤拷锟斤拷锟斤拷锟斤拷锟街和碉拷锟斤拷 HTTP 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷handlers锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷映锟戒、锟斤拷锟矫和斤拷锟斤拷锟斤拷锟斤拷锟�
HandlerMapping锟斤拷锟斤拷锟斤拷涌锟斤拷锟斤拷诮锟斤拷锟斤拷锟接筹拷涞斤拷锟接︼拷拇锟斤拷锟斤拷锟斤拷锟絟andler锟斤拷锟斤拷锟斤拷锟斤拷应锟矫筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫憋拷锟斤拷獾斤拷锟斤拷锟斤拷锟斤拷锟饺凤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟斤拷母锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟�
HandlerAdapter锟斤拷锟斤拷锟斤拷涌诎锟斤拷锟� DispatcherHandler 锟斤拷锟斤拷锟轿猴拷锟斤拷锟酵的达拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷要锟斤拷锟侥撅拷锟斤拷牡锟斤拷梅锟绞斤拷锟斤拷锟轿拷锟酵拷拇锟斤拷锟斤拷锟斤拷峁╋拷说锟斤拷貌锟斤拷浴锟�
HandlerResultHandler锟斤拷锟斤拷锟斤拷涌诖锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷煤锟侥斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷盏锟斤拷锟接︼拷锟斤拷锟斤拷锟斤拷鸾锟斤拷锟斤拷锟斤拷慕锟斤拷转锟斤拷为锟酵伙拷锟剿匡拷锟皆斤拷锟秸的革拷式锟斤拷
WebFilter锟斤拷WebFilter 锟接口讹拷锟斤拷锟斤拷一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫╋拷锟斤拷锟斤拷锟斤拷锟斤拷远锟斤拷锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷预锟斤拷锟斤拷锟酵猴拷锟斤拷锟斤拷
ServerWebExchange锟斤拷锟斤拷锟斤拷锟斤拷装锟斤拷 HTTP 锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟斤拷锟斤拷锟较拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵凤拷锟斤拷锟斤拷锟斤拷濉RI锟斤拷锟斤拷锟斤拷锟饺★拷
ServerHttpRequest 锟斤拷 ServerHttpResponse锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷直锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟秸碉拷 HTTP 锟斤拷锟斤拷头锟斤拷偷锟� HTTP 锟斤拷应锟斤拷
WebSession锟斤拷锟斤拷锟节癸拷锟斤拷锟截讹拷锟酵伙拷锟剿的会话锟斤拷息锟斤拷
Reactive Streams锟斤拷WebFlux 锟斤拷锟斤拷 Reactive Streams 锟芥范锟斤拷使锟矫凤拷锟斤拷锟斤拷锟斤拷压锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
Reactor 锟解：锟斤拷为 Spring 5 锟侥凤拷应式锟斤拷袒锟斤拷锟斤拷锟絉eactor 锟结供锟剿凤拷锟斤拷锟斤拷锟侥憋拷锟侥ｏ拷秃凸锟斤拷撸锟斤拷锟斤拷锟� Flux 锟斤拷 Mono 锟饺凤拷应式锟斤拷锟酵★拷
WebClient锟斤拷锟斤拷锟斤拷 Spring 5 锟斤拷锟斤拷锟斤拷姆锟斤拷锟斤拷锟斤拷锟街э拷锟斤拷锟接κ斤拷锟斤拷锟� HTTP 锟酵伙拷锟剿ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵拷拧锟�
Spring Data Reactive锟斤拷锟结供锟斤拷锟斤拷应式锟斤拷锟捷凤拷锟绞碉拷支锟街ｏ拷锟斤拷锟斤拷 Reactive Repositories锟斤拷
Spring Security Reactive锟斤拷锟结供锟斤拷锟斤拷应式锟斤拷全锟斤拷锟绞匡拷锟狡碉拷支锟街★拷
HttpHandler锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷图锟斤拷锟侥凤拷应式 HTTP 锟斤拷锟斤拷锟斤拷锟斤拷同锟斤拷锟斤拷为锟斤拷同锟斤拷锟斤拷时之锟斤拷墓锟酵拷锟斤拷锟斤拷锟�
ContextPathCompositeHandler锟斤拷锟斤拷锟斤拷锟节诧拷同锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷锟斤拷注锟斤拷锟斤拷应锟矫筹拷锟斤拷
锟斤拷些锟斤拷锟斤拷锟酵拷锟斤拷锟斤拷锟轿拷锟斤拷锟斤拷锟皆憋拷峁╋拷锟揭伙拷锟角匡拷锟斤拷锟斤拷锟斤拷锟斤拷锟接κ� Web 应锟矫匡拷锟斤拷平台锟斤拷通锟斤拷锟斤拷些锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷呖锟斤拷怨锟斤拷锟斤拷锟斤拷芄锟斤拷锟叫э拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟矫筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫╋拷锟斤拷锟斤拷V 锟界将一一锟斤拷细锟斤拷锟杰猴拷锟斤拷源锟斤拷锟绞碉拷止锟斤拷蹋锟斤拷锟斤拷锟斤拷值锟斤拷浅锟斤拷锟斤拷锟斤拷狻�
DispatcherHandler 锟斤拷 Spring WebFlux 锟侥猴拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟� Spring MVC 锟叫碉拷 DispatcherServlet锟斤拷锟斤拷锟斤拷锟金将达拷锟斤拷锟� HTTP 锟斤拷锟斤拷址锟斤拷锟斤拷锟接︼拷拇锟斤拷锟斤拷锟斤拷锟絟andler锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟接筹拷洹拷锟斤拷煤徒锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟角讹拷 DispatcherHandler 锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
锟斤拷始锟斤拷锟斤拷锟斤拷
ApplicationContextAware 实锟街ｏ拷DispatcherHandler 实锟斤拷锟斤拷 ApplicationContextAware 锟接口ｏ拷锟斤拷锟斤拷味锟斤拷锟斤拷锟斤拷锟皆凤拷锟绞碉拷 Spring 应锟斤拷锟斤拷锟斤拷锟斤拷锟叫碉拷 Bean锟斤拷
HandlerMapping锟斤拷HandlerAdapter 锟斤拷 HandlerResultHandler 锟侥筹拷始锟斤拷锟斤拷DispatcherHandler 锟节筹拷始锟斤拷时锟斤拷锟斤拷锟� Spring 应锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫碉拷 HandlerMapping锟斤拷HandlerAdapter 锟斤拷 HandlerResultHandler 锟斤拷锟斤拷始锟斤拷锟斤拷锟角★拷
protected void initStrategies(ApplicationContext context) {
// ... 省锟皆诧拷锟街达拷锟斤拷 ...
this.handlerMappings = ...;
this.handlerAdapters = ...;
this.resultHandlers = ...;
}
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷取 HandlerMappings锟斤拷DispatcherHandler 锟斤拷通锟斤拷 handlerMappings 锟斤拷锟斤拷锟斤拷锟杰癸拷锟斤拷锟斤拷锟斤拷前锟斤拷锟斤拷锟� HandlerMapping锟斤拷
映锟斤拷锟斤拷锟斤拷 Handler锟斤拷使锟斤拷锟揭碉拷锟斤拷 HandlerMapping 锟斤拷锟斤拷锟斤拷映锟戒到锟斤拷锟斤拷拇锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟揭伙拷锟� @Controller 锟斤拷锟斤拷锟斤拷锟斤拷一锟斤拷 RouterFunction锟斤拷锟斤拷
锟斤拷锟斤拷 Handler锟斤拷一锟斤拷锟揭碉拷锟斤拷锟斤拷锟斤拷锟斤拷DispatcherHandler 锟斤拷使锟斤拷锟绞碉拷锟斤拷 HandlerAdapter 锟斤拷锟斤拷锟矫达拷锟斤拷锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟街达拷薪锟斤拷锟结被 HandlerResultHandler 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟斤拷
锟斤拷锟侥凤拷锟斤拷锟斤拷handle
DispatcherHandler 锟侥猴拷锟侥凤拷锟斤拷锟斤拷 handle锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟教ｏ拷
public Mono handle(ServerWebExchange exchange) {
// 锟斤拷锟斤拷欠锟斤拷始锟斤拷锟斤拷 handlerMappings
if (this.handlerMappings == null) {
return createNotFoundError();
}
// 使锟斤拷 handlerMappings 锟斤拷锟斤拷锟斤拷 handler
return Flux.fromIterable(this.handlerMappings)
.concatMap(mapping -> mapping.getHandler(exchange))
.next() // 锟斤拷取锟斤拷一锟斤拷 handler
.switchIfEmpty(createNotFoundError()) // 锟斤拷锟矫伙拷锟斤拷业锟� handler锟斤拷锟斤拷锟截达拷锟斤拷
.flatMap(handler -> invokeHandler(exchange, handler)) // 锟斤拷锟斤拷 handler
.flatMap(result -> handleResult(exchange, result)); // 锟斤拷锟斤拷锟斤拷锟�
}
锟斤拷锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷锟斤拷锟叫拷锟斤拷锟�
DispatcherHandler 锟斤拷锟斤拷锟绞癸拷锟斤拷锟斤拷浅锟斤拷锟筋，锟斤拷锟皆猴拷锟斤拷锟阶碉拷锟斤拷展锟铰碉拷 HandlerMapping锟斤拷HandlerAdapter 锟斤拷 HandlerResultHandler 锟斤拷支锟街诧拷同锟侥达拷锟斤拷锟斤拷锟斤拷锟酵和凤拷锟斤拷锟斤拷锟酵★拷
锟斤拷锟较撅拷锟斤拷 DispatcherHandler 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟侥凤拷锟斤拷锟斤拷通锟斤拷锟斤拷锟街凤拷式锟斤拷Spring WebFlux 锟杰癸拷锟皆凤拷锟斤拷锟斤拷锟侥凤拷式锟斤拷锟斤拷 Web 锟斤拷锟斤拷锟斤拷锟接︼拷玫锟斤拷锟斤拷芎涂锟斤拷锟斤拷锟斤拷浴锟�
HandlerMapping 锟斤拷 Spring WebFlux 锟叫碉拷一锟斤拷锟接口ｏ拷锟斤拷锟斤拷锟斤拷锟剿斤拷锟斤拷锟斤拷映锟戒到锟斤拷锟斤拷锟斤拷锟斤拷handler锟斤拷锟斤拷锟竭硷拷锟斤拷HandlerMapping 锟斤拷实锟斤拷锟洁负锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵★拷URL 模式锟斤拷锟斤拷息锟斤拷确锟斤拷锟侥革拷锟斤拷锟斤拷拇锟斤拷锟斤拷锟接︼拷么锟斤拷锟斤拷锟角帮拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷嵌锟� HandlerMapping 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
HandlerMapping 锟接口讹拷锟斤拷
HandlerMapping 锟接口讹拷锟斤拷锟斤拷锟斤拷锟铰关硷拷锟斤拷锟斤拷锟斤拷
public interface HandlerMapping {
Mono锟斤拷要实锟斤拷锟斤拷
Spring WebFlux 锟结供锟剿硷拷锟斤拷 HandlerMapping 锟斤拷实锟斤拷锟洁，锟斤拷要锟斤拷锟斤拷锟斤拷
RequestMappingHandlerMapping锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷注锟斤拷锟接筹拷洌拷锟斤拷锟� @RequestMapping锟斤拷@GetMapping 锟饺★拷
RouterFunctionMapping锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 RouterFunction 锟侥猴拷锟斤拷式路锟缴★拷
SimpleUrlHandlerMapping锟斤拷锟斤拷锟斤拷锟津单碉拷 URL 锟斤拷锟斤拷锟斤拷锟接筹拷洹�
RequestMappingHandlerMapping 源锟斤拷锟斤拷锟�
RequestMappingHandlerMapping 锟斤拷锟筋常锟矫碉拷 HandlerMapping 实锟斤拷之一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷一些锟截硷拷实锟斤拷锟竭硷拷锟斤拷
注锟斤拷徒锟斤拷锟斤拷锟斤拷诔锟绞硷拷锟绞憋拷锟絉equestMappingHandlerMapping 锟斤拷扫锟斤拷锟斤拷锟叫碉拷 beans锟斤拷锟斤拷锟揭达拷锟斤拷 @RequestMapping 注锟斤拷姆锟斤拷锟斤拷锟斤拷锟阶拷锟斤拷锟叫╋拷锟斤拷锟斤拷锟轿拷锟斤拷锟侥达拷锟斤拷锟斤拷锟斤拷
映锟戒处锟斤拷锟斤拷RequestMappingHandlerMapping 使锟斤拷 Pattern 锟斤拷锟斤拷锟斤拷锟芥储锟斤拷匹锟斤拷 URL 模式锟斤拷
getHandler 锟斤拷锟斤拷实锟街ｏ拷
@Override
public Mono映锟斤拷匹锟斤拷锟竭硷拷
映锟斤拷匹锟斤拷锟竭硷拷通锟斤拷锟芥及锟斤拷锟铰诧拷锟借：
路锟斤拷匹锟戒：锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷锟角凤拷锟斤拷注锟斤拷锟� URL 模式匹锟戒。
锟斤拷锟襟方凤拷匹锟戒：锟斤拷锟� URL 模式匹锟戒，锟斤拷一锟斤拷锟斤拷锟斤拷锟斤拷锟侥凤拷锟斤拷锟斤拷GET锟斤拷POST 锟饺ｏ拷锟角凤拷锟诫处锟斤拷锟斤拷支锟街的凤拷锟斤拷匹锟戒。
锟斤拷锟斤拷锟斤拷锟斤拷匹锟戒：锟斤拷锟斤拷锟斤拷锟斤拷欠锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷牟锟斤拷锟斤拷锟�
头锟斤拷息匹锟戒：锟斤拷锟斤拷锟斤拷锟酵凤拷欠锟斤拷锟斤拷锟斤拷囟锟斤拷锟斤拷锟斤拷锟斤拷锟�
锟斤拷锟窖和诧拷锟斤拷媒锟斤拷锟斤拷锟斤拷匹锟戒：锟斤拷锟斤拷锟斤拷锟斤拷 Accept 头锟斤拷 Content-Type 锟角凤拷锟诫处锟斤拷锟斤拷支锟街碉拷媒锟斤拷锟斤拷锟斤拷匹锟戒。
锟斤拷锟斤拷锟脚伙拷
RequestMappingHandlerMapping 锟斤拷实锟斤拷锟斤拷一些锟斤拷锟斤拷锟脚伙拷锟斤拷施锟斤拷锟斤拷锟界缓锟斤拷匹锟斤拷锟� URL 模式锟斤拷锟皆硷拷锟斤拷锟截革拷锟斤拷模式匹锟斤拷锟斤拷锟斤拷锟�
小锟斤拷一锟斤拷
HandlerMapping 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫的关硷拷锟斤拷锟街ｏ拷锟斤拷锟斤拷锟金将斤拷锟斤拷锟斤拷锟斤拷锟接筹拷涞斤拷锟饺凤拷拇锟斤拷锟斤拷锟斤拷锟酵拷锟绞癸拷貌锟酵拷锟� HandlerMapping 实锟街ｏ拷Spring WebFlux 支锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷映锟斤拷锟斤拷裕锟斤拷锟斤拷锟接︼拷锟酵拷锟接︼拷贸锟斤拷锟斤拷锟�
HandlerAdapter 锟接匡拷锟斤拷 Spring WebFlux 锟叫帮拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷要锟侥斤拷色锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟角斤拷 DispatcherHandler 锟揭碉拷锟侥达拷锟斤拷锟斤拷锟斤拷handler锟斤拷锟斤拷锟戒到锟斤拷锟斤拷锟街达拷锟斤拷呒锟斤拷稀锟紿andlerAdapter 使锟斤拷 DispatcherHandler 锟斤拷锟斤拷锟斤拷木锟斤拷锟侥达拷锟斤拷锟斤拷锟斤拷锟酵ｏ拷只锟斤拷要通锟斤拷 HandlerAdapter 锟斤拷锟斤拷锟矫达拷锟斤拷锟斤拷锟斤拷锟缴★拷锟斤拷锟斤拷锟角讹拷 HandlerAdapter 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
HandlerAdapter 锟接口讹拷锟斤拷
HandlerAdapter 锟接口讹拷锟斤拷锟斤拷锟斤拷锟铰关硷拷锟斤拷锟斤拷锟斤拷
public interface HandlerAdapter {
boolean supports(Object handler);
Mono handle(ServerWebExchange exchange, Object handler, Object... args);
}
锟斤拷锟襟，憋拷示锟届步锟侥碉拷锟矫癸拷锟教★拷
锟斤拷要实锟斤拷锟斤拷
Spring WebFlux 锟结供锟剿硷拷锟斤拷 HandlerAdapter 锟斤拷实锟斤拷锟洁，锟斤拷要锟斤拷锟斤拷锟斤拷
RequestMappingHandlerAdapter锟斤拷支锟街伙拷锟斤拷注锟斤拷目锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 @RequestMapping 注锟斤拷姆锟斤拷锟斤拷锟�
HttpHandlerAdapter锟斤拷支锟斤拷 HttpHandler 锟接口的达拷锟斤拷锟斤拷锟斤拷
ControllerEndpointHandlerAdapter锟斤拷支锟斤拷 ControllerEndpoint 锟接口的达拷锟斤拷锟斤拷锟斤拷通锟斤拷锟斤拷锟斤拷 WebFlux 锟斤拷锟斤拷式锟斤拷獭锟�
RouterFunctionHandlerAdapter锟斤拷支锟斤拷 RouterFunction 锟接口ｏ拷锟斤拷锟节猴拷锟斤拷式路锟缴★拷
RequestMappingHandlerAdapter 源锟斤拷锟斤拷锟�
RequestMappingHandlerAdapter 锟斤拷锟筋常锟矫碉拷 HandlerAdapter 实锟斤拷之一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷一些锟截硷拷实锟斤拷锟竭硷拷锟斤拷
@Override
public boolean supports(Object handler) {
return (handler instanceof HandlerFunction) ||
(handler instanceof Controller) ||
AnnotationUtils.findAnnotation(handler.getClass(), RequestMapping.class) != null;
}
锟斤拷锟矫达拷锟斤拷锟斤拷锟斤拷handle 锟斤拷锟斤拷锟斤拷锟矫达拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷值锟斤拷
@Override
public Mono handle(ServerWebExchange exchange, Object handler) {
// 锟斤拷锟矫撅拷锟斤拷拇锟斤拷锟斤拷锟�
return ((HandlerFunction) handler).handle(exchange);
}
锟斤拷锟矫达拷锟斤拷锟斤拷锟斤拷锟竭硷拷
锟斤拷锟矫达拷锟斤拷锟斤拷锟斤拷锟竭硷拷通锟斤拷锟芥及锟斤拷锟铰诧拷锟借：
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫的诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷转锟斤拷为锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷锟矫凤拷锟斤拷锟斤拷锟斤拷锟矫达拷锟斤拷锟斤拷锟侥凤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷牟锟斤拷锟斤拷锟斤拷莞锟斤拷锟斤拷锟斤拷锟�
锟斤拷锟斤拷锟斤拷锟斤拷值锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥凤拷锟斤拷值锟斤拷锟斤拷锟斤拷转锟斤拷为锟斤拷应锟斤拷
锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷氐锟斤拷锟� Mono 锟斤拷 Flux锟斤拷HandlerAdapter 锟斤拷要锟斤拷锟斤拷锟斤拷些锟届步锟斤拷锟斤拷锟�
锟斤拷锟斤拷锟斤拷
HandlerAdapter 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟矫癸拷锟斤拷锟叫碉拷锟届常锟斤拷锟斤拷锟届常转锟斤拷为锟斤拷锟绞碉拷锟斤拷应锟斤拷
小锟斤拷一锟斤拷
HandlerAdapter 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫的关硷拷锟斤拷锟街ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷 DispatcherHandler 锟酵撅拷锟斤拷拇锟斤拷锟斤拷锟绞碉拷帧锟酵拷锟绞癸拷貌锟酵拷锟� HandlerAdapter 实锟街ｏ拷Spring WebFlux 支锟斤拷锟剿讹拷锟斤拷锟斤拷锟酵的达拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷注锟斤拷目锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟绞铰凤拷锟斤拷约锟� HttpHandler 锟接口碉拷实锟街★拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟剿匡拷艿锟斤拷锟斤拷锟皆和匡拷锟斤拷展锟皆★拷
HandlerResultHandler 锟斤拷锟斤拷锟� Spring WebFlux 锟叫革拷锟斤拷锟斤拷锟斤拷 HandlerAdapter 锟斤拷锟矫达拷锟斤拷锟斤拷锟襟返回的斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫╋拷锟斤拷转锟斤拷为锟酵伙拷锟剿匡拷锟皆斤拷锟秸碉拷 HTTP 锟斤拷应锟斤拷锟斤拷锟斤拷锟角讹拷 HandlerResultHandler 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
HandlerResultHandler 锟接口讹拷锟斤拷
HandlerResultHandler 锟接口讹拷锟斤拷锟斤拷锟斤拷锟铰关硷拷锟斤拷锟斤拷锟斤拷
public interface HandlerResultHandler {
boolean supports(HandlerResult result);
Mono handleResult(ServerWebExchange exchange, HandlerResult result);
}
锟斤拷锟襟，憋拷示锟届步锟侥达拷锟斤拷锟斤拷锟教★拷
锟斤拷要实锟斤拷锟斤拷
Spring WebFlux 锟结供锟剿硷拷锟斤拷 HandlerResultHandler 锟斤拷实锟斤拷锟洁，锟斤拷要锟斤拷锟斤拷锟斤拷
ServerResponseResultHandler 源锟斤拷锟斤拷锟�
ServerResponseResultHandler 锟角达拷锟斤拷 ServerResponse 锟斤拷锟酵斤拷锟斤拷锟� HandlerResultHandler 实锟街ｏ拷
@Override
public boolean supports(HandlerResult result) {
return result.getReturnValue() instanceof ServerResponse;
}
@Override
public Mono handleResult(ServerWebExchange exchange, HandlerResult result) {
ServerResponse response = (ServerResponse) result.getReturnValue();
return response.writeTo(exchange, result.isCommitted());
}
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷呒锟�
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷呒锟酵拷锟斤拷婕帮拷锟斤拷虏锟斤拷瑁�
锟斤拷取锟斤拷锟斤拷值锟斤拷锟斤拷 HandlerResult 锟叫伙拷取锟斤拷锟斤拷锟斤拷锟侥凤拷锟斤拷值锟斤拷
锟斤拷锟斤拷锟斤拷停锟斤拷锟斤拷莘锟斤拷锟街碉拷锟斤拷锟斤拷停锟窖★拷锟斤拷锟绞的达拷锟斤拷锟竭硷拷锟斤拷
锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷锟斤拷锟斤拷值转锟斤拷为 HTTP 锟斤拷应锟斤拷锟斤拷锟界，ServerResponse 锟窖撅拷锟斤拷锟斤拷锟斤拷锟斤拷应锟斤拷状态锟诫、头锟斤拷息锟斤拷锟藉。
锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟街碉拷锟斤拷觳斤拷模锟斤拷锟� Mono 锟斤拷 Flux锟斤拷锟斤拷锟斤拷锟斤拷要锟斤拷锟斤拷锟斤拷些锟届步锟斤拷锟斤拷锟�
写锟斤拷锟斤拷应锟斤拷锟斤拷锟斤拷锟缴碉拷锟斤拷应写锟诫到 ServerWebExchange 锟叫★拷
锟斤拷锟斤拷锟斤拷
HandlerResultHandler 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷械锟斤拷斐ｏ拷锟斤拷锟斤拷斐Ｗ拷锟轿拷锟斤拷实锟斤拷锟接︼拷锟�
小锟斤拷一锟斤拷
HandlerResultHandler 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫的关硷拷锟斤拷锟街ｏ拷锟斤拷锟斤拷锟金将达拷锟斤拷锟斤拷锟侥凤拷锟斤拷值转锟斤拷为 HTTP 锟斤拷应锟斤拷通锟斤拷使锟矫诧拷同锟斤拷 HandlerResultHandler 实锟街ｏ拷Spring WebFlux 支锟斤拷锟剿讹拷锟街凤拷锟斤拷值锟斤拷锟酵ｏ拷锟斤拷锟斤拷 ServerResponse锟斤拷ResponseEntity 锟斤拷 ModelAndView锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟剿匡拷艿锟斤拷锟斤拷锟皆和匡拷锟斤拷展锟皆ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟皆诧拷同锟侥凤拷式锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷锟�
HandlerResultHandler 锟斤拷实锟斤拷通锟斤拷锟斤拷要锟斤拷锟斤拷锟斤拷应锟斤拷锟届步锟斤拷锟皆ｏ拷确锟斤拷锟斤拷使锟斤拷锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟揭诧拷锟斤拷锟饺凤拷锟斤拷锟斤拷珊头锟斤拷锟斤拷锟接︼拷锟斤拷锟斤拷猓拷锟斤拷锟斤拷锟揭拷锟� ServerWebExchange 锟斤拷锟斤拷协锟斤拷锟斤拷锟皆憋拷锟斤拷屎筒锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷息锟斤拷
WebFilter 锟接匡拷锟斤拷 Spring WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟截和达拷锟斤拷 Web 锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟襟到达拷锟斤拷锟侥达拷锟斤拷锟斤拷之前锟斤拷之锟襟，讹拷锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷卸锟斤拷锟侥达拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷志锟斤拷录锟斤拷锟斤拷全锟皆硷拷椤拷锟斤拷锟斤拷锟斤拷取锟斤拷锟斤拷锟斤拷嵌锟� WebFilter 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
WebFilter 锟接口讹拷锟斤拷
WebFilter 锟接口讹拷锟斤拷锟斤拷锟斤拷锟铰关硷拷锟斤拷锟斤拷锟斤拷
public interface WebFilter {
Mono filter(ServerWebExchange exchange, WebFilterChain chain);
}
锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷 Spring WebFlux 锟叫ｏ拷WebFilter 通锟斤拷锟结被锟斤拷织锟斤拷一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷每锟斤拷 WebFilter 锟斤拷锟斤拷锟皆撅拷锟斤拷锟角硷拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟角斤拷锟斤拷锟襟传递革拷锟斤拷锟叫碉拷锟斤拷一锟斤拷 WebFilter锟斤拷锟斤拷锟斤拷锟斤拷式锟斤拷锟斤拷模式使锟矫癸拷锟斤拷锟斤拷锟斤拷执锟斤拷顺锟斤拷浅锟斤拷锟揭拷锟�
锟斤拷要实锟斤拷锟斤拷
Spring WebFlux 锟结供锟斤拷一些锟斤拷锟矫碉拷 WebFilter 实锟斤拷锟洁，锟斤拷锟界：
锟斤拷锟斤拷锟斤拷锟斤拷锟侥癸拷锟斤拷
锟斤拷锟斤拷锟斤拷锟斤拷通锟斤拷锟斤拷应锟矫筹拷锟斤拷锟斤拷锟斤拷锟斤拷泄锟斤拷锟斤拷锟斤拷锟斤拷锟绞癸拷锟� WebFilter 锟接口碉拷实锟斤拷锟洁：
@Configuration
public class WebFluxConfig {
@Bean
public WebFilter myCustomFilter() {
return (exchange, chain) -> {
// 锟斤拷锟斤拷锟斤拷锟斤拷远锟斤拷锟斤拷锟斤拷锟斤拷预锟斤拷锟斤拷
return chain.filter(exchange).subscriberContext(ctx -> ctx.put("customKey", "customValue"));
};
}
}
WebFilter 锟斤拷实锟斤拷锟竭硷拷
实锟斤拷 WebFilter 锟接口碉拷 filter 锟斤拷锟斤拷通锟斤拷锟芥及锟斤拷锟铰诧拷锟借：
预锟斤拷锟斤拷锟斤拷锟节碉拷锟斤拷 chain.filter(exchange) 之前锟斤拷锟斤拷 ServerWebExchange 锟斤拷锟斤拷锟轿何憋拷要锟斤拷预锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟睫革拷锟斤拷锟斤拷头锟斤拷锟斤拷询锟斤拷锟斤拷锟饺★拷
锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 WebFilterChain 锟斤拷 filter 锟斤拷锟斤拷锟斤拷锟斤拷锟襟传递革拷锟斤拷锟叫碉拷锟斤拷一锟斤拷 WebFilter锟斤拷锟斤拷通锟斤拷锟结返锟斤拷一锟斤拷 Mono
锟斤拷锟斤拷示锟届步锟侥癸拷锟剿癸拷锟教★拷
锟斤拷锟斤拷锟斤拷锟斤拷 chain.filter(exchange) 锟斤拷珊螅锟� ServerWebExchange 锟斤拷锟斤拷锟轿何憋拷要锟侥猴拷锟斤拷锟斤拷锟斤拷锟斤拷锟睫革拷锟斤拷应头锟斤拷锟斤拷应锟斤拷取锟�
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟节癸拷锟剿癸拷锟斤拷锟叫匡拷锟杰凤拷锟斤拷锟斤拷锟届常锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟阶筹拷锟铰的达拷锟襟、凤拷锟斤拷锟截讹拷锟斤拷锟斤拷应锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟�
锟届步锟斤拷锟斤拷
锟斤拷锟斤拷 filter 锟斤拷锟斤拷锟斤拷锟截碉拷锟斤拷 Mono
锟斤拷WebFilter 锟斤拷实锟斤拷锟斤拷要锟斤拷锟斤拷锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷味锟斤拷锟节癸拷锟剿癸拷锟斤拷锟叫ｏ拷锟斤拷锟皆凤拷锟斤拷锟届步锟斤拷锟斤拷应锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷拇锟斤拷锟斤拷锟�
小锟斤拷一锟斤拷
WebFilter 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟截和达拷锟斤拷 Web 锟斤拷锟斤拷锟斤拷锟接︼拷锟角匡拷蠊ぞ摺锟酵拷锟绞碉拷锟� WebFilter 锟接口诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟竭匡拷锟斤拷锟斤拷锟截讹拷锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟皆わ拷锟斤拷锟斤拷秃锟斤拷锟斤拷锟斤拷约锟绞碉拷指锟斤拷趾锟斤拷泄锟阶拷悖拷绨踩拷浴锟斤拷锟街撅拷锟铰硷拷锟紺ORS 锟斤拷锟斤拷锟饺★拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟矫筹拷锟斤拷锟侥ｏ拷锟斤拷院涂锟轿拷锟斤拷裕锟酵憋拷锟斤拷锟斤拷朔锟斤拷锟斤拷锟斤拷锟斤拷觳斤拷锟斤拷锟斤拷浴锟�
ServerWebExchange 锟斤拷 Spring WebFlux 锟叫碉拷一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟阶帮拷锟� HTTP 锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟斤拷锟斤拷锟斤拷锟较拷锟轿� Web 锟斤拷锟斤拷锟斤拷锟斤拷应锟矫筹拷锟斤拷之锟斤拷锟结供锟斤拷一锟斤拷锟斤拷锟斤拷锟侥接口★拷锟斤拷锟斤拷锟角讹拷 ServerWebExchange 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
ServerWebExchange 锟接口讹拷锟斤拷
ServerWebExchange 锟接口讹拷锟斤拷锟剿讹拷 HTTP 锟斤拷锟斤拷锟斤拷锟接︼拷姆锟斤拷屎筒锟斤拷锟斤拷锟�
public interface ServerWebExchange {
ServerHttpRequest getRequest();
ServerHttpResponse getResponse();
void beforeCommit();
boolean isCommitted();
void setCommitted(boolean committed);
Context getContext();
}
锟斤拷锟斤拷锟斤拷锟斤拷
ServerWebExchange 通锟斤拷锟斤拷锟斤拷锟斤拷锟铰猴拷锟斤拷锟斤拷锟皆ｏ拷
锟斤拷锟斤拷锟斤拷锟接︼拷拇锟斤拷锟�
ServerWebExchange 锟斤拷锟斤拷锟斤拷锟斤拷锟接︼拷拇锟斤拷锟斤拷邪锟斤拷锟斤拷藕锟斤拷慕锟缴拷锟�
锟斤拷锟斤拷锟饺★拷锟酵拷锟� getRequest() 锟斤拷锟斤拷锟斤拷取锟斤拷锟斤拷锟斤拷螅锟斤拷锟斤拷锟斤拷锟侥革拷锟斤拷锟斤拷息锟斤拷
锟斤拷应锟斤拷锟届：通锟斤拷 getResponse() 锟斤拷锟斤拷锟斤拷取锟斤拷应锟斤拷锟襟，癸拷锟斤拷锟斤拷应锟斤拷状态锟诫、头锟斤拷息锟斤拷锟斤拷应锟藉。
锟斤拷锟斤拷锟侥癸拷锟斤拷锟斤拷使锟斤拷 Context 锟斤拷锟斤拷娲拷痛锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷锟叫的革拷锟斤拷锟斤拷息锟斤拷
锟结交锟斤拷锟斤拷锟斤拷通锟斤拷 beforeCommit()锟斤拷isCommitted() 锟斤拷 setCommitted() 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟斤拷锟结交状态锟斤拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 WebFilter 锟斤拷实锟斤拷锟叫ｏ拷ServerWebExchange 锟斤拷锟斤拷锟节癸拷锟斤拷锟斤拷锟斤拷锟叫达拷锟捷ｏ拷每锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟皆凤拷锟绞猴拷锟睫革拷锟斤拷锟斤拷锟斤拷锟接︼拷锟�
锟届步锟斤拷锟斤拷
锟斤拷锟斤拷 WebFlux 锟斤拷锟斤拷应式锟侥ｏ拷ServerWebExchange 支锟斤拷锟届步锟斤拷锟斤拷锟斤拷
小锟斤拷一锟斤拷
ServerWebExchange 锟斤拷 Spring WebFlux 锟叫达拷锟斤拷 HTTP 锟斤拷锟斤拷锟斤拷锟接︼拷暮锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟结供锟斤拷一锟斤拷统一锟侥接匡拷锟斤拷锟斤拷锟绞和诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷荩锟酵敝э拷锟斤拷觳斤拷锟斤拷锟斤拷锟斤拷拇锟斤拷锟斤拷锟绞斤拷锟酵拷锟� ServerWebExchange锟斤拷锟斤拷锟斤拷锟竭匡拷锟斤拷锟斤拷 Web 锟斤拷锟斤拷锟斤拷锟斤拷应锟矫筹拷锟斤拷之锟斤拷锟斤拷懈锟叫э拷锟斤拷锟斤拷萁锟斤拷锟斤拷锟阶刺拷锟斤拷锟斤拷锟绞碉拷指锟斤拷锟斤拷艿锟斤拷锟接κ� Web 应锟矫★拷
ServerWebExchange 锟斤拷实锟斤拷通锟斤拷锟斤拷要锟斤拷锟斤拷锟斤拷应式锟侥憋拷锟侥ｏ拷停锟饺凤拷锟斤拷诖锟斤拷锟斤拷锟斤拷锟酵癸拷锟斤拷锟斤拷应时锟斤拷锟斤拷锟斤拷锟斤拷锟铰硷拷循锟斤拷锟斤拷锟接讹拷锟斤拷锟斤拷锟斤拷锟� WebFlux 锟斤拷锟斤拷锟斤拷锟斤拷锟狡★拷锟斤拷锟解，锟斤拷锟斤拷锟结供锟剿丰富锟斤拷锟斤拷锟斤拷锟侥癸拷锟斤拷锟斤拷锟杰ｏ拷使锟斤拷锟节革拷锟接碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫ｏ拷锟斤拷锟皆凤拷锟斤拷卮娲拷痛锟斤拷莞锟斤拷锟斤拷锟较拷锟�
ServerHttpRequest 锟斤拷 ServerHttpResponse 锟斤拷 Spring WebFlux 锟叫碉拷锟斤拷锟斤拷锟斤拷锟侥接口ｏ拷锟斤拷锟角分憋拷锟绞撅拷锟斤拷锟斤拷锟斤拷锟斤拷盏锟� HTTP 锟斤拷锟斤拷头锟斤拷偷锟� HTTP 锟斤拷应锟斤拷锟斤拷锟斤拷锟角讹拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
ServerHttpRequest 锟接口讹拷锟斤拷
ServerHttpRequest 锟接口讹拷锟斤拷锟剿讹拷 HTTP 锟斤拷锟斤拷姆锟斤拷剩锟�
public interface ServerHttpRequest {
URI getURI();
HttpMethod getMethod();
String getHeader(String headerName);
MultiValueMap getHeaders();
DataBufferFactory bufferFactory();
// 省锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷...
}
ServerHttpResponse 锟接口讹拷锟斤拷
ServerHttpResponse 锟接口讹拷锟斤拷锟剿讹拷 HTTP 锟斤拷应锟侥癸拷锟斤拷头锟斤拷停锟�
public interface ServerHttpResponse {
HttpStatusSeriesStatus.Series getStatusSeries();
void setStatusCode(HttpStatus statusCode);
String getHeader(String headerName);
MultiValueMap getHeaders();
void setComplete();
DataBufferFactory bufferFactory();
Mono writeWith(Publisher body);
// 省锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷...
}
body)
锟斤拷锟斤拷锟斤拷锟斤拷应锟藉。
锟斤拷锟斤拷锟斤拷锟接︼拷拇锟斤拷锟�
ServerHttpRequest 锟斤拷 ServerHttpResponse 锟节达拷锟斤拷 HTTP 锟斤拷锟斤拷锟斤拷锟接︼拷邪锟斤拷锟斤拷藕锟斤拷慕锟缴拷锟�
锟斤拷锟斤拷锟斤拷息锟斤拷取锟斤拷通锟斤拷 ServerHttpRequest 锟侥凤拷锟斤拷锟斤拷取锟斤拷锟斤拷锟� URI锟斤拷锟斤拷锟斤拷锟斤拷头锟斤拷息锟饺★拷
锟斤拷应锟斤拷锟届：使锟斤拷 ServerHttpResponse 锟侥凤拷锟斤拷锟斤拷锟斤拷状态锟诫、头锟斤拷息锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟藉。
锟斤拷锟捷伙拷锟斤拷锟斤拷锟斤拷通锟斤拷 bufferFactory() 锟斤拷锟斤拷锟斤拷取 DataBufferFactory锟斤拷锟斤拷锟节达拷锟斤拷锟酵癸拷锟斤拷锟斤拷锟捷伙拷锟斤拷锟斤拷锟斤拷
锟届步锟斤拷锟酵ｏ拷ServerHttpResponse 锟斤拷 writeWith(Publisher
body)
锟斤拷锟斤拷支锟斤拷锟届步锟斤拷锟斤拷锟斤拷应锟藉。
锟斤拷式锟斤拷锟斤拷锟斤拷支锟斤拷锟斤拷锟斤拷式锟侥凤拷式锟斤拷取锟斤拷锟斤拷锟斤拷锟叫达拷锟斤拷锟接︼拷濉�
锟届步锟斤拷锟斤拷锟斤拷
锟斤拷锟斤拷 WebFlux 锟角伙拷锟斤拷锟斤拷应式锟斤拷锟侥ｏ拷偷模锟絊erverHttpRequest 锟斤拷 ServerHttpResponse 支锟斤拷锟届步锟斤拷锟斤拷锟斤拷锟侥诧拷锟斤拷锟斤拷
锟斤拷式锟届步锟斤拷取锟酵凤拷锟酵★拷
小锟斤拷一锟斤拷
ServerHttpRequest 锟斤拷 ServerHttpResponse 锟斤拷 Spring WebFlux 锟叫达拷锟斤拷 HTTP 锟斤拷锟斤拷锟斤拷锟接︼拷慕涌凇锟斤拷锟斤拷锟斤拷峁╋拷朔岣伙拷姆锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟较拷锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟街э拷锟斤拷觳斤拷锟斤拷锟斤拷锟斤拷牟锟斤拷锟斤拷锟酵拷锟斤拷锟斤拷锟斤拷锟斤拷涌冢锟斤拷锟斤拷锟斤拷呖锟斤拷怨锟斤拷锟斤拷锟斤拷锟斤拷堋锟斤拷锟接κ斤拷锟� Web 应锟矫ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷执锟接诧拷锟斤拷锟斤拷锟斤拷锟斤拷芄锟斤拷锟斤拷锟斤拷啤锟�
锟斤拷实锟斤拷应锟斤拷锟叫ｏ拷锟斤拷锟斤拷锟斤拷通锟斤拷锟斤拷锟斤拷要直锟斤拷实锟斤拷锟斤拷些锟接口ｏ拷锟斤拷锟斤拷通锟斤拷锟斤拷锟斤拷峁╋拷锟绞碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷些实锟斤拷锟斤拷通锟斤拷锟斤拷锟斤拷锟截讹拷锟斤拷锟斤拷锟斤拷时锟斤拷锟斤拷锟斤拷锟斤拷 Netty锟斤拷锟斤拷锟缴ｏ拷锟斤拷锟结供锟斤拷效锟斤拷 I/O 锟斤拷锟斤拷锟斤拷
WebSession 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷锟节憋拷示锟酵癸拷锟斤拷 Web 锟结话锟斤拷session锟斤拷锟斤拷锟斤拷锟结供锟斤拷一锟街伙拷锟斤拷锟斤拷锟芥储锟酵硷拷锟斤拷锟斤拷锟截讹拷锟矫伙拷锟结话锟斤拷氐锟斤拷锟斤拷荨锟斤拷锟斤拷锟斤拷嵌锟� WebSession 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
WebSession 锟接口讹拷锟斤拷
WebSession 锟接口讹拷锟斤拷锟斤拷 Web 锟结话锟侥伙拷锟斤拷锟斤拷锟斤拷锟斤拷
public interface WebSession {
String getId();
Mono save();
void invalidate();
Map getAttributes();
T getAttribute(String name);
void setAttribute(String name, T value);
default Mono getAttributeOrDefault(String name, Supplier defaultValue);
// 省锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷...
}
WebSession 锟斤拷实锟斤拷锟竭硷拷
锟结话锟斤拷锟斤拷锟斤拷WebSession 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫达拷锟斤拷锟斤拷通锟斤拷锟斤拷 ServerWebExchange 锟斤拷锟斤拷锟斤拷
锟斤拷锟皆癸拷锟斤拷锟斤拷锟结话锟斤拷锟皆存储锟斤拷 getAttributes() 锟斤拷锟截碉拷 Map 锟叫ｏ拷锟斤拷锟斤拷锟芥储锟酵硷拷锟斤拷锟矫伙拷锟截讹拷锟斤拷锟斤拷息锟斤拷
锟届步锟斤拷锟芥：save() 锟斤拷锟斤拷锟届步锟斤拷锟斤拷峄帮拷锟斤拷模锟斤拷锟斤拷锟斤拷锟芥及锟斤拷锟斤拷锟斤拷写锟斤拷撞锟芥储锟斤拷
锟结话失效锟斤拷invalidate() 锟斤拷锟斤拷锟斤拷锟斤拷使锟结话锟斤拷效锟斤拷确锟斤拷锟结话锟斤拷锟捷诧拷锟劫匡拷锟矫★拷
锟结话 ID 锟斤拷锟斤拷锟斤拷每锟斤拷 WebSession 实锟斤拷锟斤拷锟斤拷一锟斤拷唯一锟斤拷 id锟斤拷锟斤拷锟节憋拷识锟截讹拷锟斤拷锟矫伙拷锟结话锟斤拷
默锟斤拷值锟斤拷取锟斤拷getAttributeOrDefault() 锟斤拷锟斤拷锟结供锟斤拷一锟街憋拷莸姆锟绞斤拷锟斤拷锟饺★拷锟斤拷锟街碉拷锟斤拷锟斤拷锟斤拷锟皆诧拷锟斤拷锟节ｏ拷锟津返伙拷默锟斤拷值锟斤拷
锟结话锟侥存储锟酵硷拷锟斤拷
WebSession 锟斤拷实锟斤拷通锟斤拷锟斤拷要锟斤拷锟斤拷锟斤拷锟铰凤拷锟芥：
锟结话锟侥达拷锟斤拷锟酵帮拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫ｏ拷WebSession 锟斤拷锟皆憋拷锟斤拷锟斤拷锟酵绑定碉拷 ServerWebExchange锟斤拷
ServerWebExchange exchange = ...;
Mono sessionMono = exchange.getSession();
sessionMono.flatMap(session -> {
// 使锟矫会话
return session.save();
});
小锟斤拷一锟斤拷
WebSession 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷锟节癸拷锟斤拷 Web 锟结话锟侥接口★拷锟斤拷锟结供锟斤拷一锟斤拷锟斤拷锟侥凤拷式锟斤拷锟芥储锟酵硷拷锟斤拷锟斤拷锟矫伙拷锟结话锟斤拷氐锟斤拷锟斤拷荩锟酵敝э拷锟斤拷觳斤拷锟斤拷锟斤拷投锟斤拷执娲⒀★拷睢Ｍ拷锟� WebSession锟斤拷锟斤拷锟斤拷锟竭匡拷锟斤拷锟斤拷锟斤拷实锟斤拷锟矫伙拷锟结话锟斤拷锟劫和癸拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫革拷锟皆伙拷锟矫伙拷锟斤拷锟斤拷锟� Web 应锟矫★拷
锟斤拷实锟斤拷应锟斤拷锟叫ｏ拷锟斤拷锟斤拷锟竭匡拷锟皆革拷锟斤拷锟斤拷要选锟斤拷同锟侥会话锟芥储实锟街ｏ拷锟斤拷锟斤拷使锟斤拷 Spring Session 锟斤拷目锟结供锟侥讹拷锟街存储锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟� Redis锟斤拷Hazelcast锟斤拷JDBC 锟饺★拷锟斤拷些实锟斤拷通锟斤拷锟结处锟斤拷锟结话锟侥达拷锟斤拷锟斤拷锟斤拷锟芥、失效锟斤拷锟竭硷拷锟斤拷锟斤拷锟斤拷 WebSession 锟接口斤拷锟叫硷拷锟缴★拷
Reactive Streams 锟斤拷一锟斤拷锟芥范锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟届步锟斤拷锟斤拷锟斤拷锟侥接口猴拷锟斤拷为锟斤拷锟皆憋拷锟节诧拷同锟侥匡拷涂锟斤拷之锟斤拷实锟街伙拷锟斤拷锟斤拷锟皆★拷Spring WebFlux 锟斤拷为锟斤拷应式锟斤拷痰锟揭伙拷锟斤拷郑锟斤拷锟窖� Reactive Streams 锟芥范锟斤拷锟斤拷锟斤拷锟角讹拷 Reactive Streams 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
Reactive Streams 锟斤拷锟侥接匡拷
Reactive Streams 锟芥范锟斤拷锟斤拷锟斤拷锟斤拷锟铰硷拷锟斤拷锟斤拷锟侥接口ｏ拷
Publisher
锟斤拷锟斤拷锟斤拷锟竭ｏ拷锟斤拷示锟斤拷锟皆诧拷锟斤拷锟斤拷锟捷碉拷源头锟斤拷
Subscriber
锟斤拷锟斤拷锟斤拷锟竭ｏ拷锟斤拷示锟斤拷锟秸诧拷锟斤拷锟斤拷锟斤拷锟捷碉拷锟斤拷锟斤拷锟竭★拷
Subscription
锟斤拷锟斤拷锟侥癸拷系锟斤拷锟斤拷锟节癸拷锟斤拷锟斤拷锟捷碉拷锟斤拷锟斤拷头锟斤拷汀锟�
Processor
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 Publisher 锟斤拷 Subscriber 锟侥斤拷锟斤拷濉�
Publisher 锟接匡拷
Publisher 锟接匡拷锟斤拷 Reactive Streams 锟侥猴拷锟侥ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷谓锟斤拷锟斤拷锟斤拷锟斤拷透锟� Subscriber锟斤拷
public interface Publisher
{
void subscribe(
Subscriber
s);
}
subscribe(`Subscriber s`)锟斤拷锟斤拷锟斤拷 Subscriber 锟斤拷锟斤拷 Publisher锟斤拷
Subscriber 锟接匡拷
Subscriber 锟接口讹拷锟斤拷锟斤拷锟斤拷未锟斤拷锟斤拷锟� Publisher 锟斤拷锟秸碉拷锟斤拷锟斤拷锟捷ｏ拷
public interface Subscriber {
void onSubscribe(Subscription s);
void onNext(T t);
void onError(Throwable t);
void onComplete();
}
Subscription 锟接匡拷
Subscription 锟接匡拷锟斤拷锟节癸拷锟斤拷 Subscriber 锟斤拷 Publisher 之锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟�
public interface Subscription {
void request(long n);
void cancel();
}
Processor 锟接匡拷
Processor 锟斤拷 Publisher 锟斤拷 Subscriber 锟侥斤拷锟斤拷澹拷锟斤拷越锟斤拷锟斤拷锟斤拷莶锟斤拷锟斤拷锟斤拷碌锟斤拷锟斤拷锟斤拷锟斤拷锟�
public interface Processor extends Subscriber, Publisher {
// 锟教筹拷锟斤拷 Subscriber 锟斤拷 Publisher 锟侥凤拷锟斤拷
}
源锟斤拷实锟斤拷锟竭硷拷
锟斤拷锟斤拷
小锟斤拷一锟斤拷
Reactive Streams 锟芥范锟结供锟斤拷一锟斤拷锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟捷达拷锟斤拷模锟酵ｏ拷Spring WebFlux 通锟斤拷实锟斤拷锟斤拷些锟接口ｏ拷支锟斤拷锟斤拷应式锟斤拷獭锟斤拷锟斤拷锟侥ｏ拷锟斤拷锟斤拷锟较低筹拷锟斤拷锟叫э拷卮锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟杰和匡拷锟斤拷锟斤拷锟皆★拷锟斤拷锟斤拷锟竭匡拷锟斤拷锟斤拷锟斤拷 Reactive Streams 锟芥范锟结供锟侥接口和伙拷锟狡ｏ拷锟斤拷锟斤拷锟斤拷效锟斤拷锟斤拷锟皆碉拷锟斤拷应式应锟矫筹拷锟斤拷
Reactor 锟斤拷一锟斤拷锟斤拷锟斤拷 Reactive Streams 锟芥范锟侥库，锟斤拷锟节癸拷锟斤拷锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应式应锟矫筹拷锟斤拷锟斤拷锟斤拷 Spring WebFlux 锟侥凤拷应式锟斤拷袒锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷嵌锟� Reactor 锟斤拷锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
Reactor 锟斤拷锟斤拷锟斤拷锟�
Reactor 锟结供锟斤拷锟斤拷锟铰猴拷锟斤拷锟斤拷锟斤拷锟�
Flux 锟斤拷 Mono 锟斤拷实锟斤拷锟竭硷拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷通锟斤拷锟斤拷态锟斤拷锟斤拷锟斤拷锟斤拷 Flux.just(), Mono.just()锟斤拷锟斤拷锟届函锟斤拷锟斤拷锟斤拷 Flux 锟斤拷 Mono 实锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷锟斤拷Reactor 锟结供锟剿丰富锟侥诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 map锟斤拷flatMap锟斤拷filter 锟饺★拷
锟斤拷锟侥伙拷锟狡ｏ拷通锟斤拷 subscribe() 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟结供 Subscriber 锟斤拷锟斤拷锟斤拷锟斤拷锟捷★拷
锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 request() 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟捷碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷锟酵ｏ拷锟斤拷锟斤拷通锟斤拷 onNext() 锟斤拷锟斤拷锟斤拷锟酵革拷锟斤拷锟斤拷锟竭★拷
锟斤拷锟斤拷锟斤拷锟缴达拷锟斤拷锟斤拷通锟斤拷 onError() 锟斤拷 onComplete() 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥达拷锟斤拷锟斤拷锟斤拷锟铰硷拷锟斤拷
Scheduler 锟斤拷实锟斤拷锟竭硷拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 Scheduler 实锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 Schedulers.parallel() 锟斤拷锟斤拷锟斤拷锟叫碉拷锟斤拷锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷龋锟绞癸拷锟� schedule() 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟今，凤拷锟斤拷 Mono 锟斤拷 Flux锟斤拷
锟斤拷锟斤拷锟斤拷锟狡ｏ拷Scheduler 锟斤拷锟皆匡拷锟斤拷锟斤拷锟斤拷牟锟斤拷锟街达拷校锟斤拷锟斤拷锟斤拷锟斤拷撇锟斤拷锟斤拷锟斤拷锟斤拷锟�
锟届步执锟叫ｏ拷锟斤拷锟斤拷锟节凤拷锟斤拷锟斤拷锟斤拷锟竭程筹拷锟斤拷锟届步执锟叫★拷
源锟斤拷实锟街诧拷锟斤拷
锟斤拷锟斤拷锟斤拷锟斤拷源锟斤拷锟斤拷锟斤拷 Flux 锟斤拷 Mono 实锟斤拷锟斤拷为锟斤拷锟斤拷源锟斤拷
应锟矫诧拷锟斤拷锟斤拷锟斤拷使锟矫诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷转锟斤拷锟斤拷锟斤拷锟剿伙拷锟斤拷稀锟�
锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 onErrorResume() 锟斤拷 doOnError() 锟饺诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷压锟斤拷锟斤拷锟斤拷使锟斤拷 onBackpressureBuffer() 锟斤拷 onBackpressureDrop() 锟饺诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷压锟斤拷
锟斤拷锟侥猴拷锟斤拷锟窖ｏ拷锟斤拷锟斤拷 subscribe() 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟结供 Subscriber 锟斤拷锟斤拷锟斤拷锟斤拷锟捷★拷
锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 Scheduler 锟斤拷锟斤拷锟届步锟斤拷锟斤拷
锟斤拷源锟斤拷锟斤拷锟斤拷使锟斤拷 dispose() 锟斤拷锟斤拷锟节诧拷锟斤拷锟斤拷要时锟酵凤拷锟斤拷源锟斤拷
小锟斤拷一锟斤拷
Reactor 锟斤拷通锟斤拷 Flux锟斤拷Mono 锟斤拷 Scheduler 锟斤拷锟斤拷锟斤拷锟斤拷峁╋拷锟揭伙拷锟角匡拷锟侥凤拷式锟斤拷锟斤拷锟斤拷锟斤拷应式应锟矫筹拷锟斤拷锟斤拷锟斤拷循 Reactive Streams 锟芥范锟斤拷支锟斤拷锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷Reactor 锟侥诧拷锟斤拷锟斤拷锟结富锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷实锟街革拷锟接碉拷锟斤拷锟捷达拷锟斤拷锟竭硷拷锟斤拷同时锟斤拷锟斤拷锟斤拷锟结供锟斤拷锟斤拷锟侥诧拷锟斤拷锟斤拷锟狡和碉拷锟饺伙拷锟狡ｏ拷锟斤拷锟斤拷应锟斤拷同锟斤拷应锟矫筹拷锟斤拷锟斤拷
Reactor 锟斤拷锟斤拷锟斤拷锟窖э拷锟斤拷峁╋拷锟斤拷锟绞斤拷锟斤拷锟斤拷荽锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷每锟斤拷锟斤拷锟斤拷芄锟斤拷锟揭伙拷锟街憋拷酆锟斤拷锟斤拷姆锟绞斤拷锟斤拷锟斤拷锟接κ较低筹拷锟酵拷锟� Reactor锟斤拷锟斤拷锟斤拷锟竭匡拷锟皆筹拷锟斤拷锟斤拷锟斤拷执锟接诧拷锟斤拷亩锟斤拷锟斤拷锟皆ｏ拷锟斤拷锟接︼拷贸锟斤拷锟斤拷锟斤拷锟杰和匡拷锟斤拷锟斤拷锟皆★拷
WebClient 锟斤拷 Spring WebFlux 锟斤拷锟斤拷锟节凤拷锟斤拷 HTTP 锟斤拷锟斤拷姆锟斤拷锟斤拷锟斤拷锟接κ斤拷突锟斤拷恕锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟绞斤拷姆锟绞斤拷锟斤拷锟斤拷锟斤拷蟛⒋锟斤拷锟斤拷锟接︼拷锟斤拷锟斤拷锟斤拷嵌锟� WebClient 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
WebClient 锟接口讹拷锟斤拷
WebClient 锟结供锟剿凤拷锟斤拷锟斤拷锟斤拷姆锟斤拷锟斤拷锟�
public interface WebClient {
default URI uri() {
return URI.create(this.baseUrl);
}
Mono getForObject(String url, Class responseType, Object... uriVariables);
Flux getForFlux(String url, Class elementType, Object... uriVariables);
// 锟斤拷锟斤拷 HTTP 锟斤拷锟斤拷锟斤拷锟斤拷锟截ｏ拷锟斤拷锟斤拷 postForObject, putForObject 锟斤拷
}
WebClient.Builder 锟斤拷锟斤拷锟斤拷
WebClient 锟斤拷实锟斤拷锟斤拷通锟斤拷 WebClient.Builder 锟斤拷锟斤拷锟侥ｏ拷
public final class WebClient.Builder {
private final String baseUrl;
public Builder(String baseUrl) {
this.baseUrl = baseUrl;
}
public WebClient build() {
return new ExchangeStrategiesDefaultWebClient(this);
}
// 锟斤拷锟斤拷锟斤拷锟斤拷选锟筋，锟斤拷锟斤拷锟斤拷锟斤拷 ExchangeStrategies, ClientHttpRequestFactory 锟斤拷
}
锟斤拷锟襟构斤拷锟酵凤拷锟斤拷
锟斤拷锟斤拷 WebClient 实锟斤拷锟斤拷使锟斤拷 WebClient.Builder 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 WebClient 实锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 WebClient 锟侥凤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷头锟斤拷锟斤拷询锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷取锟�
锟斤拷锟斤拷锟斤拷锟襟：碉拷锟斤拷 HTTP 锟斤拷锟斤拷锟斤拷应锟侥凤拷锟斤拷锟斤拷锟斤拷 getForObject锟斤拷postForObject锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷应锟斤拷 Mono 锟斤拷 Flux 锟斤拷锟斤拷式锟斤拷锟截ｏ拷锟斤拷锟皆斤拷一锟斤拷锟斤拷锟斤拷锟斤拷
源锟斤拷实锟街诧拷锟斤拷
WebClient webClient = WebClient.builder().baseUrl("http://example.com").build();
锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 WebClient 锟侥凤拷锟斤拷锟斤拷式锟斤拷锟斤拷锟斤拷锟斤拷
Mono personMono = webClient.get()
.uri("/person/{id}", id)
.retrieve()
.bodyToMono(Person.class);
锟斤拷锟斤拷锟斤拷锟襟并伙拷取锟斤拷应锟斤拷锟斤拷锟斤拷 retrieve() 锟斤拷锟斤拷锟斤拷指锟斤拷锟斤拷应锟斤拷转锟斤拷锟侥凤拷式锟斤拷
锟斤拷应锟斤拷转锟斤拷锟斤拷使锟斤拷 bodyToMono 锟斤拷 bodyToFlux 锟饺凤拷锟斤拷锟斤拷锟斤拷应锟斤拷转锟斤拷为指锟斤拷锟斤拷锟酵★拷
锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷 onErrorResume 锟斤拷 onErrorMap 锟饺诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟杰凤拷锟斤拷锟侥达拷锟斤拷
锟斤拷锟侥猴拷锟斤拷锟窖ｏ拷锟斤拷锟斤拷锟斤拷应锟斤拷 Mono 锟斤拷 Flux 锟斤拷锟斤拷锟斤拷锟斤拷锟捷★拷
锟斤拷锟斤拷锟斤拷锟届步锟斤拷锟斤拷
WebClient 支锟街诧拷锟斤拷锟斤拷锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟皆凤拷锟斤拷锟斤拷锟侥凤拷式锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
小锟斤拷一锟斤拷
WebClient 锟斤拷 Spring WebFlux 锟斤拷一锟斤拷强锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷诠锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟接κ� HTTP 锟酵伙拷锟剿★拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷式锟侥凤拷式锟斤拷锟斤拷锟斤拷锟襟，诧拷通锟斤拷 Reactive Streams 锟芥范支锟斤拷锟届步锟斤拷锟捷达拷锟斤拷锟斤拷WebClient 锟斤拷锟斤拷锟绞癸拷锟斤拷锟斤拷浅锟斤拷屎锟斤拷锟斤拷锟接κ接︼拷贸锟斤拷锟斤拷锟绞癸拷茫锟斤拷锟斤拷猿锟斤拷锟斤拷锟斤拷锟街达拷锟届步锟斤拷痰锟斤拷锟斤拷疲锟斤拷锟斤拷应锟矫筹拷锟斤拷锟斤拷锟斤拷芎涂锟斤拷锟斤拷锟斤拷浴锟�
锟斤拷锟斤拷锟竭匡拷锟斤拷锟斤拷锟缴碉拷使锟斤拷 WebClient 锟斤拷锟解部锟斤拷锟斤拷锟斤拷锟酵拷牛锟斤拷锟饺★拷锟斤拷荩锟斤拷锟斤拷锟斤拷锟接κ斤拷姆锟绞斤拷锟斤拷锟斤拷锟叫╋拷锟斤拷荨锟酵拷锟� WebClient锟斤拷Spring WebFlux 应锟矫筹拷锟斤拷锟斤拷锟斤拷薹锟截硷拷锟缴碉拷锟斤拷锟斤拷锟斤拷锟接κ较低筹拷小锟�
Spring Data Reactive 锟斤拷 Spring Data 锟斤拷目锟斤拷一锟斤拷锟街ｏ拷锟斤拷锟结供锟斤拷一锟斤拷锟斤拷锟节凤拷锟斤拷锟斤拷应式锟斤拷锟捷存储锟侥筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷式锟斤拷锟斤拷应式锟侥凤拷式锟斤拷锟斤拷锟斤拷锟捷凤拷锟绞和诧拷锟斤拷锟斤拷支锟斤拷锟斤拷 MongoDB锟斤拷Redis锟斤拷R2DBC锟斤拷Reactive Relational Database Connectivity锟斤拷锟斤拷锟斤拷应式锟斤拷锟捷库。锟斤拷锟斤拷锟角讹拷 Spring Data Reactive 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
Spring Data Reactive 锟斤拷锟侥革拷锟斤拷
Reactive Repository 锟接口讹拷锟斤拷
public interface ReactiveCrudRepository extends ReactiveRepository {
Mono save(T entity);
Flux findAll();
Mono findById(ID id);
Mono deleteById(ID id);
// 锟斤拷锟斤拷锟斤拷锟斤拷...
}
锟斤拷应式锟斤拷锟捷凤拷锟绞诧拷锟斤拷
锟斤拷锟斤拷实锟斤拷锟洁：锟斤拷锟斤拷一锟斤拷实锟斤拷锟洁，使锟斤拷 JPA 注锟斤拷锟斤拷锟斤拷菘锟斤拷囟锟斤拷锟阶拷锟斤拷锟斤拷侄巍锟�
锟斤拷锟斤拷挚锟接口ｏ拷锟斤拷锟斤拷一锟斤拷锟教筹拷锟斤拷 ReactiveCrudRepository 锟斤拷锟截讹拷锟斤拷锟捷匡拷锟� Repository 锟接口★拷
public interface MyEntityRepository extends ReactiveCrudRepository {
// 锟斤拷锟斤拷锟斤拷锟斤拷锟皆讹拷锟斤拷锟窖拷锟斤拷锟�
}
锟斤拷锟斤拷锟斤拷锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷应式锟斤拷锟斤拷源锟酵客伙拷锟剿ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷 MongoDB 锟斤拷 ReactiveMongoDatabase锟斤拷
使锟矫仓库：锟节凤拷锟斤拷锟阶拷氩⑹癸拷貌挚锟接口斤拷锟斤拷锟斤拷锟捷诧拷锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷询锟斤拷使锟矫仓匡拷涌锟斤拷峁╋拷姆锟斤拷锟斤拷锟斤拷远锟斤拷锟斤拷询锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷询锟斤拷
锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷询锟斤拷锟斤拷锟绞癸拷锟� Mono 锟斤拷 Flux 锟斤拷锟届步锟斤拷锟皆★拷
源锟斤拷实锟斤拷锟竭硷拷
实锟斤拷筒挚舛拷澹猴拷锟斤拷锟斤拷锟斤拷锟绞碉拷锟酵仓匡拷涌凇锟�
Spring 应锟斤拷锟斤拷锟斤拷锟侥ｏ拷Spring 应锟斤拷锟斤拷锟斤拷锟斤拷扫锟斤拷挚锟接口诧拷锟斤拷锟斤拷锟斤拷锟斤拷实锟街★拷
执锟叫诧拷询锟斤拷锟斤拷锟斤拷锟矫仓匡拷涌诘姆锟斤拷锟绞憋拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟阶拷锟轿拷锟斤拷菘锟斤拷锟斤拷锟斤拷
锟斤拷锟斤拷锟阶帮拷锟斤拷锟窖拷锟斤拷锟斤拷装锟斤拷 Mono 锟斤拷 Flux 锟叫凤拷锟截★拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟杰凤拷锟斤拷锟斤拷锟届常锟斤拷锟斤拷锟斤拷锟斤拷转锟斤拷为锟斤拷锟绞碉拷锟斤拷应锟斤拷
锟斤拷应式锟斤拷锟斤拷锟狡ｏ拷使锟斤拷 Reactive Streams 锟芥范锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷应式锟斤拷锟捷匡拷锟斤拷锟绞撅拷锟�
@Service
public class MyEntityService {
private final MyEntityRepository repository;
@Autowired
public MyEntityService(MyEntityRepository repository) {
this.repository = repository;
}
public Mono addMyEntity(MyEntity entity) {
return repository.save(entity);
}
public Flux getAllMyEntities() {
return repository.findAll();
}
}
小锟斤拷一锟斤拷
Spring Data Reactive 通锟斤拷锟结供锟斤拷应式锟街匡拷涌冢锟斤拷锟斤拷锟斤拷锟接κ斤拷锟斤拷莘锟斤拷实锟绞碉拷帧锟斤拷锟斤拷锟斤拷锟斤拷锟� Reactive Streams 锟芥范锟斤拷锟斤拷锟斤拷锟皆凤拷锟斤拷锟斤拷锟侥凤拷式锟斤拷锟斤拷锟斤拷锟捷匡拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟矫筹拷锟斤拷锟斤拷锟斤拷芎涂锟斤拷锟斤拷锟斤拷浴锟斤拷锟斤拷锟斤拷呖锟斤拷锟斤拷锟斤拷傻囟锟斤拷锟街匡拷涌冢锟斤拷锟绞癸拷锟� Spring 锟结供锟斤拷 CRUD 锟斤拷锟斤拷锟斤拷锟皆讹拷锟斤拷锟窖拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷莶锟斤拷锟斤拷锟�
Spring Data Reactive 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟街达拷锟斤拷应式锟斤拷锟侥ｏ拷秃涂锟杰ｏ拷锟斤拷 WebFlux锟斤拷锟睫缝集锟缴ｏ拷为锟斤拷锟斤拷锟斤拷应式应锟矫筹拷锟斤拷锟结供锟斤拷强锟斤拷锟斤拷锟斤拷莘锟斤拷锟斤拷锟斤拷锟斤拷锟酵拷锟绞癸拷锟� Spring Data Reactive锟斤拷锟斤拷锟斤拷锟竭匡拷锟皆癸拷锟斤拷锟斤拷效锟斤拷锟斤拷锟皆碉拷应锟矫筹拷锟斤拷同时锟斤拷锟街达拷锟斤拷募锟斤拷锟皆和匡拷维锟斤拷锟皆★拷
Spring Security Reactive 锟斤拷 Spring Security 锟斤拷锟斤拷应式锟斤拷展锟斤拷锟斤拷为锟斤拷应式应锟矫筹拷锟斤拷锟结供锟剿帮拷全锟斤拷锟斤拷证支锟街★拷锟斤拷锟斤拷锟角讹拷 Spring Security Reactive 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
Spring Security Reactive 锟斤拷锟侥革拷锟斤拷
ServerSecurityContextRepository 锟接口讹拷锟斤拷
public interface ServerSecurityContextRepository {
Mono save(ServerSecurityContext context);
Mono load();
void invalidate();
}
ServerHttpSecurity 锟斤拷锟斤拷
public class ServerHttpSecurity {
public ServerHttpSecurity(ReactiveAuthenticationManager authentication) {
// ...
}
public SecurityWebFilterChain build() {
// ...
}
public ServerHttpSecurity authorizeExchange(Consumer configurer) {
// ...
}
// 锟斤拷锟斤拷锟斤拷锟矫凤拷锟斤拷锟斤拷锟斤拷锟斤拷 cors, csrf, formLogin, httpBasic 锟斤拷
}
锟斤拷应式锟斤拷证锟斤拷锟斤拷权锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷证锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 ReactiveAuthenticationManager锟斤拷
锟斤拷锟斤拷锟矫伙拷锟斤拷锟今：达拷锟斤拷锟斤拷锟斤拷锟斤拷 ReactiveUserDetailsService锟斤拷
锟斤拷锟斤拷 ServerHttpSecurity锟斤拷使锟斤拷 ServerHttpSecurity 锟斤拷锟斤拷锟斤拷全锟斤拷锟皆★拷
锟斤拷锟矫帮拷全锟斤拷锟斤拷锟侥存储锟斤拷锟斤拷锟斤拷 ServerSecurityContextRepository锟斤拷
注锟斤拷 WebFilter锟斤拷锟斤拷 SecurityWebFilterChain 注锟结到 Web 锟斤拷锟斤拷锟斤拷锟斤拷锟叫★拷
锟斤拷锟斤拷锟斤拷证锟斤拷锟斤拷权锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫ｏ拷Spring Security Reactive 锟斤拷锟斤拷锟斤拷锟襟并达拷锟斤拷锟斤拷证锟斤拷锟斤拷权锟斤拷
源锟斤拷实锟斤拷锟竭硷拷
锟斤拷始锟斤拷锟斤拷锟斤拷应锟矫筹拷锟斤拷锟斤拷锟斤拷时锟斤拷Spring Security Reactive 锟斤拷始锟斤拷锟斤拷全锟斤拷锟矫★拷
锟斤拷锟斤拷锟斤拷锟截ｏ拷SecurityWebFilterChain 锟斤拷锟斤拷锟斤拷锟襟并革拷锟斤拷锟斤拷锟矫的帮拷全锟斤拷锟皆斤拷锟叫达拷锟斤拷锟斤拷
锟斤拷证锟斤拷使锟斤拷 ReactiveAuthenticationManager 锟斤拷锟斤拷锟矫伙拷锟斤拷证锟斤拷
锟斤拷权锟斤拷锟斤拷锟斤拷 ServerHttpSecurity 锟斤拷锟矫碉拷锟斤拷权锟斤拷锟斤拷使锟斤拷 ReactiveAccessDecisionManager 锟斤拷锟叫凤拷锟绞匡拷锟狡★拷
锟斤拷全锟斤拷锟斤拷锟侥ｏ拷使锟斤拷 ServerSecurityContextRepository 锟斤拷锟斤拷每锟斤拷锟斤拷锟斤拷陌锟饺拷锟斤拷锟斤拷摹锟�
锟届常锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷全锟斤拷氐锟斤拷斐ｏ拷锟斤拷锟斤拷锟街なэ拷芑锟斤拷锟绞拒撅拷锟斤拷
锟斤拷应锟斤拷锟斤拷锟斤拷锟斤拷证锟斤拷锟斤拷权锟侥斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟斤拷馗锟斤拷突锟斤拷恕锟�
小锟斤拷一锟斤拷
Spring Security Reactive 为锟斤拷应式应锟矫筹拷锟斤拷锟结供锟斤拷全锟斤拷陌锟饺э拷帧锟斤拷锟斤拷锟斤拷锟� Spring Security 锟侥猴拷锟侥革拷锟筋，锟斤拷通锟斤拷锟斤拷应式锟斤拷锟侥ｏ拷锟斤拷峁╋拷锟斤拷觳斤拷锟斤拷锟斤拷锟斤拷锟斤拷陌锟饺拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵拷锟� ServerHttpSecurity 锟斤拷锟斤拷锟矫ｏ拷锟斤拷锟斤拷锟竭匡拷锟斤拷锟斤拷锟截讹拷锟斤拷锟斤拷证锟斤拷锟斤拷权锟斤拷锟皆ｏ拷锟斤拷锟斤拷锟姐不同应锟矫筹拷锟斤拷陌锟饺拷锟斤拷锟�
Spring Security Reactive 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟� Spring WebFlux 锟睫缝集锟缴ｏ拷为锟斤拷应式 Web 应锟矫筹拷锟斤拷锟结供强锟斤拷陌锟饺拷锟斤拷稀锟酵拷锟绞癸拷锟� Spring Security Reactive锟斤拷锟斤拷锟斤拷锟竭匡拷锟皆癸拷锟斤拷锟斤拷全锟斤拷锟缴匡拷锟斤拷锟斤拷锟斤拷维锟斤拷锟斤拷锟斤拷应式应锟矫筹拷锟斤拷
HttpHandler 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷一锟斤拷锟斤拷锟节达拷锟斤拷 HTTP 锟斤拷锟斤拷慕涌冢锟斤拷锟斤拷锟斤拷锟接κ斤拷锟斤拷模锟斤拷锟斤拷锟斤拷筒锟轿碉拷 HTTP 锟斤拷锟斤拷锟斤拷锟斤拷约锟斤拷HttpHandler 锟斤拷为一锟斤拷锟斤拷同锟侥接口ｏ拷锟斤拷锟斤拷锟斤拷同锟斤拷锟斤拷锟斤拷时锟斤拷锟斤拷通锟斤拷锟斤拷同锟斤拷实锟斤拷锟斤拷锟斤拷锟斤拷 HTTP 锟斤拷锟斤拷锟斤拷锟斤拷锟角讹拷 HttpHandler 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
HttpHandler 锟接口讹拷锟斤拷
HttpHandler 锟接口讹拷锟斤拷锟斤拷一锟斤拷 handle 锟斤拷锟斤拷锟斤拷锟斤拷锟节达拷锟斤拷锟斤拷锟斤拷锟� HTTP 锟斤拷锟襟并凤拷锟斤拷一锟斤拷锟斤拷应锟斤拷
public interface HttpHandler {
Mono handle(ServerHttpRequest request, ServerHttpResponse response);
}
handle(ServerHttpRequest request, ServerHttpResponse response)锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟襟并癸拷锟斤拷锟斤拷应锟斤拷
锟斤拷锟斤拷职锟斤拷
HttpHandler 锟侥猴拷锟斤拷职锟斤拷锟斤拷锟斤拷锟�
锟斤拷锟襟，憋拷示锟届步锟斤拷锟斤拷应锟斤拷锟斤拷锟斤拷锟教★拷
实锟街诧拷锟斤拷
锟斤拷锟斤拷 HttpHandler 实锟斤拷锟斤拷实锟斤拷 HttpHandler 锟接口伙拷使锟斤拷锟斤拷锟叫碉拷实锟街★拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 handle 锟斤拷锟斤拷锟叫憋拷写锟竭硷拷锟皆达拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷路锟缴★拷锟斤拷证锟斤拷业锟斤拷锟斤拷锟饺★拷
锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷拇锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷锟斤拷状态锟诫、锟斤拷应头锟斤拷锟斤拷应锟藉。
锟斤拷锟斤拷 Mono
锟斤拷锟斤拷锟斤拷一锟斤拷 Mono
锟斤拷锟斤拷示锟斤拷应锟窖撅拷锟斤拷锟酵或将憋拷锟斤拷锟酵★拷
锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 handle 锟斤拷锟斤拷锟叫达拷锟斤拷锟斤拷锟杰凤拷锟斤拷锟斤拷锟届常锟斤拷确锟斤拷锟斤拷锟角憋拷锟绞碉拷锟斤拷转锟斤拷为锟斤拷应锟斤拷
示锟斤拷实锟斤拷
锟斤拷锟斤拷锟斤拷一锟斤拷锟津单碉拷 HttpHandler 实锟斤拷示锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷一锟斤拷锟教讹拷锟斤拷锟斤拷应锟斤拷
public class SimpleHttpHandler implements HttpHandler {
@Override
public Mono handle(ServerHttpRequest request, ServerHttpResponse response) {
String body = "Hello, World!";
response.getHeaders().add("Content-Type", "text/plain");
return response.writeWith(Flux.just(DataBufferUtils.wrap(body)));
}
}
小锟斤拷一锟斤拷
HttpHandler 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷锟节达拷锟斤拷 HTTP 锟斤拷锟斤拷幕锟斤拷锟斤拷涌凇锟斤拷锟斤拷峁╋拷锟揭伙拷锟斤拷虻ザ锟斤拷锟斤拷姆锟绞斤拷锟斤拷锟斤拷锟� HTTP 锟斤拷锟斤拷凸锟斤拷锟斤拷锟接︼拷锟酵拷锟绞碉拷锟� HttpHandler 锟接口ｏ拷锟斤拷锟斤拷锟竭匡拷锟皆匡拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟教ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟揭碉拷锟斤拷呒锟斤拷锟斤拷锟斤拷锟斤拷锟接︼拷锟斤拷锟斤拷锟�
HttpHandler 锟斤拷实锟街匡拷锟斤拷锟斤拷锟斤拷锟斤拷 Spring WebFlux 锟斤拷锟斤拷锟斤拷锟� DispatcherHandler锟斤拷HandlerMapping锟斤拷HandlerAdapter 锟饺ｏ拷锟斤拷锟绞癸拷茫锟斤拷怨锟斤拷锟揭伙拷锟斤拷锟斤拷锟斤拷锟斤拷锟接κ� Web 应锟矫筹拷锟斤拷锟斤拷锟街低诧拷蔚慕涌锟轿拷锟揭拷叨榷锟斤拷频锟� Web 应锟矫筹拷锟斤拷锟结供锟斤拷强锟斤拷锟斤拷锟斤拷锟皆★拷
ContextPathCompositeHandler 锟斤拷 Spring WebFlux 锟叫碉拷一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵伙拷锟斤拷锟斤拷锟斤拷辖锟斤拷锟斤拷应锟矫筹拷锟斤拷映锟戒到锟斤拷同锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷锟斤拷context paths锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟节达拷统锟斤拷 Servlet 锟斤拷锟斤拷锟斤拷为每锟斤拷 Web 应锟矫筹拷锟斤拷锟斤拷锟矫诧拷同锟斤拷 URL 路锟斤拷锟斤拷
锟斤拷锟斤拷锟角讹拷 ContextPathCompositeHandler 锟斤拷锟斤拷锟皆达拷锟绞碉拷锟斤拷呒锟斤拷筒锟斤拷锟斤拷锟斤拷细锟斤拷锟斤拷锟斤拷
ContextPathCompositeHandler 锟接口讹拷锟斤拷
ContextPathCompositeHandler 实锟斤拷锟较诧拷锟斤拷一锟斤拷锟接口ｏ拷锟斤拷锟斤拷 HandlerMapping 锟接口碉拷一锟斤拷实锟街ｏ拷锟斤拷锟斤拷锟斤拷硕锟斤拷 Handler 锟斤拷锟斤拷每锟斤拷锟斤拷锟襟都癸拷锟斤拷一锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷锟斤拷
锟斤拷要锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷路锟斤拷映锟斤拷
ContextPathCompositeHandler 维锟斤拷锟斤拷一锟斤拷映锟戒，锟斤拷每锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷映锟戒到一锟斤拷 Handler锟斤拷
private final Map contextPaths = new ConcurrentHashMap<>();
锟斤拷锟斤拷应锟矫筹拷锟斤拷
应锟矫筹拷锟斤拷锟斤拷锟斤拷诔锟绞硷拷锟绞蓖拷锟� ContextPathCompositeHandler 锟斤拷 addHandler 锟斤拷锟斤拷锟斤拷锟接碉拷映锟斤拷锟叫ｏ拷
public void addHandler(String contextPath, HttpHandler handler) {
this.contextPaths.put(contextPath, handler);
// 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟绞侥Ｊ斤拷锟狡ワ拷锟斤拷锟斤拷锟阶拷锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷
updatePattern();
}
锟斤拷锟斤拷锟斤拷锟斤拷
ContextPathCompositeHandler 通锟斤拷 getHandler 锟斤拷锟斤拷锟斤拷确锟斤拷锟斤拷锟斤拷应锟斤拷锟斤拷锟侥革拷 Handler 锟斤拷锟斤拷锟斤拷
@Override
public Mono锟斤拷锟斤拷锟斤拷锟绞侥Ｊ�
ContextPathCompositeHandler 使锟斤拷锟斤拷锟斤拷锟斤拷锟绞斤拷锟狡ワ拷锟斤拷锟斤拷锟铰凤拷锟斤拷锟�
private void updatePattern() {
// 锟斤拷锟斤拷匹锟斤拷锟斤拷锟斤拷注锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟绞�
String regex = contextPaths.keySet().stream()
.map(this::toRegex)
.collect(Collectors.joining("|", "^(", ")$"));
this.compiledPattern = Pattern.compile(regex);
}
锟斤拷锟斤拷锟斤拷
锟斤拷锟矫伙拷锟斤拷业锟狡ワ拷锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷锟斤拷ContextPathCompositeHandler 锟结创锟斤拷一锟斤拷锟斤拷示 "Not Found" 锟侥达拷锟斤拷锟斤拷锟斤拷锟斤拷
private Mono createNotFoundError(ServerWebExchange exchange) {
return Mono.just(new HandlerAdapter() {
@Override
public boolean supports(Object handler) {
return true;
}
@Override
public Mono handle(ServerWebExchange exchange, Object handler) {
return ServerResponse.notFound().build().writeTo(exchange);
}
});
}
小锟斤拷一锟斤拷
ContextPathCompositeHandler 锟斤拷锟斤拷锟� Spring WebFlux 锟斤拷锟斤拷锟节斤拷锟斤拷锟接︼拷贸锟斤拷锟接筹拷涞斤拷锟酵拷锟斤拷锟斤拷锟铰凤拷锟斤拷锟� HandlerMapping 实锟街★拷锟斤拷通锟斤拷维锟斤拷一锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷锟斤拷 HttpHandler 锟斤拷映锟戒，锟斤拷锟斤拷每锟斤拷应锟矫筹拷锟斤拷锟斤拷锟斤拷锟皆硷拷锟斤拷锟斤拷锟斤拷路锟斤拷锟斤拷通锟斤拷锟斤拷锟斤拷锟斤拷锟绞狡ワ拷锟斤拷锟斤拷锟铰凤拷锟斤拷锟斤拷锟绞癸拷锟� HandlerAdapter 锟斤拷锟斤拷锟斤拷偷锟斤拷锟斤拷锟接︼拷拇锟斤拷锟斤拷锟斤拷锟�
锟斤拷锟斤拷锟斤拷锟侥Ｊ绞癸拷锟斤拷诘锟斤拷锟斤拷锟斤拷锟斤拷锟绞碉拷锟斤拷胁锟斤拷锟酵癸拷锟斤拷锟斤拷锟� WebFlux 应锟矫筹拷锟斤拷锟矫简单和革拷效锟斤拷每锟斤拷应锟矫筹拷锟津都匡拷锟斤拷锟斤拷锟皆硷拷锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷锟斤拷锟斤拷 ContextPathCompositeHandler 锟斤拷锟斤拷锟斤拷锟斤拷路锟缴碉拷锟斤拷确锟斤拷应锟矫筹拷锟斤拷锟斤拷锟斤拷锟斤拷
锟斤拷锟斤拷锟斤拷Spring WebFlux 锟斤拷芎锟斤拷锟斤拷锟斤拷锟斤拷全锟斤拷锟斤拷锟斤拷锟剿ｏ拷希锟斤拷锟斤拷锟皆帮拷锟斤拷锟斤拷全锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟� WebFlux锟斤拷原锟斤拷锟斤拷锟斤拷注锟斤拷锟斤拷锟界爱锟斤拷獭锟斤拷锟斤拷锟揭筹拷锟缴查看V锟斤拷每锟斤拷锟斤拷碌锟皆拷锟斤拷锟斤拷锟斤拷锟斤拷荩锟斤拷锟斤拷锟斤拷锟揭伙拷锟缴筹拷锟斤拷
全锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷ERA5锟斤拷锟斤拷锟截凤拷锟斤拷
锟侥讹拷锟斤拷锟斤拷学习锟斤拷锟斤拷锟斤拷锟界构锟斤拷锟斤拷锟铰ｏ拷
锟侥讹拷锟斤拷为Mate品锟斤拷盛锟戒：HarmonyOS NEXT锟接筹拷锟斤拷锟斤拷戏锟斤拷锟杰得碉拷锟斤拷锟斤拷头锟�
锟侥讹拷实锟街讹拷锟襟集猴拷锟斤拷DataTable锟斤拷锟洁互转锟斤拷
锟侥讹拷锟斤拷锟斤拷NEXT元锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟窖匡拷锟斤拷锟较硷拷锟斤拷品
锟侥讹拷锟结巢锟斤拷锟叫★拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟狡硷拷锟截闭凤拷锟斤拷
锟侥讹拷锟斤拷锟斤拷锟紸rcMap锟斤拷锟斤拷锟叫斤拷锟斤拷栅锟斤拷图锟斤拷锟截诧拷锟斤拷锟斤拷锟斤拷
锟侥讹拷锟斤拷讯锟斤拷锟斤拷锟竭客凤拷锟斤拷营锟斤拷系统锟斤拷锟斤拷
锟侥讹拷锟斤拷锟节猴拷锟斤拷NEXT锟斤拷血锟斤拷锟脚达拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
锟侥讹拷5. Spring Cloud OpenFeign 锟斤拷锟斤拷式 WebService 锟酵伙拷锟剿的筹拷锟斤拷细使锟斤拷
锟侥讹拷Java锟斤拷锟斤拷模式锟斤拷锟斤拷态锟斤拷锟斤拷锟酵讹拷态锟斤拷锟斤拷锟侥对比凤拷锟斤拷
锟侥讹拷Win11锟绞记憋拷锟斤拷锟皆讹拷锟斤拷锟斤拷应锟矫碉拷锟斤拷色锟斤拷锟斤拷示锟斤拷锟斤拷
锟侥讹拷
锟斤拷锟节猴拷锟斤拷锟斤拷锟斤拷系锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟�锟斤拷锟斤拷站锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟狡硷拷锟斤拷锟斤拷
频锟斤拷 锟斤拷锟斤拷频锟斤拷锟斤拷锟斤拷锟斤拷专锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷卓锟斤拷锟斤拷锟�锟斤拷app锟斤拷锟斤拷
锟狡硷拷 锟斤拷原锟斤拷锟斤拷锟斤拷锟斤拷锟铰帮拷锟斤拷锟斤拷锟斤拷锟杰匡拷锟斤拷锟斤拷锟截诧拷锟斤拷
锟斤拷锟斤拷 锟斤拷锟斤拷色锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 锟斤拷锟斤拷锟�锟斤拷锟斤拷战锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
扫锟斤拷维锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟街伙拷锟芥本锟斤拷
扫锟斤拷维锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷微锟脚癸拷锟节号ｏ拷
锟斤拷站锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟较达拷锟斤拷锟斤拷锟斤拷锟街凤拷锟斤拷陌锟饺拷锟斤拷敕拷始锟�[email protected]
锟斤拷ICP锟斤拷2022002427锟斤拷-10 锟芥公锟斤拷锟斤拷锟斤拷锟斤拷43070202000427锟斤拷© 2013~2025 haote.com 锟斤拷锟斤拷锟斤拷
