当客户端与热流断开连接时执行一些操作

Question

我制作了一个简单的spring boot应用程序。我有一个RESTendpoint，它返回当前时间的热流。

@RestController
public class NowResource {

    @GetMapping(value = "/now", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> now() {
        return Flux.interval(Duration.ofSeconds(1))
            .flatMap(t -> Flux.just(Instant.now().toString()));
    }

}

当我调用http://localhost:8080/now时，我得到的数据流看起来像：

数据：2018-04-03T13:20:38.31322100Z

数据：2018-04-03T13:20:39.31149350Z

Data： 2018-04-03T13:20:40.310878800Z

......

当我断开与流的连接（关闭浏览器选项卡）时，会抛出并捕获IOException，并打印堆栈跟踪。

JAVA伊奥。IOException:主机中的软件中止了已建立的连接

......

我试过抓住它，但它已经被抓住了，不能回到我的方法。

我尝试添加doOnTerminate（），doOnError（）等到Flux，但似乎没有任何效果，我猜实际事件是不同类型的。

我能以某种方式访问这个异常，以不同于打印它的方式处理它吗？（我想避免日志中有200行输出，而只打印“完成”。）

编辑：我的解决方案基于托马斯·皮诺斯的答案

我最终采用了这种方法，不同之处在于我将其移动到了一个新类中，这样它就可以处理来自所有控制器的所有此类异常。

@Slf4j
@ControllerAdvice
class IOExceptionHandler implements WebExceptionHandler {

    @ExceptionHandler(IOException.class)
    public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
        return Mono.just(ex.getMessage())
            .doOnNext(
                msg -> log.warn("IOException occurred: {}.", msg)
            )
            .then();
    }

}

Answer 1

该异常与浏览器和控制器之间的HTTP连接处理有关（简单地说）。

它可以在控制器的@ExceptionHandler方法中处理（或者在@ControllerAdvice类中处理，如果您想在更多控制器上应用相同的异常处理）。

例如：

@RestController
public class NowResource {
    ...

    @ExceptionHandler(IOException.class)
    public void handleException(IOException e) {
        log.warn("IOException occurred: {}", e.getMessage());
    }
}