POC RSocket

Getting started

# build
mvn package

Running vanilla-server

The vanilla-server is a project using only RSocket library, no framework.

java -jar application/vanilla-server/target/vanilla-server-jar-with-dependencies.jar

Running vanilla-client

Several clients to showcase the RSocket models:

# fire & forget
java -cp client/vanilla-client/target/vanilla-client-jar-with-dependencies.jar \
    lin.louis.poc.rsocket.client.AddNumberFnFClient

# request / response
java -cp client/vanilla-client/target/vanilla-client-jar-with-dependencies.jar \
    lin.louis.poc.rsocket.client.SayHelloClient

# request / stream
java -cp client/vanilla-client/target/vanilla-client-jar-with-dependencies.jar \
    lin.louis.poc.rsocket.client.AddNumberStreamClient

# request / channel
java -cp client/vanilla-client/target/vanilla-client-jar-with-dependencies.jar \
    lin.louis.poc.rsocket.client.CountEvenNumbersClient

Using RSocket Client CLI:

# With TCP
# fire & forget
rsc tcp://localhost:7000 --debug --fnf --data 2

# request / response
rsc tcp://localhost:7000 --debug --request --data everyone

# request / stream
rsc tcp://localhost:7000 --debug --stream --data 2

# With WebSocket
# fire & forget
rsc ws://localhost:7001 --debug --fnf --data 2

# request / response
rsc ws://localhost:7001 --debug --request --data everyone

# request / stream
rsc ws://localhost:7001 --debug --stream --data 2

Running spring-boot-app

Using spring framework to check how it works with RSocket:

java -jar application/spring-boot-app/target/spring-boot-app.jar

Running spring-boot-client

Client using spring framework:

java -jar client/spring-boot-client/target/spring-boot-client.jar

At the time of writing this POC, I did not find anything about supporting request / channel model in Spring framework unfortunately.

However, routing is seamlessly supported by Spring with its @MessageMapping annotation.

Using RSocket Client CLI:

# fire & forget
rsc tcp://localhost:7002 --debug --fnf --data 2 --route add-number

# request / response
rsc tcp://localhost:7002 --debug --request --data everyone --route say-hello

# request / stream
rsc tcp://localhost:7002 --debug --stream --data 2 --route add-number-stream