Spring Boot 源码分析 —— ReactiveWebServerApplicationContext

1. 概述

本文接 《精尽 Spring Boot 源码分析 —— ServletWebServerApplicationContext》 一文，我们来分享 ReactiveWebServerApplicationContext 类，它提供 Reactive Web 环境的 Spring 容器。

AnnotationConfigReactiveWebServerApplicationContext 的类图关系如下：

• 相比来说，ReactiveWebServerApplicationContext 比 ServletWebServerApplicationContext 有更多的层级关系。不过没事，我们一点一点来看。

艿艿：Spring Webflux ，我自己目前没太使用过。看这块，就单纯好奇下，哈哈哈。

2. ReactiveWebApplicationContext

org.springframework.boot.web.reactive.context.ReactiveWebApplicationContext ，继承 ApplicationContext 接口，Reactive Web ApplicationContext 接口。代码如下：

// ReactiveWebApplicationContext.java

public interface ReactiveWebApplicationContext extends ApplicationContext {
}

3. ConfigurableReactiveWebApplicationContext

org.springframework.boot.web.reactive.context.ConfigurableReactiveWebApplicationContext ，继承 ConfigurableApplicationContext、「2. ReactiveWebApplicationContext」 接口，可配置的 ReactiveWebApplicationContext 接口。代码如下：

// ReactiveWebApplicationContext.java

public interface ConfigurableReactiveWebApplicationContext extends ConfigurableApplicationContext, ReactiveWebApplicationContext {
}

4. GenericReactiveWebApplicationContext

org.springframework.boot.web.reactive.context.GenericReactiveWebApplicationContext ，实现 「3. ConfigurableReactiveWebApplicationContext」 接口，继承 GenericApplicationContext 类，通用的 Reactive Web ApplicationContext 实现类。代码如下：

// GenericReactiveWebApplicationContext.java

public class GenericReactiveWebApplicationContext extends GenericApplicationContext
        implements ConfigurableReactiveWebApplicationContext {

    public GenericReactiveWebApplicationContext() {
    }

    public GenericReactiveWebApplicationContext(DefaultListableBeanFactory beanFactory) {
        super(beanFactory);
    }

    @Override // 覆写 AbstractApplicationContext 方法
    protected ConfigurableEnvironment createEnvironment() {
        return new StandardReactiveWebEnvironment(); // <X>
    }

    @Override // 覆写 AbstractApplicationContext 方法
    protected Resource getResourceByPath(String path) {
        // We must be careful not to expose classpath resources
        return new FilteredReactiveWebContextResource(path); // <Y>
    }

}

• 重点在 <X> 和 <Y> 处，覆写了方法，分别返回了 StandardReactiveWebEnvironment 和 FilteredReactiveWebContextResource 对象。不过看了下这两个对象，暂时也没什么特殊的方法。所以，可暂时忽略~

5. ReactiveWebServerApplicationContext

艿艿：正戏开始~

org.springframework.boot.web.reactive.context.ReactiveWebServerApplicationContext ，实现 ConfigurableWebServerApplicationContext 接口，继承 GenericReactiveWebApplicationContext 类，Spring Boot 使用 Reactive Web 服务器的 ApplicationContext 实现类。

5.1 构造方法

// ReactiveWebServerApplicationContext.java

/**
 * ServerManager 对象
 */
private volatile ServerManager serverManager;
/**
 * 通过 {@link #setServerNamespace(String)} 注入。
 *
 * 不过貌似，一直没被注入过，可以暂时先无视
 */
private String serverNamespace;

public ReactiveWebServerApplicationContext() {
}

public ReactiveWebServerApplicationContext(DefaultListableBeanFactory beanFactory) {
    super(beanFactory);
}

• serverManager 属性，ServerManager 对象。详细解析，见 「5.2 ServerManager」 。

5.2 ServerManager

ServerManager 是 ReactiveWebServerApplicationContext 的内部静态类，实现 org.springframework.http.server.reactive.HttpHandler 接口，内含 Server 的管理器。

5.2.1 构造方法

// ReactiveWebServerApplicationContext#ServerManager.java

/**
 * WebServer 对象
 */
private final WebServer server;
/**
 * HttpHandler 对象，具体在 {@link #handle(ServerHttpRequest, ServerHttpResponse)} 方法中使用。
 */
private volatile HttpHandler handler;

private ServerManager(ReactiveWebServerFactory factory) {
    this.handler = this::handleUninitialized; // <1> 同下面
//          this.handler = new HttpHandler() {
//                @Override
//                public Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response) {
//                    return handleUninitialized(request, response);
//                }
//            };
    this.server = factory.getWebServer(this); // <2>
}

private Mono<Void> handleUninitialized(ServerHttpRequest request, ServerHttpResponse response) {
    throw new IllegalStateException("The HttpHandler has not yet been initialized");
}

• <1> 处，创建的 handler 对象，内部实现调用了 #handleUninitialized(ServerHttpRequest request, ServerHttpResponse response) 方法，会抛出 IllegalStateException 异常。表示，此时该 server 还不可用。因为，server 都还没启动。
  分享到：
  Spring Boot 源码分析 —— Application ... | Spring Boot 源码分析 —— ServletWebSer ...
  • 2019-08-16 13:14
  • 浏览 896
  • 评论(0)
  • 分类:编程语言
  • 查看更多