Reactive Programming with Spring Framework 5

Explore flux operations in reactive programming with Spring Framework 5, comparing flux and mono, and using blockFirst, subscribe, and collectList to convert a flux to a list.

Filter a flux of person objects in Spring Framework 5, compare next versus single for matches, and handle not found or multiple results with onErrorReturn and doOnError.

Use StepVerifier to inspect monos and fluxes, validate reactive stream behavior with expectNextCount, verifyComplete, and not found scenarios in Project Reactor tests.

Create the initial movie service layer that uses the MongoDB repository, and exposes getMovieById (mono) and getAllMovies (flux) via a MovieService interface.

Implement a Spring MVC rest controller for movies, mapping /movies, with get all movies returning a flux and get by id returning a mono, using path variable binding.

build a flux that emits a new movie event every second for a specific movie id and expose it as a text/event-stream streaming endpoint.

Compare imperative, declarative, and functional programming, emphasizing immutable data and thread safety. Discover Java 8 functional interfaces, including Function, Predicate, Supplier, and Consumer, and streaming pipelines in reactive Spring code.

Set up a WebClient-based beer client with a WebClientConfig and a base URL. Write lean tests that instantiate BeerClientImpl directly to mimic Spring wiring without the full context.

Implement optional query parameters for beer listings using a URI builder, covering page size, page number, beer name, style, and inventory, with tests to verify results.

Configure Netty-based WebClient logging by enabling wiretap on the reactor http client, setting log levels to debug or trace, and viewing detailed request and response bodies.

Use uriBuilder to bind url parameters (uuid, upc) in the V1 path, replacing string concatenation, and update WebClientProperties and BeerClient build method to pass parameters, and ensure tests pass.

Implement a post operation to create a new beer by sending a BeerDto with beerName, beerStyle, upc, and price, and validate a 201 created response.

Explore reactive threading and reactive API, refactor the get inventory by id test from blocking to a functional mono pipeline using map and flatMap, and manage race conditions with countdownLatch.

Update maven dependencies to spring-boot-starter-webflux, switch from spring mvc to webflux, and enable the Netty server, while removing mock MVC tests and preparing for reactive controller methods.

Discover Spring Data R2DBC as a reactive alternative to JPA and Hibernate, with non blocking drivers, learn to convert Hibernate JPA to R2DBC, updating datasource and dependencies for reactive CRUD.

Migrate an app to the R2DBC reactive framework for MySQL, update Maven dependencies, remove JPA and Hibernate, and convert repositories to a reactive CRUD repository with R2DBC and H2.

Refactor the list beers API to use reactive types via R2DBC fluent API, returning a Mono of beer paged list by mapping beer to beerDto and preserving the API.

Refactor the save new beer to return a mono of beerDto, enabling reactive flow across service and controller, and adjust tests for http 201 and id-based location.

Demonstrates refactoring the update beer operation to return 404 not found when the id is missing, using WebClient tests, AtomicBoolean logic, and reactive patterns in Spring Framework 5.

Explore functional endpoints and the functional programming paradigm in Spring Web Flux to rapidly build RESTful APIs, shifting from Spring MVC style controllers.

Implements server-side validation for BeerDto by wiring a Spring validator into the WebFlux flow, using doOnNext to apply validation and throwing ServerWebInputException on errors to return a bad request.

Explore handling update beer by id responses, implementing 404 not found and 204 statuses in a Spring reactive flow, with validation errors 400 and robust logging for path variables.

Implement a reactive delete by id in a Spring app, using findById and deleteById, with NotFoundException and 404 handling, and tests verify success and not-found.

Explore reactive streams by modeling continuous data flows, such as stock quotes and location information. Compare flux with earlier mono approaches and learn how streaming data enhances reactive programming.

Create a new streaming-stock-quote service project in IntelliJ using Spring Initializr, add WebFlux and Lombok, configure a reactive streaming service with no persistence, and commit to GitHub.

Develop a WebFlux quote handler with two methods: fetchQuotes returning JSON and streamQuotes delivering ndjson, using a quote generator service with a default size of 10.

Build a reactive quote router in Spring WebFlux, supporting json fetch and ndjson streaming. Implement router config and tests, configure a web test client, and validate with curl streaming demonstrations.

Explore reactive programming with Spring Framework 5 by streaming data from a stock quotes service and persisting it to MongoDB using Spring Data MongoDB's reactive capabilities.

Explore reactive MongoDB in a Spring context, covering NoSQL documents, JSON-like structures, and optional schemas, and learn to persist stock quotes to a local MongoDB using Spring Data reactive repositories.

Implement a quote runner that streams stock quotes, throttles to a cap, and persists them to Mongo via a reactive Spring Boot pipeline using a command line runner.

Explore reactive programming with Spring Framework 5 by using RabbitMQ as a scalable messaging broker to stream stock quote data with a reactive stock quote service.

Explore a reactive RabbitMQ application with Spring Reactor to send and read messages from queues, including configuring RabbitMQ and streaming stock quotes end to end.

Add and integrate a stock quote generation service in a Spring application, including the quote model, a services package, and the interface and implementation to stream stock quotes via RabbitMQ.

Configure a RabbitConfig class to define a queue name and create a connection mono with a caching connection factory, then build a RabbitFlux sender from it.

Set up a reactive RabbitMQ receiver in Spring, subscribe to a delivery flux, and log and count each received stock quote from a queue.