Как получить атрибуты модели при использовании функций маршрутизатора Spring WebFlux? - PullRequest
Новая
       70

Как получить атрибуты модели при использовании функций маршрутизатора Spring WebFlux?

1 голос
/ 28 апреля 2020

Spring WebFlux предоставляет на выбор два варианта программирования: Аннотированные контроллеры и Функциональные конечные точки . В первом случае мы можем использовать аннотацию @ModelAttribute для передачи атрибутов модели из контроллера в представление (например, Thymeleaf html -template) и наоборот. Однако, когда дело доходит до функций маршрутизатора, я только что выяснил, как прикрепить атрибуты модели к ServerResponse, но не могу найти способ вернуть их. Рассмотрим следующий фрагмент кода: 

@Configuration
public class StudentsRouterFunctions {

    // inject repository
    private final StudentsCrudRepository repo;

    public StudentsRouterFunctions(StudentsCrudRepository repo) {
        this.repo = repo;
    }

    @Bean
    RouterFunction<?> routs() {
        return RouterFunctions.route()
                .GET("/students", this::showStudents)
                .POST("/students", this::saveStudent)
                .build();
    }

    // #1: GET-handler
    private Mono<ServerResponse> showStudents(ServerRequest request) {

        // set model attributes
        Map<String, Object> model = new HashMap<>();
        Mono<Student> studentsList = repo.findAll().collectList();
        Mono<Student> newStudent = Mono.just(new Student());
        model.put("students", studentsList);
        model.put("studentForm", newStudent);

        // render the view
        return ServerResponse.ok()
                .contentType(MediaType.TEXT_HTML)
                .render("students-template", model);
    }

    // #2: POST-handler
    private Mono<ServerResponse> saveStudent(ServerRequest request) {

        // and here I somehow need to get my new student object 
        // back from the view via "studentForm" model attribute

        // Student newStudent = request.getModel().get("studentForm"); 
        // !!! however, ServerRequest.getModel() method doesn't exist

        return repo.save(newStudent)
                .then(ServerResponse.status(HttpStatus.PERMANENT_REDIRECT)
                        .render("redirect:/students", new Object()));
    }

1 Ответ

1 голос
/ 28 апреля 2020

Нет метода ServerRequest::getModel, но ServerRequest::bodyToMono(Class), который извлекает тело, где находится ваша модель, до Mono<T>.

Затем используйте преимущество типа возврата метода реактивного хранилища ReactiveCrudRepository::save, возвращающего Mono<T> с использованием Mono::flatMap.

I Я не проверял его, но он должен работать. 

private Mono<ServerResponse> saveStudent(ServerRequest request) {
    return request.bodyToMono(Student.class)               // Mono<Student> (a new one)
                  .flatMap(repo::save)                     // Mono<Student> (a saved one)
                  .then(ServerResponse                     // redirect sequence
                      .status(HttpStatus.PERMANENT_REDIRECT)
                      .render("redirect:/students", new Object()));
}

// .flatMap(repo::save) is the same as .flatMap(newStudent -> repo.save(newStudent))

Обратите внимание, что метод Mono::then отбрасывает элемент из источника, поэтому перенаправленный объект остается как new Object(), поэтому вы хотите использовать Mono::map. 

private Mono<ServerResponse> saveStudent(ServerRequest request) {
    return request.bodyToMono(Student.class)               // Mono<Student> (a new one)
                  .flatMap(repo::save)                     // Mono<Student> (a saved one)
                  .map(savedStudent -> ServerResponse      // redirect sequence
                      .status(HttpStatus.PERMANENT_REDIRECT)
                      .render("redirect:/students", savedStudent));
}
...