環(huán)境：Springboot2.4.12

概述

spring-web模塊包含了對響應式web應用程序的以下基本支持：

• 對于服務器請求處理，有兩個級別的支持。

1. HttpHandler：處理HTTP請求的基本協(xié)議，包括非阻塞I/O和響應式流背壓，以及Reactor Netty、Undertow、Tomcat、Jetty和任何Servlet 3.1+容器的適配器。
2. WebHandler API：稍微高級一點的，用于處理請求的通用web API，在此基礎上構建具體的編程模型，如帶注釋的控制器和函數(shù)式端點。

• 對于客戶端，有一個基本的ClientHttpConnector契約來執(zhí)行HTTP請求，包括非阻塞I/O和響應式流回壓，以及Reactor Netty, Reactive Jetty HttpClient和Apache HttpComponents的適配器。應用程序中使用的高級web客戶端構建在這個基本契約之上。
• 對于客戶端和服務器，用于HTTP請求和響應內(nèi)容的序列化和反序列化的編解碼器。

HttpHandler

HttpHandler是一個簡單的協(xié)議，只有一個方法來處理請求和響應。它故意最小化，其主要和唯一的目的是在不同的HTTP服務器api上提供最小的抽象。

支持的服務器api如下表所示：

下表描述了服務器依賴關系：

下面的代碼片段顯示了在每個服務器API中使用HttpHandler適配器：

• Reactor Netty

HttpHandler handler = WebHttpHandlerBuilder.applicationContext(this.applicationContext).build();
ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(handler);
HttpServer.create().host(host).port(port).handle(adapter).bind().block();

• Undertow

HttpHandler handler = WebHttpHandlerBuilder.applicationContext(this.applicationContext).build();
UndertowHttpHandlerAdapter adapter = new UndertowHttpHandlerAdapter(handler);
Undertow server = Undertow.builder().addHttpListener(port, host).setHandler(adapter).build();
server.start();

• Tomcat

HttpHandler handler = WebHttpHandlerBuilder.applicationContext(this.applicationContext).build();
Servlet servlet = new TomcatHttpHandlerAdapter(handler);


Tomcat server = new Tomcat();
File base = new File(System.getProperty("java.io.tmpdir"));
Context rootContext = server.addContext("", base.getAbsolutePath());
Tomcat.addServlet(rootContext, "main", servlet);
rootContext.addServletMappingDecoded("/", "main");
server.setHost(host);
server.setPort(port);
server.start();

• Jetty

HttpHandler handler = WebHttpHandlerBuilder.applicationContext(this.applicationContext).build();
Servlet servlet = new JettyHttpHandlerAdapter(handler);


Server server = new Server();
ServletContextHandler contextHandler = new ServletContextHandler(server, "");
contextHandler.addServlet(new ServletHolder(servlet), "/");
contextHandler.start();


ServerConnector connector = new ServerConnector(server);
connector.setHost(host);
connector.setPort(port);
server.addConnector(connector);
server.start();

• Servlet 3.1+ Container

要將war部署到任何Servlet 3.1+容器，你可以擴展并在war中包含
AbstractReactiveWebInitializer。這個類用ServletHttpHandlerAdapter封裝了一個HttpHandler，并將其注冊為Servlet。

部分源碼：?

public abstract class AbstractReactiveWebInitializer implements WebApplicationInitializer {
  public void onStartup(ServletContext servletContext) throws ServletException {
    String servletName = getServletName();
    ApplicationContext applicationContext = createApplicationContext();
    refreshApplicationContext(applicationContext);
    registerCloseListener(servletContext, applicationContext);


    // 與上面的服務器一樣通過WebHttpHandlerBuilder構建HttpHandler對象
    HttpHandler httpHandler = WebHttpHandlerBuilder.applicationContext(applicationContext).build();
    // 該類實現(xiàn)了javax.servlet.Servlet接口
    ServletHttpHandlerAdapter servlet = new ServletHttpHandlerAdapter(httpHandler);


    ServletRegistration.Dynamic registration = servletContext.addServlet(servletName, servlet);
    registration.setLoadOnStartup(1);
    registration.addMapping(getServletMapping());
    registration.setAsyncSupported(true);
  }  
}

WebHandler

org.springframework.web.server包構建在HttpHandler契約之上，為通過多個WebExceptionHandler、多個WebFilter和單個WebHandler組件的鏈處理請求提供通用的web API。只需指向自動檢測組件的Spring ApplicationContext，或者向構建器注冊組件，就可以將該鏈與WebHttpHandlerBuilder組合在一起。

HttpHandler的目標很簡單，就是抽象出不同的HTTP服務器，而WebHandler API的目標是提供web應用中常用的更廣泛的功能，例如:

• 具有屬性的用戶會話
• 請求屬性
• 已解析請求的區(qū)域設置或主體
• 訪問已解析和緩存的表單數(shù)據(jù)
• 多部分數(shù)據(jù)的摘要。
• 等等

特殊bean類型

下表列出了WebHttpHandlerBuilder可以在Spring ApplicationContext中自動檢測或直接注冊的組件:

Form Data

ServerWebExchange公開了以下訪問表單數(shù)據(jù)的方法:

Mono<MultiValueMap<String, String>> getFormData();

DefaultServerWebExchange使用配置的HttpMessageReader將表單數(shù)據(jù)(
application/x-www-form-urlencoded)解析為MultiValueMap。默認情況下，F(xiàn)ormHttpMessageReader被配置為由ServerCodecConfigurer bean使用。

Multipart Data

ServerWebExchange公開了以下訪問多部分數(shù)據(jù)的方法:

Mono<MultiValueMap<String, Part>> getMultipartData();

DefaultServerWebExchange使用配置的HttpMessageReader<MultiValueMap<String, Part>>來將multipart/form-data內(nèi)容解析為MultiValueMap。默認情況下，這是DefaultPartHttpMessageReader，它沒有任何第三方依賴。另外，還可以使用基于Synchronoss nio Multipart庫的SynchronossPartHttpMessageReader。兩者都是通過ServerCodecConfigurer bean進行配置的。

要以流式方式解析多部分數(shù)據(jù)，你可以使用HttpMessageReader<Part>返回的` Flux<Part> `。例如，在帶注釋的控制器中，使用@RequestPart意味著通過名稱訪問各個部分，就像map一樣，因此需要完整解析多個部分的數(shù)據(jù)。相比之下，可以使用@RequestBody將內(nèi)容解碼到Flux<Part>，而無需收集到MultiValueMap。

Filters

在WebHandler API中，你可以使用WebFilter在過濾器和目標WebHandler處理鏈的其余部分之前和之后應用攔截風格的邏輯。當使用WebFlux配置時，注冊WebFilter就像把它聲明為Spring bean一樣簡單，并且(可選地)通過在bean聲明上使用@Order或實現(xiàn)Ordered來表示優(yōu)先級。

Exceptions

在WebHandler API中，可以使用WebExceptionHandler來處理來自WebFilter實例鏈和目標WebHandler的異常。當使用WebFlux配置時，注冊WebExceptionHandler就像聲明它為Spring bean一樣簡單，并且(可選)通過在bean聲明上使用@Order或實現(xiàn)Ordered來表示優(yōu)先級。

下表描述了可用的WebExceptionHandler實現(xiàn)：

Codecs

spring-web和spring-core模塊通過非阻塞I/O提供響應式流回壓，支持序列化和反序列化與高層對象之間的字節(jié)內(nèi)容。下面介紹這種支持：

• Encoder與Decoder是底層協(xié)議，獨立于HTTP對內(nèi)容進行編碼和解碼。
• HttpMessageReader和HttpMessageWriter是編碼和解碼HTTP消息內(nèi)容的協(xié)議。
• Encoder可以使用EncoderHttpMessageWriter包裝，以適應在web應用程序中使用，而 Decoder可以使用DecoderHttpMessageReader包裝。
• DataBuffer抽象了不同的字節(jié)緩沖區(qū)表示形式(例如Netty ByteBuf、java.nio。ByteBuffer等)，也是所有編解碼器都能處理的。

spring-core模塊提供了byte[]、ByteBuffer、DataBuffer、Resource和String編碼器和解碼器的實現(xiàn)。spring-web模塊提供了Jackson JSON、Jackson Smile、JAXB2、Protocol buffer和其他Encoder和Decoder，以及針對表單數(shù)據(jù)、多部分內(nèi)容、服務器發(fā)送事件等只支持web的HTTP消息閱讀器和writer實現(xiàn)。