rsocket-server-raw.java

@Component
public record RService() {

    @EventListener(ApplicationReadyEvent.class)
    public void ready() {
        final Logger log = LoggerFactory.getLogger(RService.class);
        var transport = TcpServerTransport.create(InetSocketAddress.createUnresolved("localhost", 7766));
        var socket = new RSocket() {

            @Override
            public Mono<Void> fireAndForget(Payload payload) {
                var request = payload.getDataUtf8();
                log.info("received " + request);
                return Mono.empty();
            }
        };

        var socketAcceptor = SocketAcceptor.with(socket);
        RSocketServer.create(socketAcceptor)
                .bind(transport)
                .doOnNext(cc -> log.info("server started on " + cc.address()))
                .block();
    }
}