Introduction
RSocket is a binary protocol for use on byte stream transports such as TCP, WebSockets, and Aeron.
It enables the following symmetric interaction models via async message passing over a single connection:
- request/response (stream of 1)
- request/stream (finite stream of many)
- fire-and-forget (no response)
- event subscription (infinite stream of many)
It supports session resumption, to allow resuming long-lived streams across different transport connections. This is particularly useful for mobile⬄server communication when network connections drop, switch, and reconnect frequently.
In our tutorial, we will implement RSocket using the Java programming language.
Why Springboot
Although I could simply implement RSocket with a simple Java application, I chose Springboot because it's a huge project on the JVM languages ecosystem. Springboot doesn't have a stable version for RSocket yet, but that shouldn't stop us experimenting with it.
Structure
Our project will consist of two sub-projects. The Consumer, who will do the requests and the Producer, who will provide the Consumer with data.
Getting Started
If you want to easily get started with a Springboot project I recommend always using the Spring Initializr.
Configuring Gradle
First of all we have to configure our build.gradle and include the rsocket-starter-dependency from Springboot:
For the Consumer we should include also the reactive-web-starter dependency, because we want to somehow display the data that we receive from the Producer.
Configuration
Now let's get our hands dirty and write some code 😉.
Producer
First we have to configure in which port will our Producer receive new connections:
The spring.rsocket.server.port=7000
configures the RSocket to start listening on port 7000 and the spring.main.lazy-initialization=true
is to make sure that Springboot will initialize its beans lazily.
Consumer
Now, here, we configure the RSocket client, by creating two Beans of type RSocket and RSocketRequester. The RSocket bean is used to create the connection to the Producer. The RSocketRequester bean is like our WebClient
(if we are using Reactive) or the RestTemplate
(if we are using MVC), he will do the requests to Producer.
The Actual Code
Our two applications (the Producer and the Consumer) will use the following domain objects for their communication:
Simple Communication
Let's start with an easy example, a simple Request with a single Response.
Producer
If you ever used WebSockets with Springboot the @MessageMapping
annotation should be familiar.
Here, with the @MessageMapping("greet")
we specify the route "greet", which receives a GreetingsRequest
and returns a single object GreetingsResponse
as a response.
Consumer
Here we see a simple @RestController
which injects the RSocketRequester
(the one we configured earlier) and uses him to do the Request. As you see, we tell the requester
to do a Request to the "greet" route (which we configured earlier in the Producer).
Communication with Stream
Delivering a stream of data with RSocket comes natural and with not that much of an effort.
Producer
As you see in the gist above, we configured our @MessageMapping
as before, but now we return a Flux (don't know what Mono and Flux are? Check this StackOverflow post).
We also use the .delayElements()
method to simulate a delay between our responses.
Consumer
Not much have changed from our other request to the Producer, clearly the .route("greet-stream")
. But if you see carefully, now our @GetMapping
produces a text/event-stream
and not the default application/json
.
Let's check the result!
Closing thoughts
So, that was it! I hope I gave you a clear explanation on how to use the new RSocket protocol!
You can find the project here:
Springboot RSocket
This project aims to give an idea on how to work with the RSocket protocol with the Springboot framework.
Getting started
./gradlew :producer:bootRun
./gradlew :consumer:bootRun
Navigate to:
http://localhost:8080/greet/{YourName}
http://localhost:8080/greet-stream/{YourName}
For more, check my getting started guide here: https://dev.to/petros0/getting-started-with-rsocket-in-springboot-5889.
Thanks for reading and have fun!
Top comments (0)