socket.d.js 是基于 websocket 包装的 socket.d 协议的实现。就是用 ws 传输数据，但功能更强大。
| 功能 | 原生 websocket | socket.d | 说明 |
|---|---|---|---|
| listen | 有 | 有 | 监听消息 |
| send | 有 | 有 | 发消息 |
| sendAndRequest | 无 | 有 | 发消息并接收一个响应（类似于 http） |
| sendAndSubscribe | 无 | 有 | 发消息并接收多个响应（也叫订阅） |
| event(or path) | 无 | 有 | 消息有事件或路径（可对消息，进行业务路由） |
| meta(or header) | 无 | 有 | 消息有元信息或头信息（可为数据，标注业务语义） |
| 自动心跳 | 无 | 有 | |
| 断开后自动重链 | 无 | 有 |
下面感受下开发方面的差异！
1、客户端示例代码
使用时，可以根据自己的业务对原生接口包装，进一步简化使用。
<script src="js/socket.d.js"></script>
<script>
async function init(){
//构建事件监听
const eventListener = await SocketD.newEventListener().doOnMessage((s,m)=>{
//监听所有消息（可能不需要）
}).doOn("/im/user.upline", (s,m)=>{ //事件的应用
//监听用户上线
let user_id = m.meta("user_id");
}).doOn("/im/user.downline", (s,m)=>{
//监听用户下线
let user_id = m.meta("user_id"); //元信息的应用
});
//创建单例
window.clientSession = SocketD.createClient("sd:ws://127.0.0.1:8602/?u=a&p=2")
.listen(eventListener)
.open();
}
function join(){
clientSession.sendAndRequest("/user/join", SocketD.newEntity()).thenReply(r->{
//加入成功
});
}
init();
</script>
Socket.D 有三个发消息的接口：
| 接口 | 说明 |
|---|---|
| send | 像 websocket。多了事件与元信息属性 |
| sendAndRequest | 像 http |
| sendAndSubscribe | 像 reactive stream 。多了事件与元信息属性 |
2、服务端示例代码（用 java 演示）
public class Demo {
public static void main(String[] args) throws Throwable {
List<Session> userSessions = new ArrayList<Session>();
//创建监听器
Listener listener = new EventListener().doOnOpen(s->{
//鉴权
if("a".equals(s.param("u")) == false){
s.close();
}else{
//加入用户表
s.attrPut("user_id", s.param("u"));
userSessions.add(s);
}
}).doOn("/user/join", (s,m)->{
if(m.isRequest()){
s.reply(m, new StringEntity());
}
for(Session s1: userSessions){
//告诉所有用户，有人上线
s1.send("/im/user.upline", new StringEntity().metaPut("user_id"), s.attr("userId"));
}
});
//启动服务
SocketD.createServer("sd:ws")
.config(c -> c.port(8602))
.listen(listener)
.start();
}
}
3、Socket.D 是什么东东？
Socket.D 是一个基于“事件”和“语义消息”“流”的网络应用层协议（听起来好像很 ao 口）。支持 tcp, udp, ws, kcp 传输（有各种不同语言的实现）。有用户说，“Socket.D 之于 Socket，尤如 Vue 之于 Js、Mvc 之于 Http”。
协议之所有强大，有三个关键基础因素：
- 事件
- 语义消息
- 流
它的帧码结构：
[len:int][flag:int][sid:str(<64)][\n][event:str(<512)][\n][metaString:str(<4k)][\n][data:byte(<16m)]
因为是应用层协议，所以可以建立在任意传输层协议之上。比如 websocket。