Java Spring服务端如何感知客户端取消请求并终止处理？

当客户端主动取消请求（比如关闭浏览器、中断HTTP连接）时，服务端可以通过以下方式感知并终止耗时任务，避免资源浪费：

Spring原生支持的实现方式 #

1. 检查线程中断状态 #

Tomcat、Jetty等Servlet容器检测到客户端断开连接时，会中断处理该请求的线程。你可以在业务逻辑中定期检查线程的中断标记，从而终止流程：

@GetMapping("/long-running-task")
public ResponseEntity<String> handleLongTask() throws InterruptedException {
    for (int step = 0; step < 5; step++) {
        // 每步执行后检查线程是否被中断
        if (Thread.currentThread().isInterrupted()) {
            // 清理临时资源（如关闭流、释放连接）
            log.warn("客户端已取消请求，终止任务");
            return ResponseEntity.status(HttpStatus.REQUEST_TIMEOUT).body("任务已终止");
        }
        // 模拟1秒耗时操作
        Thread.sleep(1000);
    }
    return ResponseEntity.ok("任务执行完成");
}

2. 使用WebAsyncTask处理异步请求 #

如果任务是异步执行的，Spring提供的WebAsyncTask支持监听请求取消事件，绑定回调逻辑：

@GetMapping("/async-long-task")
public WebAsyncTask<ResponseEntity<String>> handleAsyncLongTask() {
    Callable<ResponseEntity<String>> task = () -> {
        for (int step = 0; step < 5; step++) {
            if (Thread.currentThread().isInterrupted()) {
                log.warn("异步任务被中断，终止执行");
                return ResponseEntity.status(HttpStatus.REQUEST_TIMEOUT).body("异步任务已终止");
            }
            Thread.sleep(1000);
        }
        return ResponseEntity.ok("异步任务执行完成");
    };

    // 创建WebAsyncTask，指定超时时间并绑定回调
    WebAsyncTask<ResponseEntity<String>> asyncTask = new WebAsyncTask<>(60000, task);
    asyncTask.onCompletion(() -> log.info("任务完成或被取消"));
    asyncTask.onTimeout(() -> ResponseEntity.status(HttpStatus.GATEWAY_TIMEOUT).body("任务超时"));

    return asyncTask;
}

3. 利用AsyncContext监听连接状态 #

对于底层Servlet异步处理，可通过AsyncContext的监听器捕获连接关闭事件：

@GetMapping("/servlet-async-task")
public void handleServletAsync(HttpServletRequest request, HttpServletResponse response) {
    AsyncContext asyncContext = request.startAsync();
    asyncContext.setTimeout(60000);

    // 添加连接丢失监听器
    asyncContext.addListener(new AsyncListener() {
        @Override
        public void onConnectionLost(AsyncEvent event) throws IOException {
            log.warn("客户端连接丢失，终止异步任务");
            asyncContext.complete();
        }

        // 实现其他空方法
        @Override public void onComplete(AsyncEvent event) throws IOException {}
        @Override public void onTimeout(AsyncEvent event) throws IOException {}
        @Override public void onError(AsyncEvent event) throws IOException {}
        @Override public void onStartAsync(AsyncEvent event) throws IOException {}
    });

    // 启动异步任务线程
    new Thread(() -> {
        try {
            for (int step = 0; step < 5; step++) {
                if (asyncContext.getRequest().isClosed()) break;
                Thread.sleep(1000);
            }
            asyncContext.getResponse().getWriter().write("任务执行完成");
        } catch (Exception e) {
            log.error("任务执行出错", e);
        } finally {
            asyncContext.complete();
        }
    }).start();
}

替代方案（原生支持无法满足时） #

如果任务与请求线程完全解耦（比如在独立线程池执行），可尝试以下方案：

• 主动取消接口：为每个请求生成唯一ID，客户端取消时调用/cancel/{requestId}接口，服务端维护取消标记集合，任务定期检查标记并终止。
• 拆分任务：将大任务拆分为多个小步骤，每步执行后检查取消状态，避免长时间无法中断的操作。
• 响应式编程：使用Spring WebFlux，基于Reactor框架天然支持请求取消的传播，客户端取消时自动终止数据流处理。

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