npm/wo-base-websocket-server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

save commid to socket in addition to usid

Browse Source
This commit is contained in:
Luk 2024-09-20 19:12:12 +08:00
parent a33572c240
commit e88d063184
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
basesocket.js
View File

@ -50,7 +50,8 @@ module.exports = {
if (typeof _passtokenSource?.usid === 'string') { if (typeof _passtokenSource?.usid === 'string') {
socket.appkey = _passtokenSource.appkey socket.appkey = _passtokenSource.appkey
socket.usid = _passtokenSource.usid socket.usid = _passtokenSource.usid
socket.skid = socket.skid || _passtokenSource.clid || 'skid' + crypto.randomBytes(16).toString('hex') // 注意，skid 这个名字 仅限在本文件内使用，在外部都使用 clid (client id) socket.commid = _passtokenSource.commid
socket.skid = _passtokenSource.clid || socket.skid || 'skid' + crypto.randomBytes(16).toString('hex') // 注意，skid 这个名字 仅限在本文件内使用，在外部都使用 clid (client id)
// my.socketPool[socket.skid] = socket // my.socketPool[socket.skid] = socket
console.log( console.log(
{ {
@ -81,14 +82,14 @@ module.exports = {
}) })
}) })
my.wsServer.on('close', () => {}) my.wsServer.on('close', () => { })
// 一个全局的 heartbeat，不必给每个 socket 一个 heartbeat // 一个全局的 heartbeat，不必给每个 socket 一个 heartbeat
if (heartbeat) { if (heartbeat) {
console.log('WebSocket_heartbeat: starting...') console.log('WebSocket_heartbeat: starting...')
setInterval(() => { setInterval(() => {
my.wsServer.clients.forEach((socket) => { my.wsServer.clients.forEach((socket) => {
console.log('WebSocket_heartbeat: ', { usid: socket.usid, skid: socket.skid, appkey: socket.appkey, readyState: socket.readyState }) console.log('WebSocket_heartbeat: ', { usid: socket.usid, commid: socket.commid, skid: socket.skid, appkey: socket.appkey, readyState: socket.readyState })
if (socket.readyState !== ws.OPEN) { if (socket.readyState !== ws.OPEN) {
//socket.isAlive = false //socket.isAlive = false
} else { } else {
@ -106,7 +107,8 @@ module.exports = {
my.wsServer.clients.forEach((socket) => { my.wsServer.clients.forEach((socket) => {
if (clid && socket.skid === clid) { if (clid && socket.skid === clid) {
delete socket.usid delete socket.usid
// 要不要清除 socket.? 似乎不清除也没问题 delete socket.commid
// 要不要清除 socket.?clid 似乎不清除也没问题
} }
}) })
}, },