From 9dae52a858030f4a5e6077a59496c544c2f421d0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=A7=89?= <huan0016@gmail.com>
Date: Sun, 22 Oct 2023 16:30:14 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BF=83=E8=B7=B3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main.js | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/src/main.js b/src/main.js
index 3ccf11d..1626c06 100644
--- a/src/main.js
+++ b/src/main.js
@@ -166,6 +166,29 @@ const chat = new Chat({
   }
 })
 
+// 与每个客户端保持心跳
+clientList.setChannel('ping', {
+  onopen: async (event, client) => {
+    console.log('打开信道', event.target.label)
+    clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'ping' }))
+  },
+  onmessage: async (event, client) => {
+    const data = JSON.parse(event.data)
+    if (data.type === 'ping') {
+      console.log(client.name, '心跳:', data)
+      clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'pong' }))
+      return
+    }
+    if (data.type === 'pong') {
+      console.log(client.name, '心跳:', data)
+      await new Promise((resolve) => setTimeout(resolve, 1000))
+      clientList.sendto(client.id, 'ping', JSON.stringify({ type: 'ping' }))
+      return
+    }
+    console.log('未知类型:', data.type)
+  }
+})
+
 // 与每个客户端都建立聊天信道
 clientList.setChannel('chat', {
   onopen: async (event, client) => {