spring-boot - 如何在同一个应用程序中创建具有客户端和服务器的 RSocket 应用程序？

Question

我正在尝试制作一个项目，我想在其中创建一个包含服务器和客户端应用程序的 rsocket 应用程序。我尝试了很多东西，但似乎没有任何效果，有人可以帮我吗？

Answer 1

看看 LocalClientTransport 和 LocalServerTransport。

https://github.com/rsocket/rsocket-java/blob/d903e9635a159285b6943ea93156c31aa406ba5d/rsocket-transport-local/src/test/java/io/rsocket/transport/local/LocalPingPong.java

这应该像 websocket 或其他传输上的连接，但没有 IO 开销。

    RSocketServer.create(new PingHandler())
        .payloadDecoder(PayloadDecoder.ZERO_COPY)
        .bind(LocalServerTransport.create("test-local-server"))
        .block();

    Mono<RSocket> client =
        RSocketConnector.create()
            .payloadDecoder(PayloadDecoder.ZERO_COPY)
            .connect(LocalClientTransport.create("test-local-server"));