Spring Boot 4 Microservices & REST APIs · Урок

Реактивные контроллеры

Создавайте неблокирующие конечные точки с WebFlux

«Реактивные контроллеры» — бесплатный урок Spring Boot 4 Microservices & REST APIs на CoddyKit. Это урок 2 из 4. Ты можешь прочитать весь урок бесплатно ниже — а потом практиковать его прямо в браузере с встроенным редактором кода и ИИ-репетитором 24/7. Это часть пути обучения Spring Boot 4 Microservices & REST APIs, и твой прогресс синхронизируется между веб-версией и приложением CoddyKit. Курс Spring Boot 4 Microservices & REST APIs содержит 4 уроков всего.

Части этого урока еще не переведены и отображаются на английском.

Reactive Web Endpoints

With WebFlux you write @RestController classes just like in Spring MVC, but methods return reactive types instead of plain objects.

Return Mono<T> for a single resource
Return Flux<T> for a collection or stream

Returning a Mono

A handler returning Mono resolves to a single JSON object. The framework subscribes for you.

@RestController
@RequestMapping("/users")
public class UserController {
    @GetMapping("/{id}")
    public Mono<User> getUser(@PathVariable String id) {
        return userService.findById(id);
    }
}

Returning a Flux

A handler returning Flux serializes to a JSON array by default.

@GetMapping
public Flux<User> getAllUsers() {
    return userService.findAll();
}

No Blocking Allowed

Inside reactive handlers you must not call blocking code. Return the publisher and let the chain stay reactive.

// BAD: blocks the event loop
@GetMapping("/bad")
public User bad() {
    return userService.findById("1").block();
}

// GOOD: stays reactive
@GetMapping("/good")
public Mono<User> good() {
    return userService.findById("1");
}

Path and Query Params

Binding annotations work the same as in MVC: @PathVariable, @RequestParam, and @RequestBody.

@GetMapping("/search")
public Flux<User> search(@RequestParam String name) {
    return userService.findByName(name);
}

Accepting a Reactive Body

A POST handler can accept a Mono request body, keeping the whole flow non-blocking.

@PostMapping
public Mono<User> create(@RequestBody Mono<User> body) {
    return body.flatMap(userService::save);
}

Setting Status Codes

Use @ResponseStatus or wrap results in ResponseEntity within a Mono.

@PostMapping
@ResponseStatus(HttpStatus.CREATED)
public Mono<User> create(@RequestBody Mono<User> body) {
    return body.flatMap(userService::save);
}

ResponseEntity in a Mono

To control headers and status dynamically, return Mono<ResponseEntity<T>>.

@GetMapping("/{id}")
public Mono<ResponseEntity<User>> getUser(@PathVariable String id) {
    return userService.findById(id)
        .map(ResponseEntity::ok)
        .defaultIfEmpty(ResponseEntity.notFound().build());
}

Streaming with Server-Sent Events

Set the content type to text/event-stream to stream a Flux to the client over time.

@GetMapping(value = "/stream",
    produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<Long> stream() {
    return Flux.interval(Duration.ofSeconds(1));
}

Error Handling

Use onErrorResume to map errors to a fallback publisher, or a @ControllerAdvice for global handling.

@GetMapping("/{id}")
public Mono<User> getUser(@PathVariable String id) {
    return userService.findById(id)
        .onErrorResume(e -> Mono.error(
            new ResponseStatusException(HttpStatus.NOT_FOUND)));
}

The Netty Server

WebFlux runs on Netty by default — an event-loop server with a small fixed thread pool. This is why blocking calls are so harmful: blocking one thread stalls many requests.

Quick Check

Test your understanding of reactive controllers.

Recap

You learned how to build reactive endpoints:

@RestController methods return Mono or Flux
Never call block() inside a handler
Use ResponseEntity in a Mono for dynamic status
Stream with text/event-stream

Часто задаваемые вопросы

Урок «Реактивные контроллеры» бесплатный?

Да — полный текст урока «Реактивные контроллеры» бесплатно доступен здесь в веб-версии. Чтобы практиковать его интерактивно (встроенный редактор кода и ИИ-репетитор 24/7) и разблокировать остальной курс Spring Boot 4 Microservices & REST APIs, подпишись на CoddyKit PRO. Курс Spring Boot 4 Microservices & REST APIs содержит 4 уроков всего.

Чему я научусь в уроке «Реактивные контроллеры»?

Создавайте неблокирующие конечные точки с WebFlux Ты практикуешь Spring Boot 4 Microservices & REST APIs с помощью реального кода, который запускаешь прямо в браузере, и ИИ-репетитор 24/7 отвечает на твои вопросы во время урока.

Нужен ли мне опыт, чтобы начать Spring Boot 4 Microservices & REST APIs?

Предыдущий опыт не требуется. Spring Boot 4 Microservices & REST APIs на CoddyKit структурирован для всех уровней — от новичков до продвинутых, поэтому ты можешь начать отсюда или с самого начала и учиться в своем темпе. Это урок 2 из 4.

Сколько времени занимает урок «Реактивные контроллеры»?

Большинство уроков CoddyKit занимают около 5–10 минут. Каждый из них компактный и интерактивный, поэтому ты постоянно делаешь прогресс и продолжаешь с того же места в веб-версии и приложении.

Можно ли писать и запускать код в этом уроке Spring Boot 4 Microservices & REST APIs?

Да. Каждый урок Spring Boot 4 Microservices & REST APIs включает встроенный редактор кода, поэтому ты пишешь и запускаешь реальный код прямо в браузере и получаешь моментальную обратную связь от AI — локальная установка не требуется.

Все уроки этого курса

← Назад к Spring Boot 4 Microservices & REST APIs