基于语义消息流的网络开发框架
Socket.D 是一种应用协议，也是一个开发框架。可以在客户端和服务端之间“快速”、“高质量”、“流式”自由通讯。
- 异步通讯，由带语义的主题消息驱动
- 语言无关，使用二进制通信协议（支持 tcp, ws, udp）。支持多语言、多平台
- 背压流控，请求时不让你把服务端发死了
- 断线重连，自动连接恢复
- 多路复用
- 双向通讯，单链接双向互听互发
- 自动分片，数据超出 16Mb，会自动分片、自动重组（udp 除外）
- 扩展定制，可为数据添加 meta 语义标注（就像 http header）
- 接口简单
| 对比项目 | socket.d | http | websocket(ws) | 备注 |
|---|---|---|---|---|
| 发消息（Qos0） | 有 | 无 | 有 | 适合监听埋点，日志上报 |
| 发送并请求（Qos1） | 有 | 有 | 无 | 适合马上答复确认 |
| 发送并订阅（流） | 有 | 无 | 无 | 适合视频播放之类的，分块流式获取 |
| 答复或响应 | 有 | 有 | 无 | |
| 单连接双向通讯 | 有 | 无 | 有（不便） | 双向互发、互听。适合反向调服务 |
| 数据分片 | 有 | / | 无 | 适合大文件上传 |
| 断线自动重连 | 有 | / | 无 | |
| 有元信息或头信息 | 有 | 有 | 无 | |
| 基础传输协议 | tcp, udp, ws | tcp | http |
可用于 MSG、RPC、IM、MQ 等一些的场景开发，可替代 Http, Websocket, gRpc 等一些协议。比如移动设备与服务器的连接，比如一些微服务场景等等。
简单的协议说明（ 详见：《协议文档》 ）
- 连接地址风格
sd:tcp://19.10.2.3:9812/path?u=noear&t=1234
sd:udp://19.10.2.3:9812/path?u=noear&t=1234
sd:ws://19.10.2.3:1023/path?u=noear&t=1234
- 帧码结构
//udp only <2k
[len:int][flag:int][sid:str(<64)][\n][topic:str(<512)][\n][metaString:str(<4k)][\n][data:byte(<16m)]
- 指令流
| Flag | Server | Client |
|---|---|---|
| Unknown | ::close() | ::close() |
| Connect | / | c(Connect)->s::onOpen(),s(Connack?)->c::onOpen() |
| Connack | ->s::onOpen(),s(Connack?)->c | / |
| Ping | / | c(Ping)->s(Pong)->c |
| Pong | ->s(Pong)->c | / |
| Close | s(Close)->c | c(Close)->s |
| Message | s(Message)->c | c(Message)->s |
| Request | s(Request)->c(Reply or ReplyEnd)->s | c(Request)->s(Reply or ReplyEnd)->c |
| Subscribe | s(Subscribe)->c(Reply...ReplyEnd)->s | c(Subscribe)->s(Reply...ReplyEnd)->c |
| Reply | ->s(Reply)->c | ->c(Reply)->s |
| ReplyEnd | ->s(ReplyEnd)->c | ->c(ReplyEnd)->s |
//The reply acceptor registration in the channel is removed after the reply is completed
- 学习
请点击：《快速入门与学习》。Java 之外的语言与平台会尽快跟进（欢迎有兴趣的同学加入社区）
- 规划情况了解
| 语言或平台 | 客户端 | 服务端 | 备注 |
|---|---|---|---|
| java | 已完成 | 已完成 | 支持 tcp, udp, ws 通讯架构 |
| js | 开发中 | / | 支持 ws 通讯架构 |
| python | 开发中 | / | 支持 ws 通讯架构 |
| 其它 | 计划中 | 计划中 |
| QQ交流群：870505482 | 微信交流群（申请时输入：SocketD） |
|---|---|
 |
交流群里，会提供 "保姆级" 支持和帮助。如有需要，也可提供技术培训和顾问服务
public class Demo {
public static void main(String[] args) throws Throwable {
//::启动服务端
SocketD.createServer(new ServerConfig("sd:tcp").port(8602))
.listen(new SimpleListener(){
@Override
public void onMessage(Session session, Message message) throws IOException {
if(message.isRequest()){
session.replyEnd(message, new StringEntity("And you too."));
}
}
})
.start();
Thread.sleep(1000); //等会儿，确保服务端启动完成
//::打开客户端会话
Session session = SocketD.createClient("sd:tcp://127.0.0.1:8602/?token=1b0VsGusEkddgr3d")
.open();
//发送并请求（且，收回答复）
Entity reply = session.sendAndRequest("/demo", new StringEntity("Hello wrold!").meta("user","noear"));
}
}