- SpringBoot 2.4.1
- Kotlin
- OpenJDK 11
- Gradle
RSocket Client CLI : https://github.com/making/rsc
open your macos Terminal , and keyin
brew install making/tap/rsc
now enjoy it.
Kotlin has more useful and powerful api than Java.
- Resource efficient
- Secured/robust codes
- Back pressure (inspired by TCP/UDP)
| Type | Value | Description |
|---|---|---|
| RESERVED | 0x00 | Reserved |
| SETUP | 0x01 | Sent by client to initiate protocol processing. |
| LEASE | 0x02 | Lease: Sent by Responder to grant the ability to send requests. |
| KEEPALIVE | 0x03 | Keepalive: Connection keepalive. |
| REQUEST_RESPONSE | 0x04 | Request Response: Request single response. |
| REQUEST_FNF | 0x05 | Fire And Forget: A single one-way message. |
| REQUEST_STREAM | 0x06 | Request Stream: Request a completable stream. |
| REQUEST_CHANNEL | 0x07 | Request Channel: Request a completable stream in both directions. |
| REQUEST_N | 0x08 | Request N: Request N more items with Reactive Streams semantics. |
| CANCEL | 0x09 | Cancel Request: Cancel outstanding request. |
| PAYLOAD | 0x0A | Payload: Payload on a stream. For example, response to a request, or message on a channel. |
| ERROR | 0x0B | Error: Error at connection or application level. |
| METADATA_PUSH | 0x0C | Metadata: Asynchronous Metadata frame |
| RESUME | 0x0D | Resume: Replaces SETUP for Resuming Operation (optional) |
| RESUME_OK | 0x0E | Resume OK : Sent in response to a RESUME if resuming operation possible (optional) |
| EXT | 0x3F | Extension Header: Used To Extend more frame types as well as extensions. |
Easy start the springboot app.
you can use rsc client test this app or another rsocket client app communicate.
go
rsc --debug --request --data "{\"message\":\"Hello\"}" --route request-response --stacktrace tcp://localhost:7000
rsc --debug --stream --route stream-get-all-members --stacktrace tcp://localhost:7000
rsc --debug --channel --data 2 --route channel-get-member-by-id --stacktrace tcp://localhost:7000
rsc --debug --fnf --data "bruce-client" --route fire-forget-log-health --stacktrace tcp://localhost:7000