Spring WebFlux应用停止时reactor-http-epoll线程未关闭致内存泄漏

问题根源 #

这些未停止的epoll线程属于WebClient底层的Netty事件循环组，通常是因为：

• WebClient未由Spring容器管理，上下文关闭时无法自动释放资源
• 自定义Netty配置时，手动创建的EventLoopGroup未添加销毁逻辑
• 存在未完成的异步请求订阅，导致线程被占用无法退出

正确配置WebClient #

1. 由Spring托管WebClient实例 #

不要手动new WebClient()，通过WebClient.Builder注入，让Spring处理生命周期：

@Configuration
public class WebClientConfig {
    @Bean
    public WebClient webClient() {
        return WebClient.builder()
                .baseUrl("https://your-api-host.com")
                .build();
    }
}

Spring上下文关闭时，会自动清理WebClient关联的Netty资源。

2. 自定义Netty EventLoopGroup时添加销毁钩子 #

如果需要自定义epoll线程池（比如指定线程数），必须配置销毁方法：

@Configuration
public class WebClientConfig {
    @Bean(destroyMethod = "shutdownGracefully")
    public EventLoopGroup epollEventLoopGroup() {
        return new EpollEventLoopGroup(4); // 根据业务调整线程数
    }

    @Bean
    public WebClient webClient(EventLoopGroup eventLoopGroup) {
        HttpClient httpClient = HttpClient.create()
                .runOn(eventLoopGroup);
        return WebClient.builder()
                .clientConnector(new ReactorClientHttpConnector(httpClient))
                .build();
    }
}

destroyMethod = "shutdownGracefully"会让Spring在上下文关闭时调用EventLoopGroup的优雅关闭方法，释放epoll线程。

3. 清理未完成的异步订阅 #

检查服务代码，确保所有Mono/Flux订阅都能在应用关闭时被取消：

@Service
public class ApiService {
    private final WebClient webClient;
    private final List<Disposable> activeSubscriptions = new CopyOnWriteArrayList<>();

    public ApiService(WebClient webClient) {
        this.webClient = webClient;
    }

    public Mono<String> fetchData() {
        Mono<String> response = webClient.get()
                .uri("/data")
                .retrieve()
                .bodyToMono(String.class);
        // 记录订阅实例，用于关闭时取消
        Disposable disposable = response.subscribe();
        activeSubscriptions.add(disposable);
        return response;
    }

    @PreDestroy
    public void cleanupSubscriptions() {
        activeSubscriptions.forEach(Disposable::dispose);
    }
}

@PreDestroy方法会在Bean销毁时取消所有未完成的订阅，避免线程被占用。

依赖版本检查 #

确保spring-boot-starter-webflux和Reactor Netty版本匹配，不要手动引入冲突版本：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-webflux</artifactId>
    </dependency>
    <!-- 除非特殊需求，否则不需要手动引入reactor-netty-http -->
</dependencies>

Spring Boot的starter已经包含了适配的Reactor Netty版本，手动指定版本容易引发资源泄漏问题。

验证方法 #

启动应用后调用API，然后执行优雅关闭（比如Ctrl+C或Actuator的/actuator/shutdown），查看日志是否还存在线程未停止的警告。

内容的提问来源于stack exchange，提问作者Edgar Guzmán