如果 Flux 有异常，如何“窥视”？

Question

我将 Spring Webflux 与 Tomcat servlet 容器（spring-boot-starter-web + spring-boot-starter-webflux）一起使用，我想获得以下信息结果：

如果flux of立即失败，我想发送给客户端响应码400

否则，我想发送响应代码 200 并流式传输通量

我尝试了不同的解决方案，但没有一个有效。 v1 和 v2 不发送预期的响应代码如果失败场景，v3 不流输出是快乐的场景。

我想“窥视”failFlux 上的异常并在发送响应代码 200 之前触发异常

@RequestMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public class X {
 Flux<String> happyFlux = Flux.generate(s -> s.next("x"));  
 Flux<String> failFlux = Flux.error(new ResponseStatusException(BAD_REQUEST));

 //ok: flux is streamed

 @RequestMapping("/v1/happy")
 Flux<String> v1Happy() {
    return happyFlux;
 }

 //nok: http status code is 200

 @RequestMapping("/v1/fail")
 Flux<String> v1Fail() {
    return failFlux;
 }

 //ok: flux is streamed

 @RequestMapping("/v2/happy")
 Mono<ResponseEntity<Flux<String>>> v2Happy() {
    return Mono.just(ResponseEntity.ok().body(happyFlux));
 }

 //nok: http status code is 200

 @RequestMapping("/v2/fail")
 Mono<ResponseEntity<Flux<String>>> v2Fail() {
    return Mono.just(ResponseEntity.ok().body(failFlux));
 }

 //nok: flux is not streamed but collected on server side

 @RequestMapping("/v3/happy")
 Mono<ResponseEntity<List<String>>> v3Happy() {
    return happyFlux.collectList().map(ResponseEntity::ok);
 }

 //ok: http status code is 400

 @RequestMapping("/v3/fail")
 Mono<ResponseEntity<List<String>>> v3Fail() {
    return failFlux.collectList().map(ResponseEntity::ok);
 }

附言。有趣的是，v1 和 v2 与 netty 一起工作（仅 spring-boot-starter-webflux）。

更新

我认为“偷窥”Flux 是不可能的。对于 servlet 堆栈，我真正需要的是在 Spring 中更好的 Flux 处理：https://jira.spring.io/browse/SPR-17440

Answer 1

我建议不要使用 collectList() ，因为这会破坏生成 Stream 的全部目的。 我相信如果出现异常消息，您应该得到 500。

例如，检查下面的代码。

public Mono<ServerResponse> listPeople(ServerRequest request) {
    int error = 10/0;
    Flux<Person> peopleFlux = this.repository.allPeople();
    peopleFlux = withDelay(peopleFlux);

    return ServerResponse.ok().contentType(MediaType.TEXT_EVENT_STREAM).body(peopleFlux, Person.class);


}

声明

int error = 10/0;

导致 500 异常，在客户端我得到 500。如果我注释掉错误语句，那么我得到 200。 所以，如果你没有得到 500，请分享你的代码。请注意，如果错误发生在服务器开始返回流中的单个事件之后，那么它不会是 500。 你应该使用 HTTP 207。https://httpstatuses.com/207