Spring WebFlux发布

Question

我正在使用WebClient发布API，但它没有返回任何内容。我假设线程保持打开状态，并且没有完成，因为我可以使用一个块来获得我想要的东西，但我对WebClient和异步的东西还是很陌生，所以我不能百分之百确定。

具体而言，我有以下方法：

public Mono<AppDto> applicationPost(AppDto dto){    
   return webClient.post()
            .uri("/api/doStuff")
            .contentType(MediaType.APPLICATION_JSON)
            .body(MonoConverter.appDtoToMono(dto), String.class)
            .exchange()
            .flatMap(clientResponse -> clientResponse.bodyToMono(Map.class))
            .map(MonoConverter::mapValueToAppDto);
}

其中，MonoConverter对映射值进行一些转换，因此这应该是无关的。上面返回了一个202 Accepted，但它没有返回值，也没有命中我的MapValueToAppldTo方法。但是，以下方法确实有效：

public Mono<AppDto> applicationPost(AppDto dto){
    Map map = webClient.post()
            .uri("/api/doStuff")
            .contentType(MediaType.APPLICATION_JSON)
            .body(MonoConverter.appDtoToMono(dto), String.class)
            .exchange()
            .flatMap(clientResponse -> clientResponse.bodyToMono(Map.class))
            .block();
    return Mono.just(MonoConverter.mapValueToAppDto(map));
}

我假设这是可行的，因为它使用block，但我有一个类似的get方法：

public Mono<AppDto> applicationGetOne(String appId){
    return webClient.get()
            .uri("/api/getOne/{0}",appId)
            .exchange()
            .flatMap(clientResponse -> clientResponse.bodyToMono(Map.class))
            .map(MonoConverter::mapValueToAppDto);
}

我更喜欢使用第一个片段，因为它不使用block，而且它更简单，格式与我的其他方法相同。

有没有人知道为什么第一个不起作用，或者知道我怎样才能让它起作用？

Answer 1

我找到了出现此问题的原因。它实际上与我的控制器有关（D'oh！）。对于post方法，我有绑定错误的验证，所以我只是返回一个响应实体，而没有给它一个类型。所以我在响应实体中添加了一个类型，这解决了问题。

例如：

@PostMapping(value="/post")
public ResponseEntity addThing(@Validated @RequestBody AppDto dto, BindingResult result){
    ...
}

是什么解决了这个问题：

@PostMapping(value="/post")
public ResponseEntity<Mono<?>> addThing(@Validated @RequestBody AppDto dto, BindingResult result){
    ...
}

我假设，由于最初没有指定类型，它没有使用mono响应所在的线程，因此我从未得到响应，但通过声明类型，Spring知道使用mono，从而允许它完成。