监测心跳时间

services/sse/sse.go

@@ -50,7 +50,7 @@ func (s *ServerSentRouter) Notify() {
 		}()
 		// 监听消息通道并发送给客户端
 		flusher := s.ResponseWriter.(http.Flusher)
-		ticker := time.NewTicker(60 * time.Second)
+		ticker := time.NewTicker(15 * time.Second)
 		defer ticker.Stop()
 		for {
 			select {