Spring WebFlux: Как перенаправить на другую функцию-обработчик на основе параметров запроса?

Question

Я пишу персональный API с использованием функционального программирования Spring WebFlux, как маршрутизировать различные функции-обработчики на основе имен параметров запроса?

    @Bean
    public RouterFunction<ServerResponse> route(PersonHandler personHandler) {
        return RouterFunctions.route(GET("/people/{id}").and(accept(APPLICATION_JSON)), personHandler::get)
                .andRoute(GET("/people").and(accept(APPLICATION_JSON)), personHandler::all)
                .andRoute(GET("/people/country/{country}").and(accept(APPLICATION_JSON)), personHandler::getByCountry)
//                .andRoute(GET("/people?name={name}").and(accept(APPLICATION_JSON)), personHandler::searchByName)
//                .andRoute(GET("/people?age={age}").and(accept(APPLICATION_JSON)), personHandler::searchByAge)
//                I am expecting to do something like this
                ;
    }

Или мне нужно обработать это в функции обработчика? как

    public Mono<ServerResponse> searchPeople(ServerRequest serverRequest) {
        final Optional<String> name = serverRequest.queryParam("name");
        final Optional<String> age = serverRequest.queryParam("age");
        Flux<People> result;

        if(name.isPresent()){
            result = name.map(peopleRepository::searchByName)
                    .orElseThrow();
        } else if(age.isPresent()){
            result = name.map(peopleRepository::searchByage)
                    .orElseThrow();
        }

        return ok().contentType(MediaType.APPLICATION_JSON).body(result, People.class);
    }

Каков наилучший способ сделать это?

Спасибо

Answer 1

Вы можете создать свой собственный RequestPredicate и использовать существующую инфраструктуру (подключив его к and()):

public static RequestPredicate hasQueryParam(String name) {
  return RequestPredicates.queryParam(name, p -> StringUtils.hasText(p));
}