RSocket Node.js Broker

RSocket Node.js Broker，架构如下:

注意实现：

• 考虑到接入的应用都是基于JavaScript，所以不再采用RSocket的Composite Metadata二进制规范，而是采用JSON数据格式，样例如下：

{
  "message/x.rsocket.routing.v0": [
    "com.example.logging.LoggingService.getLog"
  ]
}

应用接入

应用元信息

应用向Broker注册时，需要提供对应的元信息，如果是外部的设备接入，还需要提供接入的Token信息，请参考 https://github.com/rsocket/rsocket/blob/master/Extensions/Security/Authentication.md

应用的元信息保存在setupPayload的data中，主要信息如下：

{
  "name": "app-1",
  "ip": "192.168.1.1",
  "port": 8080,
  "owner": "leijuan",
  "tags": [
    "logging",
    "agent"
  ],
  "services": [
    "com.example.logging.LoggingService"
  ]
}

其中的services元素主要是向Broker注册应用提供的服务列表，如果没有对外提供服务，则忽略该元素。 为了方便进行应用管理，建议提供以下信息：

• name: 应用名称
• ip： IP地址
• owner: 应用拥有者
• tags: 应用标签列表

服务调用路由规则

RSocket的服务调用主要是基于RSocket的服务路由规范，详情请参考 https://github.com/rsocket/rsocket/blob/master/Extensions/Routing.md RSocket的路由规则是由多个Tags组成，第一个tag是请求的handler名称(服务名+函数名)，后续的tag都是辅助路由，比如调用指定节点的服务，格式如下即可：

{
  "message/x.rsocket.routing.v0": [
    "com.example.logging.LoggingService.getLog",
    "e=bc75a624-834f-4bb0-95cf-de3956f96d3f"
  ]
}

应用需求描述样例 - 日志服务

浏览器端发起RSocket请求，需要获取某一服务器下的日志信息：

• 请求类型： request/response
• 请求格式： json
• 请求路由： 需要带上对应服务器的UUID
• 服务名称: com.example.logging.LoggingService
• 服务接口: getLog(fileName, offset, limit) 其中offset为日志行号，limit为返回日志的总行数
• 返回: 日志行数

RSocket连接监控和监控度检查

在实际的部署中，会出现应用到RSocket Broker的网络连接问题，如果网络不可用导致连接断开等问题，这个时候就需要一个重连机制，考虑到架构的简洁性，建议使用Kubernetes的Liveness机制，对应用进行进行监控， 在RSocket连接不可用的情况下采用重启应用的方式重新连接到RSocket Broker。 详细请参考 Kubernetes - Configure Liveness, Readiness and Startup Probes

RSocket Broker提供了健康度检查接口，从应用端只需要发送以下信息，就可以测试应用到RSocket Broker之间网络是否正常，返回值为 {"status":"UP"}

{
  "message/x.rsocket.routing.v0": [
    "ping"
  ]
}

RSocket Broker

RSocket Broker的运维管理： Ops接口

为了方便Ops管理，RSocket Broker提供了另外一个RSocket监听端口(42253), 用于接收Ops请求，如你可以通过以下命令就可以查看当前的Broker上的应用信息。

rsc --request ws://localhost:42253

监听不同的端口主要是安全的考虑，而且也容易实现。更多的Ops需求，你只需要实现opsRequestHandler函数即可。

如果对接的Ops系统无法使用RSocket协议，你可以在RSocket Broker中启动一个Express.js服务，对外提供REST API服务。

浏览器端访问和负载均衡问题

如果浏览器端也要访问RSocket Broker，而且数量还比较大的话，建议部署多个Broker，然后对外提供服务。注意实现如下：

• 服务提供者要同时注册到Broker上： Broker之间是不通讯的，这样可以保证应用或者浏览器连接到任何一个Broker都可以调用服务
• 浏览器端负载均衡： 采用随机IP连接即可
• 安全考虑： 如果浏览器端接入需要安全认证，建议可以考虑JWT方式，这样可以携带应用的信息，当然还要设置一下对应的过期时间，如30秒。 RSocket是长连接，JWT主要用在连接创建时的验证，所以30秒是没有问题的

开发者体验(DX)

考虑到实际的开发便捷性，建议应用自行实现以下功能：

• RSocket Flowable 和 RxJS之间相互转换
• Single 和 Promise相互转换

References

• RSocket Protocol: https://rsocket.io/about/protocol
• RSocket Flowable API: https://github.com/rsocket/rsocket-js/blob/master/docs/03-flowable-api.md
• rsc: RSocket Client CLI https://github.com/making/rsc