RSocket 面向连接的、消息驱动的协议开源项目

我要开发同款
匿名用户2018年11月11日
53阅读
开发技术Kotlin
所属分类网络工具包、程序开发
授权协议Apache

作品详情

RSocket就是为服务而设计的。它是面向连接的、消息驱动的协议,内置了应用程序级的流控制。它在浏览器中和在服务器上一样工作。事实上,Web浏览器可以服务于后端微服务的流量。它也是二进制的。它可以同样好地处理文本和二进制数据,并且可以分解有效工作负载。它将应用程序中的所有交互建模为网络原语。这意味着,你可以流化数据或执行发布/订阅,而无需设置应用程序队列。

目前提供Java、JavaScript、C++和Kotlin版本实现。

服务端示例代码:

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

客户端示例代码:

Mono<RSocket> 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();
声明:本文仅代表作者观点,不代表本站立场。如果侵犯到您的合法权益,请联系我们删除侵权资源!如果遇到资源链接失效,请您通过评论或工单的方式通知管理员。未经允许,不得转载,本站所有资源文章禁止商业使用运营!
下载安装【程序员客栈】APP
实时对接需求、及时收发消息、丰富的开放项目需求、随时随地查看项目状态

评论