SpringBoot停机时Flux异步接口抛出异步分发不支持异常的解决

异常成因 #

当Flux流未完成时停止Spring Boot应用，抛出的UnsupportedOperationException本质是Tomcat已关闭异步调度能力，但后台的Reactor订阅线程仍在尝试完成响应分发：

• Spring Boot触发停机后，Tomcat会快速销毁ServletContext并停止支持异步请求处理；
• 你的Flux通过delayElements在后台线程异步发射元素，当流最终完成（或被中断）时，Spring的ResponseBodyEmitter会尝试通过Tomcat的AsyncContext分发完成信号，但此时该上下文已不支持异步调度，直接抛出异常。

解决措施 #

1. 给Flux绑定应用关闭信号，主动终止流 #

修改接口代码，让Flux在应用触发关闭事件时立即停止发射元素，避免后续的完成信号分发操作：

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextClosedEvent;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.time.Duration;

@RestController
public class StrListController {

    @GetMapping(value = "/api/getStrListFlux", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> getListOfStr0(ApplicationEventPublisher publisher) {
        // 创建监听应用关闭的信号源
        Mono<Void> shutdownTrigger = Mono.create(sink -> {
            ApplicationListener<ContextClosedEvent> shutdownListener = event -> sink.success();
            publisher.addApplicationListener(shutdownListener);
            // 订阅取消时移除监听，避免内存泄漏
            sink.onDispose(() -> publisher.removeApplicationListener(shutdownListener));
        });

        return Flux.just("Str-1", "Str-2", "Str-3", "Str-4", "Str-5")
                .log()
                .delayElements(Duration.ofSeconds(1))
                // 收到关闭信号立即终止流
                .takeUntilOther(shutdownTrigger);
    }
}

2. 配置Spring Boot优雅停机参数 #

在application.properties（或application.yml）中开启优雅停机，并设置合理的等待时长，确保应用有时间处理完现有请求或主动终止长连接：

# 开启优雅停机模式
server.shutdown=graceful
# 设置停机阶段的超时时间，根据你的流处理时长调整（比如10秒）
spring.lifecycle.timeout-per-shutdown-phase=10s

该配置会让Spring Boot在停机时：

• 先停止接受新请求；
• 等待指定时长，让正在处理的请求完成；
• 触发ContextClosedEvent，配合上面的Flux终止逻辑，彻底避免异步分发异常。

额外说明 #

如果你的应用中有多个类似的Reactive接口，也可以封装一个全局的关闭信号Bean，注入到各个接口中复用，避免重复代码。

内容的提问来源于stack exchange，提问作者Pramod Sharma