java - 如何防止嵌入式netty服务器从spring-boot-starter-webflux启动?

标签 java spring spring-boot spring-webflux

我想使用 Springs 新的响应式 webflux 扩展在客户端和服务器应用程序之间建立通信。

对于依赖管理,我使用 gradle。 我在服务器端以及客户端的 build.gradle 文件基本上是:

buildscript {
    repositories {
        mavenCentral()
        maven { url "https://repo.spring.io/snapshot" }
    }
    dependencies {
        classpath("org.springframework.boot:spring-boot-gradle-plugin:2.0.0.BUILD-SNAPSHOT")
    }
}

repositories {
    mavenCentral()
    maven { url "https://repo.spring.io/snapshot" }
}

apply plugin: 'java'
apply plugin: 'org.springframework.boot'
apply plugin: "io.spring.dependency-management" 

dependencies {
    compile("org.springframework.boot:spring-boot-starter-webflux")
}

(需要注意的是 2.0.0.BUILD-SNAPSHOT 是一个移动的目标,由于依赖关系内部的变化,手头的问题可能有一天会消失)

当我启动服务器端应用程序时,一切都正常启动,包括嵌入式 netty 服务器的启动。

但是当启动客户端应用程序时,也会启动一个 netty 服务器,导致“java.net.BindException: Address already in use”,因为客户端 netty 服务器监听与服务器端 netty 服务器相同的端口。

我的问题是:为什么netty首先在客户端启动,我该如何防止它?

根据 Spring-Boot 文档,Spring 尝试确定是否需要 Web 支持并相应地配置 Spring 应用程序上下文。

根据文档,这可以通过调用 setWebEnvironment(false) 来覆盖。我的客户端启动代码如下所示:

@SpringBootApplication(scanBasePackages = { "com.tatics.flux.main" })
public class Client {
    public static void main(String[] args) throws Exception {
        SpringApplication app = new SpringApplication(Client.class);
        app.setWebEnvironment(false);
        app.run(Client.class, args);

        WebClient webClient = WebClient.create();

        Mono<String> result = webClient
                .post()
                .uri("http://localhost:8080/fluxService")

                // This does not work any more: .body("Hallo")
                // and must be replaced by:
                .body(BodyInserters.fromObject("Hallo"))

                .accept(MediaType.TEXT_PLAIN)
                .exchange()
                .flatMap(response -> response.bodyToMono(String.class));
    }
}

不幸的是,netty 仍在启动。 我还注意到 setWebEnvironment(false) 被标记为已弃用。

感谢任何有关如何防止 netty 启动但保留所有 webflux 依赖项的帮助。

以下是自动配置报告的摘录:

=========================
AUTO-CONFIGURATION REPORT
=========================

Positive matches:
-----------------
...

ReactiveWebServerAutoConfiguration matched:
  - found ReactiveWebApplicationContext (OnWebApplicationCondition)

ReactiveWebServerAutoConfiguration#defaultReactiveWebServerCustomizer matched:
  - @ConditionalOnMissingBean (types: org.springframework.boot.autoconfigure.web.reactive.DefaultReactiveWebServerCustomizer; SearchStrategy: all) did not find any beans (OnBeanCondition)

ReactiveWebServerConfiguration.ReactorNettyAutoConfiguration matched:
  - @ConditionalOnClass found required class 'reactor.ipc.netty.http.server.HttpServer'; @ConditionalOnMissingClass did not find unwanted class (OnClassCondition)
  - @ConditionalOnMissingBean (types: org.springframework.boot.web.reactive.server.ReactiveWebServerFactory; SearchStrategy: all) did not find any beans (OnBeanCondition)

ReactorCoreAutoConfiguration matched:
  - @ConditionalOnClass found required classes 'reactor.core.publisher.Mono', 'reactor.core.publisher.Flux'; @ConditionalOnMissingClass did not find unwanted class (OnClassCondition)

...

Negative matches:
-----------------
...
ReactiveWebServerConfiguration.JettyAutoConfiguration:
  Did not match:
     - @ConditionalOnClass did not find required class 'org.eclipse.jetty.server.Server' (OnClassCondition)

ReactiveWebServerConfiguration.TomcatAutoConfiguration:
  Did not match:
     - @ConditionalOnClass did not find required class 'org.apache.catalina.startup.Tomcat' (OnClassCondition)

ReactiveWebServerConfiguration.UndertowAutoConfiguration:
  Did not match:
     - @ConditionalOnClass did not find required class 'io.undertow.Undertow' (OnClassCondition)

...

ReactiveWebServerConfiguration.JettyAutoConfiguration:
  Did not match:
     - @ConditionalOnClass did not find required class 'org.eclipse.jetty.server.Server' (OnClassCondition)

ReactiveWebServerConfiguration.TomcatAutoConfiguration:
  Did not match:
     - @ConditionalOnClass did not find required class 'org.apache.catalina.startup.Tomcat' (OnClassCondition)

ReactiveWebServerConfiguration.UndertowAutoConfiguration:
  Did not match:
     - @ConditionalOnClass did not find required class 'io.undertow.Undertow' (OnClassCondition)

最佳答案

除了@Brian_Clozel 答案:

您可以通过在 application.yml 中指定来禁用 Netty(或任何其他服务器):

spring.main.web-application-type: none

或application.properties:

spring.main.web-application-type=none

关于java - 如何防止嵌入式netty服务器从spring-boot-starter-webflux启动?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43574234/

相关文章:

java - 更改 Android 中应用程序的 DisplayMetrics(API 级别低于 17)

java - Regex Java 非法/不支持的转义序列

java - 将 spring mvc 添加到 spring java "desktop"应用程序

java - spring-boot-gradle-plugin 是否随 spring-boot 版本一起移动?

java - 改变Spring OAuth2的Json返回格式

java - 使用 void 方法格式化 java 文本

java - 如果我在 Spring Framework 的 @PostConstruct 中初始化对象属性,我应该将它们标记为 volatile 吗?

spring - ETL、Esper 还是 Drools?

spring - 如何验证数据源有效且配置正确?

spring - 如何在 Spring Boot 应用程序中使用禁用连接池?