import org.springframework.web.server.adapter.WebHttpHandlerBuilder; //导入依赖的package包/类
@Bean
public Server jettyServer(ApplicationContext context) throws Exception {
    HttpHandler handler = WebHttpHandlerBuilder.applicationContext(context).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("localhost");
    connector.setPort(port);
    server.addConnector(connector);

    return server;
}
 

import org.springframework.web.server.adapter.WebHttpHandlerBuilder; //导入依赖的package包/类
@Bean public HttpHandler handler() {
    return WebHttpHandlerBuilder
        .webHandler((WebHandler) toHttpHandler(routing()))
        .filter(limitFilter)
//        .filter(validateFilter)
        .build();
  }
 

import org.springframework.web.server.adapter.WebHttpHandlerBuilder; //导入依赖的package包/类
@Bean
public Tomcat embededTomcatServer(ApplicationContext context) throws Exception {
    HttpHandler handler = WebHttpHandlerBuilder.applicationContext(context).build(); 

    // Tomcat and Jetty (also see notes below)
    Servlet servlet = new TomcatHttpHandlerAdapter(handler);

    Tomcat tomcatServer = new Tomcat();
    tomcatServer.setHostname("localhost");
    tomcatServer.setPort(this.port);
    Context rootContext = tomcatServer.addContext("", System.getProperty("java.io.tmpdir"));
    Tomcat.addServlet(rootContext, "httpHandlerServlet", servlet);
    rootContext.addServletMappingDecoded("/", "httpHandlerServlet");

    return tomcatServer;
}
 

import org.springframework.web.server.adapter.WebHttpHandlerBuilder; //导入依赖的package包/类
@Test
public void enableSpringWebSessionConfiguresThings() {

	this.context = new AnnotationConfigApplicationContext();
	this.context.register(GoodConfig.class);
	this.context.refresh();

	WebSessionManager webSessionManagerFoundByType = this.context.getBean(WebSessionManager.class);
	Object webSessionManagerFoundByName = this.context.getBean(WebHttpHandlerBuilder.WEB_SESSION_MANAGER_BEAN_NAME);

	assertThat(webSessionManagerFoundByType).isNotNull();
	assertThat(webSessionManagerFoundByName).isNotNull();
	assertThat(webSessionManagerFoundByType).isEqualTo(webSessionManagerFoundByName);

	assertThat(this.context.getBean(ReactiveSessionRepository.class)).isNotNull();
}
 

import org.springframework.web.server.adapter.WebHttpHandlerBuilder; //导入依赖的package包/类
@Before
public void startServer(){
    if(!isServerStarted) {
        AnnotationConfigApplicationContext ac = new AnnotationConfigApplicationContext();
        ac.register(TestingConfiguration.class);
        ac.refresh();

        ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(WebHttpHandlerBuilder.webHandler(new DispatcherHandler(ac)).build());
        HttpServer httpServer = HttpServer.create(PORT);
        httpServer.newHandler(adapter).block();
        isServerStarted = true;
    }
}
 

import org.springframework.web.server.adapter.WebHttpHandlerBuilder; //导入依赖的package包/类
@Profile("default")
@Bean
public NettyContext nettyContext(ApplicationContext context) {
    HttpHandler handler = WebHttpHandlerBuilder.applicationContext(context).build();
    ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(handler);
    HttpServer httpServer = HttpServer.create("localhost", this.port);
    return httpServer.newHandler(adapter).block();
}
 

import org.springframework.web.server.adapter.WebHttpHandlerBuilder; //导入依赖的package包/类
@Bean
public Undertow undertowServer(ApplicationContext context) {
    HttpHandler handler = WebHttpHandlerBuilder.applicationContext(context).build();  // (2)

    // Undertow
    UndertowHttpHandlerAdapter undertowAdapter = new UndertowHttpHandlerAdapter(handler);
    Undertow server = Undertow.builder()
        .addHttpListener(port, "localhost")
        .setHandler(undertowAdapter)
        .build();

    return server;
}
 

import org.springframework.web.server.adapter.WebHttpHandlerBuilder; //导入依赖的package包/类
@Profile("default")
@Bean
public NettyContext nettyContext(ApplicationContext context) {
    HttpHandler handler = WebHttpHandlerBuilder.applicationContext(context)
        .exceptionHandler(exceptionHandler())
        .build();
    ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(handler);
    HttpServer httpServer = HttpServer.create("localhost", this.port);
    return httpServer.newHandler(adapter).block();
}