响应式 Spring 查询参数

Ant*_*eda 2 handlers spring-boot queryparam reactive

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

GET /v1/address?type=business
Run Code Online (Sandbox Code Playgroud)

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

[
  { "id" : 1, "type" : "business", "street" : "..."},
  { "id" : 2, "type" : "business", "street" : "..."},
  ...
}
Run Code Online (Sandbox Code Playgroud)

我正在使用路由器功能来映射请求:

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

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

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

        ...
    }
}
Run Code Online (Sandbox Code Playgroud)

现在 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);
    });
}
Run Code Online (Sandbox Code Playgroud)

我也不能在参数上 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));
    });
}
Run Code Online (Sandbox Code Playgroud)

如果查询参数存在并退回到 getAllAddresses() 方法,那么使用查询参数的流程是什么?真的有可能吗?

g00*_*00b 6

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

request
    .getQueryParam("type")
    .map(type -> service.getAddressByType(type))
    .orElseGet(() -> service.getAllAddresses());
Run Code Online (Sandbox Code Playgroud)

在这种情况下,orElseGet()更有意义,因为它被懒惰地调用。请注意,这两种方法都应该具有相同的返回类型,因此可能Flux<Address>.