Reactive Spring查询参数

Question

我的Spring Reactive Web API应该能够根据查询参数进行过滤，但我正在努力做到这一点。

GET /v1/address?type=business

应该返回系统中所有'business‘类型的地址(这只是一个例子，因为我并没有发布实际的需求)。如果参数不存在，则只返回所有地址。

[
  { "id" : 1, "type" : "business", "street" : "..."},
  { "id" : 2, "type" : "business", "street" : "..."},
  ...
}

我使用Router函数来映射请求：

public RouterFunction<ServerResponse> route(AddressHandler handler) {
    return route(GET("/v1/address"), handler::getAddresses);
}

但我正在努力确定如何检查参数，如果参数不存在，则返回所有地址。

class AddressHandler {
    Mono<ServerResponse> getAddressesFilteredOrNot(ServerRequest request) {
        Optional<String> addressType = request.getQueryParam("type");

        ...
    }
}

现在Optional.ifPresent()不起作用了，我不能从这个方法返回：

class AddressHandler {
    Mono<ServerResponse> getAddressesFilteredOrNot(ServerRequest request) {
        Optional<String> addressType = request.getQueryParam("type");

        // invalid
        addressType.ifPresent(addrType -> {
            return ServerResponse.ok()
                .body(this.service.getAddressByType(addrType),
                   Address.class);
    });
}

另外，我不能在参数上使用switchIfEmpty()，因为它抛出了一个NullPointerException：

class AddressHandler {
    Mono<ServerResponse> getAddressesFilteredOrNot(ServerRequest request) {
        Optional<String> addressType = request.getQueryParam("type");

        // also invalid
        return Mono.justOrEmpty(addressType.orElse(""))
               .flatMap(addrType -> ServerResponse.ok().body(this.service.getAddressByType(addrType), Address.class)
               .switchIfEmpty(ServerResponse.ok().body(this.service.getAllAddresses(), Address.class));
    });
}

如果查询参数存在并依赖于getAllAddresses()方法，那么使用查询参数的流程是什么？这真的可能吗？

Answer 1

您可以使用Optional的orElse()或orElseGet()功能来调用替代方法。例如：

request
    .getQueryParam("type")
    .map(type -> service.getAddressByType(type))
    .orElseGet(() -> service.getAllAddresses());

在这种情况下，orElseGet()更有意义，因为它是延迟调用的。但请注意，这两个方法应该具有相同的返回类型，因此可能是Flux<Address>。