Spring Data R2DBC CRUD Example

Overview: In this article, I would like to show you how to perform various CRUD operations using Spring Data R2DBC  along with Spring WebFlux. I would use Postgres in this example. If you are using H2/MySQL..etc the concept remains same. Spring Data R2DBC: R2DBC stands for Reactive Relational DB connectivity. As a Java developer, you know

Spring Data R2DBC CRUD ExampleRead More »

Scatter Gather Pattern

Overview In this tutorial, I would like to demonstrate Scatter Gather Pattern which is one of the Enterprise Integration Patterns for the distributed system architecture using NATS messaging server. Please check my previous artcile here to know more about NATS. Scatter Gather Pattern Let’s consider an application in which we need to do a set

Scatter Gather PatternRead More »

spring webflux streaming

Spring WebFlux Streaming

Overview: In this tutorial, I would like to demo Spring WebFlux Streaming Response (aka Server Sent Events) – a mechanism for pushing notifications/messages to the browsers from the back-end application in real time. Spring WebFlux Streaming: Traditionally browsers have to make a request to the server to fetch the latest information. It has worked just

Spring WebFlux StreamingRead More »

Reactive gRPC In Java

Overview: In this tutorial, I would like to show you how to apply the reactive streams & develop Reactive gRPC. If you are new to both gRPC and reactor, then you might have to check these articles first! gRPC series reactor series Prerequisite: gRPC Unary API In Java – Easy Steps gRPC Client Streaming API In

Reactive gRPC In JavaRead More »

gRPC Bidirectional Streaming

Overview: In this tutorial, I would like to show you how to implement gRPC Bidirectional Streaming API in Java. I assume that you have a basic understanding of what gRPC is. If not, read the below articles first. Protocol Buffers – A Simple Introduction gRPC – An Introduction Guide gRPC Unary API In Java – Easy Steps gRPC Server

gRPC Bidirectional StreamingRead More »

MongoDB Tailable Cursor With WebFlux

Overview: In this tutorial, I would like to show you how to access the MongoDB Tailable Cursor or Infinite Streams with Spring Data Reactive MongoDB. This approach can help us to develop a Spring Boot application to automatically notify our users on the new records getting inserted into a collection. MongoDB Tailable Cursor: By default, when

MongoDB Tailable Cursor With WebFluxRead More »

MongoDB Aggregation Pipeline With Reactive Spring Data

Overview: In this tutorial, I would like to show how to use the MongoDB Aggregation Pipeline to process multiple documents and present the data in the desired format with Reactive Spring Data MongoDB Repository and MongoDB Template. Project Setup: Lets first create a simple spring boot project with these dependencies. Sample Application: Let’s consider an application

MongoDB Aggregation Pipeline With Reactive Spring DataRead More »

reactor hot publisher

Reactor limitRate Example

Overview: In this tutorial, Lets see how we could use Reactor limitRate to limit the rate of the incoming or outgoing messages through our reactive channel. If you are new to project reactor, take a look at all these articles here first for better understanding. Reactor limitRate: In reactive programming, we have subscribers (downstream) and

Reactor limitRate ExampleRead More »

RSocket + WebSocket + Spring Boot = Real Time Application

Overview: In this tutorial, I would like to show you how to create a real time application using RSocket WebSocket & Spring Boot.  If you are new to RSocket, take a loot these articles first. RSocket With Java – Getting Started RSocket With Spring Boot RSocket – Uploading Files With Reactive Programming Sample Application: Our

RSocket + WebSocket + Spring Boot = Real Time ApplicationRead More »