多次访问Actuator接口后Spring Cloud Gateway无响应问题求助

核心原因 #

Spring Cloud Gateway基于Netty的Reactor非阻塞线程模型，你在Actuator路径配置的WebFilter中使用同步的RestTemplate调用认证服务，会直接阻塞Netty的EventLoop工作线程。当多次访问Actuator触发WebFilter后，所有EventLoop线程会被占满阻塞，导致Gateway无法处理任何新请求。而Tomcat服务采用Servlet线程池模型，同步调用仅占用Servlet线程，只要线程池有剩余资源就不会导致服务僵死，这就是两者表现差异的根本原因。

解决方案 #

1. 替换为非阻塞的WebClient（推荐） #

使用Spring WebFlux提供的WebClient替代RestTemplate，适配Gateway的Reactor非阻塞模型，从根源避免线程阻塞：

@Bean
public WebClient webClient() {
    return WebClient.builder()
            .baseUrl("http://auth-service")
            .build();
}

// 在WebFilter中实现认证逻辑
@Override
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
    String token = exchange.getRequest().getHeaders().getFirst("Authorization");
    return webClient.get()
            .uri("/auth/validate?token={token}", token)
            .retrieve()
            .bodyToMono(Boolean.class)
            .flatMap(valid -> {
                if (valid) {
                    return chain.filter(exchange);
                } else {
                    exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
                    return exchange.getResponse().setComplete();
                }
            });
}

2. 若必须使用RestTemplate，隔离阻塞调用线程 #

将RestTemplate的同步调用放到独立的线程池中，避免占用Netty的EventLoop线程：

@Bean
public Executor authCallExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(10);
    executor.setMaxPoolSize(20);
    executor.setQueueCapacity(100);
    executor.setThreadNamePrefix("auth-call-");
    executor.initialize();
    return executor;
}

// 在WebFilter中调整调用逻辑
@Override
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
    String token = exchange.getRequest().getHeaders().getFirst("Authorization");
    return Mono.fromCallable(() -> {
        // 同步调用认证服务
        ResponseEntity<Boolean> response = restTemplate.getForEntity(
                "http://auth-service/auth/validate?token={token}", 
                Boolean.class, 
                token
        );
        return response.getBody() != null && response.getBody();
    }).subscribeOn(Schedulers.fromExecutor(authCallExecutor()))
            .flatMap(valid -> {
                if (valid) {
                    return chain.filter(exchange);
                } else {
                    exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
                    return exchange.getResponse().setComplete();
                }
            });
}

3. 补充配置优化 #

• 给RestTemplate配置HTTP连接池，避免频繁创建销毁连接：

@Bean
public RestTemplate restTemplate() {
    PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();
    connectionManager.setMaxTotal(200);
    connectionManager.setDefaultMaxPerRoute(50);
    
    CloseableHttpClient httpClient = HttpClientBuilder.create()
            .setConnectionManager(connectionManager)
            .build();
    
    HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory(httpClient);
    factory.setConnectTimeout(5000);
    factory.setReadTimeout(5000);
    
    return new RestTemplate(factory);
}

• 精准配置WebFilter的拦截路径，避免对非Actuator请求触发不必要的认证逻辑。

验证步骤 #

1. 调整后多次访问Actuator接口，观察Gateway是否还会出现无响应情况。
2. 使用jstack工具查看JVM线程状态，确认Netty EventLoop线程未被阻塞。

内容的提问来源于stack exchange，提问作者Equent R