From 6b235ba28c6ca4383222715b207811c1cea32a89 Mon Sep 17 00:00:00 2001
From: junleea <354425203@qq.com>
Date: Sat, 22 Mar 2025 17:38:44 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8D=E5=9C=A8=E5=BA=94=E7=94=A8=E5=B1=82?=
 =?UTF-8?q?=E5=8F=91=E9=80=81=E5=BF=83=E8=B7=B3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 handler/im.go | 33 ++++++++++++++++-----------------
 1 file changed, 16 insertions(+), 17 deletions(-)

diff --git a/handler/im.go b/handler/im.go
index 3b4211d..bc634fd 100644
--- a/handler/im.go
+++ b/handler/im.go
@@ -12,7 +12,6 @@ import (
 	"net/http"
 	"strconv"
 	"sync"
-	"time"
 )
 
 type SMessage struct {
@@ -85,8 +84,8 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) {
 	defer ws.Close()
 	ch := pubsub.Channel()
 	//定时器，每3秒发送一次心跳
-	ticker := time.NewTicker(3 * time.Second)
-	defer ticker.Stop()
+	//ticker := time.NewTicker(3 * time.Second)
+	//defer ticker.Stop()
 
 	var sessionID uint
 
@@ -153,18 +152,18 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) {
 	}()
 
 	//发送心跳包
-	for {
-		select {
-		case <-done:
-			//客户端断开连接
-			return
-		case t := <-ticker.C:
-			//发送心跳
-			err := ws.WriteMessage(websocket.PingMessage, nil)
-			if err != nil {
-				log.Println("Ping error:", err, t)
-				return
-			}
-		}
-	}
+	//for {
+	//	select {
+	//	case <-done:
+	//		//客户端断开连接
+	//		return
+	//	case t := <-ticker.C:
+	//		//发送心跳
+	//		err := ws.WriteMessage(websocket.PingMessage, nil)
+	//		if err != nil {
+	//			log.Println("Ping error:", err, t)
+	//			return
+	//		}
+	//	}
+	//}
 }