首先根据 Socket.D 官网的副标题,Socket.D 的自我定义是:
基于事件和语义消息流的网络应用协议。
官网定义的特点是:
Socket.D 是基于这些特性需求诞生的一种新型响应式网络协议。Socket.D 借鉴了很多其他协议发展过程中遇到的问题,然后总结归纳进自己的实践当中。
基于 Socket.D 的一些主要特性分别做一下介绍,并和 HTTP 之类的常见协议进行比较:
Socket.D 是基于显示连接地址的,可以实现像 http 或 websocket 一样的“频道”路由的效果。地址例:
//模拟聊天场景的用户地址 sd:tcp://127.0.0.1:8602 //模拟聊天场景的管理员地址 sd:tcp://127.0.0.1:8602/admin?u=admin&p=1234
Socket.D 每个消息都有事件描述,可以起到 path 或 topic 或 cmd 类似的路由效果。示例:
//模拟消息中间件的发布指令 client.send("event.mq.publish", new StringEvent("{userId:1}").metaSet("topic","demo")); //模拟消息中间件的订阅指令 client.send("event.mq.subscribe", new StringEvent("").metaSet("topic","demo"));
现在 Multiplexing,Asynchronous,Non-blocking I/O 已经被说烂了,基本上就是标配。这些特性意味着什么?拿HTTP的发展史感受一下:
所以,HTTP/2具有的优点,Socket.D 都有。另外,Socket.D 是一个二进制协议,也就是说在一个 Socket.D 连接上传输的消息体对数据格式没有任何要求,应用程序可以为所欲为的压缩数据量的大小。
这样的二进制协议通常来说能给性能带来极大的提升,但是产生的代价是,网络中间件也会因为无法解读消息体中的数据,丧失了在对具体应用流量进行监控,日志和路由的能力。所以 Socket.D 通过把每个消息体分成 sid, event, data 和 metaString 的方式,在保证高效传输的前提下,也提供了暴露元数据给网络中间件的能力(方便做语义处理),同时还能路由消息。
frame: {flag, message: {sid, event, entity: { metaString, data}}}
对于每个 data,应用可以采用不同的序列化方法。metaString 则采用标准的 url queryString 的通用格式(所有网络中间件通用)。
上面提到,HTTP这几年在传输性能上进步了很多。但说到底在应用层仍然仅支持client request/server response的交互模型。
这里一些同学可能有疑问,比如:
HTTP2.0推出了一个新的Server Push功能,但这个功能通常只是用来提前将一些静态资源返还给用户而已。举个例子:一个简单的网站有三个静态资源组成: index.html, index.css, index.js。 我们打开浏览器打开index.html,就会发起一个HTTP request拿到index.html。在不使用server push的情况下,我们要等浏览器解析出index.css 和 index.js之后才会再次向服务器发起请求。而运用server push,服务器可以根据一些规则预知到浏览器也需要index.css和index.js,并在客户端发送新的请求之前直接推送给该客户端。
所以,这个功能的使用场景非常有限,而且也不是一个真正双向的交互模式。
回到交互模式,Socket.D 的几种模式:
通常来说,越复杂的交互模式,为了保存交互状态,就需要占用更多的内存和计算资源。这也是为什么 Socket.D 会提供多种不同的 API。另外,当 Socket.D 的 client 和 server 建立了长连接之后,任何一方都可以是 Requester 或是 Responder。服务器也可以扮演 Requester 的角色,首先发起 Request。
Socket.D 还有另外一个非常重要的概念使之完全区分于类HTTP协议,那就是异步消息传递。
不同于HTTP当中存在Request,Response。Socket.D在网络传输上只有Frame这一个消息格式。有一个相同点是,类HTTP协议通常拥有一个显式的destination (URL),使用起来会非常有亲切感和简单。
如果Requester的 Socket.D 消息R首先通过了一个网络中间件(Broker),那么请求者(Requester)并不关心该消息的最终目的地在哪里,网络中间件可以全权负责路由模块的实现。该架构可以支持微服务,也可以支持IOT场景,等等。
这种架构很有意思,不仅能在微服务中加入streaming支持,还有如下特点:
由于 Socket.D 的双向流特性,和Broker建立连接的客户端即可以做Requester也可以做Responder,比如图中的Device 1和Device 2虽然是移动终端或者IOT设备,但仍然可以向其他设备或数据中心的主机提供服务
Socket.D 在成功建立连接时。如果该client想要暴露一个服务,则在连接地址上给自己取个名字(就像加入一个社交群,让别人能At到你)。连接成功建立之后,Socket.D Broker可以直接通过记录网络连接状况来达到服务注册和发现的效果。通过'@'参数取名示例:
sd:tcp://127.0.0.1:8602?@=demoapp
前面说过,Socket.D 是一个二进制协议,但仍然可以在消息体中通过 metaString 来暴露信息给网络中间件。每个消息实体的 metaString 会带有‘@’参数, 告诉 Socket.D Broker 消息应该转发给谁,从而实现路由效果。示例:
client.send("/demo", new StringEntity("").at("demoapp"));
与连接时给自己取名的 '@' 参数相乎应。取了名,就能被“别人” at 到!
整个架构当中,所有节点都只需要知道Broker的地址和服务端口即可。只要成功连接信息流就是双向的。Borker可以直接通过建立的Connection寻址服务节点,所有的服务调用者都不需要知道服务暴露方的地址
而Broker又可以通过连接的 url 地址,进行签权控制。
管理微服务集群往往需要有一个中心化的控制中心,在这个架构中 Socket.D Broker 就是自然而然的中心,知道整个集群中所有的情况。