RSocket 就是為服務(wù)而設(shè)計(jì)的。它是面向連接的、消息驅(qū)動(dòng)的協(xié)議，內(nèi)置了應(yīng)用程序級(jí)的流控制。它在瀏覽器中和在服務(wù)器上一樣工作。事實(shí)上，Web 瀏覽器可以服務(wù)于后端微服務(wù)的流量。它也是二進(jìn)制的。它可以同樣好地處理文本和二進(jìn)制數(shù)據(jù)，并且可以分解有效工作負(fù)載。它將應(yīng)用程序中的所有交互建模為網(wǎng)絡(luò)原語。這意味著，你可以流化數(shù)據(jù)或執(zhí)行發(fā)布 / 訂閱，而無需設(shè)置應(yīng)用程序隊(duì)列。

目前提供 Java、JavaScript、C++ 和 Kotlin 版本實(shí)現(xiàn)。

服務(wù)端示例代碼：

RSocketFactory.receive()
????.frameDecoder(Frame::retain)
????.acceptor(new?PingHandler())
????.transport(TcpServerTransport.create(7878))
????.start()
????.block()
????.onClose();

客戶端示例代碼：

Mono?client?=
????RSocketFactory.connect()
????????.frameDecoder(Frame::retain)
????????.transport(TcpClientTransport.create(7878))
????????.start();PingClient?pingClient?=?new?PingClient(client);Recorder?recorder?=?pingClient.startTracker(Duration.ofSeconds(1));int?count?=?1_000;pingClient????.startPingPong(count,?recorder)
????.doOnTerminate(()?->?System.out.println("Sent?"?+?count?+?"?messages."))
????.blockLast();