代码拉取完成,页面将自动刷新
sd:ws
需要客户端和服务端同时升级(因为加了 子协议验证
)
应用示例:
SocketD.createServer("sd:ws")
.listen(new EventListener()
.doOnOpen(s->{s.handshake().outMeta("test","1")})
)
.open();
应用示例:
SocketD.createClient("sd:ws://127.0.0.1")
.config(c => c
.heartbeatInterval(1000*5)
.fragmentSize(1024 * 1024)
.metaPut("test","1"))
.connectHandler(c=> {
console.log("connect begin...");
return c.connect();
})
.open();
接配置名 | 新配置名 | 备注 |
---|---|---|
maxThreads | exchangeThreads | 交换线程数,用于消息接收等(原来的名字,语义不明) |
coreThreads | codecThreads | 解码线程数,用于编解码等(原来的名字,语义不明) |
/ | ioThreads | Io线程数,用于连接等 |
sequenceMode | sequenceSend | 有锁顺序发送(原来的名字,语义不明) |
/ | nolockSend | 无锁发送 |
备注:关于线程配置,在不同的适配时使用情况不同。其中 exchange 支持直接配置线程池(以支持 jdk21 的虚拟线程池)
接配置名 | 新配置名 | 备注 |
---|---|---|
maxThreads | exchangeThreads | 交换线程数,用于消息接收等(原来的名字,语义不明) |
coreThreads | codecThreads | 解码线程数,用于编解码等(原来的名字,语义不明) |
/ | ioThreads | Io线程数,用于连接等 |
备注:关于线程配置在 js 里,基本没用到
安全退出集群机制
//通知要开始关闭了(集群相关方不会再发消息进来)
session.closeStarting();
//等5秒,结束正在处理的消息
sleep(5_000)
//正试关闭
session.close();