Search⌘ K
AI Features
Home
Courses
Build E-Commerce Apps with Reactive Programming in Spring Boot

Creating a RSocket Server

Explore how to create an RSocket server in Spring Boot by adding the necessary dependencies and using Reactor Netty. Understand the use of FluxProcessor to manage dynamic reactive streams that deliver real-time data updates to subscribers, enabling efficient and scalable communication.

We'll cover the following...

Adding RSocket dependency

Let’s start by adding the following dependency to our pom.xml file:

XML
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-rsocket</artifactId>
</dependency>
Adding Spring Boot’s RSocket starter to the build file

This single addition to our build file introduces:

  • RSocket Core and Transport Netty
  • Reactor Netty
  • Spring Messaging (from the Spring Framework)
  • Jackson

The description of the above points is as follows:

  • RSocket: The protocol itself is implemented in Java.

  • Reactor Netty: Netty as a reactive message manager is valuable. Being wrapped in Reactor goodness makes Netty a powerful server.

  1. Spring + Jackson: How messages are picked up, serialized, transported, deserialized, and routed is just as important as the reactive nature of the protocol. Spring’s proven architecture of handling
...