Spring WebFlux中客户端断开连接时如何取消WebClient的流式请求？

看起来你碰到了响应式编程中冷序列特性和框架订阅管理的典型坑，我来帮你梳理清楚问题所在，以及正确的解决方式：

先说说你之前代码的核心问题 #

你写的代码里犯了一个冷流的关键错误：Flux是冷序列，每次调用subscribe()都会重新发起一次完整的WebClient请求。

你手动调用flux.subscribe()得到的Disposable，对应的是一个完全独立的订阅——相当于你偷偷发起了一个和返回给客户端无关的第二个请求。之后你返回原Flux给客户端时，框架会为这个Flux再发起一次新的订阅（也就是客户端实际接收的请求）。所以你调用disposable.dispose()时，只是取消了你手动发起的那个请求，对客户端正在接收的请求完全没有影响，这就是为什么你的代码没效果。

正确的解决思路：利用框架的自动订阅管理 #

在Spring生态中，不管是纯WebFlux还是Spring MVC（你的错误栈显示你用的是MVC，因为有ResponseBodyEmitter和Servlet异步处理相关逻辑），当客户端断开连接时，框架会自动取消返回给客户端的Flux的订阅。而WebClient的请求是和这个订阅绑定的——一旦订阅被取消，WebClient会自动终止和外部服务的连接，根本不需要你手动管理Disposable！

那为什么你会碰到客户端断开后WebClient还在跑的情况？大概率是你在Flux上的某些操作符（比如share()、cache()或者自定义filter）意外阻断了取消信号的向上传递，或者你的异常处理逻辑干扰了框架的默认行为。

修正后的代码示例 #

你只需要确保返回的Flux和WebClient的请求直接绑定，同时可以通过doOnCancel()监听取消信号（用于日志排查），并处理客户端断开时的异常：

return webClient.post()
    .uri(uri)
    .bodyValue(req)
    .retrieve()
    .bodyToFlux(String.class)
    // 你的filters、maps等操作符
    .doOnCancel(() -> {
        // 这里可以加日志，确认客户端断开时取消信号触发
        log.info("客户端已断开连接，正在终止与外部服务的WebClient请求");
    })
    // 处理客户端断开导致的Broken Pipe等异常，避免框架抛出不必要的错误日志
    .onErrorResume(IOException.class, e -> {
        log.warn("客户端连接异常，终止响应", e);
        return Flux.empty();
    });

关键注意事项 #

1. 绝对不要手动subscribe返回给客户端的Flux：框架会自动处理订阅，手动subscribe会导致重复发起请求，且无法关联到客户端的连接生命周期。
2. 依赖取消信号而非Error信号：客户端断开连接时，响应式流的标准行为是触发onCancel而非onError（虽然有时候会伴随IOException，但取消信号是更可靠的终止依据）。
3. 检查操作符是否阻断取消信号：如果你用了publish().refCount()、cache()这类操作符，可能会把冷流转为热流，导致取消信号无法传递到上游的WebClient请求。如果不需要热流特性，尽量避免使用这类操作符。

关于你碰到的错误栈 #

你日志里的AsyncRequestNotUsableException是因为客户端断开后，框架还尝试向已关闭的连接写数据导致的。通过上面的onErrorResume处理IOException（包括Broken Pipe），可以避免这个异常被抛到框架层面，减少不必要的错误日志。

备注：内容来源于stack exchange，提问作者Coco Liliace