LaniakeaSupercluster
/
webrtc
2
2
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

移除心跳测试

This commit is contained in:
觉 2023-10-22 18:30:25 +08:00
parent f85316b86c
commit f79a2b2f66
1 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/main.js
View File

@ -166,28 +166,28 @@ const chat = new Chat({
} }
}) })
// 与每个客户端保持心跳 //// 与每个客户端保持心跳
clientList.setChannel('ping', { //clientList.setChannel('ping', {
onopen: async (event, client) => { // onopen: async (event, client) => {
console.log('打开信道', event.target.label) // console.log('打开信道', event.target.label)
clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'ping' })) // clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'ping' }))
}, // },
onmessage: async (event, client) => { // onmessage: async (event, client) => {
const data = JSON.parse(event.data) // const data = JSON.parse(event.data)
if (data.type === 'ping') { // if (data.type === 'ping') {
console.log(client.name, '心跳:', data) // console.log(client.name, '心跳:', data)
clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'pong' })) // clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'pong' }))
return // return
} // }
if (data.type === 'pong') { // if (data.type === 'pong') {
console.log(client.name, '心跳:', data) // console.log(client.name, '心跳:', data)
await new Promise((resolve) => setTimeout(resolve, 5000)) // await new Promise((resolve) => setTimeout(resolve, 5000))
clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'ping' })) // clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'ping' }))
return // return
} // }
console.log('未知类型:', data.type) // console.log('未知类型:', data.type)
} // }
}) //})
// 与每个客户端都建立聊天信道 // 与每个客户端都建立聊天信道
clientList.setChannel('chat', { clientList.setChannel('chat', {