WebFlux-忽略“取消”信号

Question

试图从其他人那里得到答案

假设我有一个简单的控制器，如下所示：

@RestController
class DemoController {

    @GetMapping("/demo/{text}")
    public Flux<String> getDemo(@PathVariable String text) {
        return Flux.fromArray(text.split(""))
            .map(String::toUpperCase)
            .delayElements(Duration.ofSeconds(1L))
            .doOnNext(s -> System.out.println("S: " + s + " -> " + LocalDateTime.now().getSecond()))
            .doOnCancel(() -> System.out.println("Cancelled"));
    }
}

我希望处理忽略“取消”信号，这通常在客户端断开连接时出现。试图通过nginx的proxy\u ignore\u client\u abort on实现这一点 但这不能正常工作。

我可以。订阅（...）到自定义订阅者，例如忽略取消信号，但比我看到的处理执行了两次-这是非常明显的，没有预料到。

另一个选择是，我可以扩展流量

@Override
public void cancel() {
    System.out.println("Cancelled / ignored");
}

但这看起来更像是黑客攻击。

有人能告诉我，什么是通过控制器触发的、可以忽略取消信号的反应管道的“正确”运行方式吗？




Answer 1

当前的webflux行为是完美的。然而，您的要求似乎有所不同，即使订户不再对监听数据感兴趣，您也总是希望发出这种信息。在这种情况下，只需加热电源即可。

@RestController
class DemoController {

    @GetMapping("/demo/{text}")
    public Flux<String> getDemo(@PathVariable String text) {
        return Flux.fromArray(text.split(""))
                .map(String::toUpperCase)
                .delayElements(Duration.ofSeconds(1L))
                .doOnNext(s -> System.out.println("S: " + s + " -> " + LocalDateTime.now().getSecond()))
                .doOnCancel(() -> System.out.println("Cancelled"))
                .cache(); // hot source
    }
}