非法状态异常： 块（）/块第一（）/块最后（） 是阻塞，这在线程反应器中不受支持

Question

我在Spring Webflow中的阻塞操作出错了。我检索地址文档的Mono列表，并使用此地址文档的Mono列表来形成街道地址（带有Street），如下所示：

Mono<List<Address>> docs = getAddress(id, name);

AddressResponse addrResponse = new AddressResponse.Builder().
                        withStreet(docs.map(doc -> doc.stream().
                                 map(StreetAddress::map).
                                collect(Collectors.toList())).block()).
                        build();

地图方法：

 public static StreetAddress map(Address addr) {
            return new Builder().
                withId(addr.getId()).
                withStreet(addr.getStreetAddress()).
                build();
        }

当我执行上述代码时，它抛出一个“block（）/blockFirst（）/brockLast（）are-blocking，这在线程reactor-http-nio-2中不受支持”。你能建议一下如何修理吗。我想在不阻止它的情况下检索AddressResponse。此响应将进一步用于响应实体中的代码，如下所示：

 return Mono.just(ResponseEntity
                .status(HttpStatus.OK)
                .body(addrResponse)));

Answer 1

问题是你试图混合反应式和命令式代码。相反，只需将其映射到反应管道中：

Mono<AddressResponse> response = docs.map(addresses->{
  return new AddressResponse.Builder()
          .withStreet(addresses -> addresses.stream()
                                .map(StreetAddress::map)
                                .collect(Collectors.toList()))
           .build();
})

然后您可以按原样返回它，或将其映射到Mono