改进 SSE读取错误处理将读取错误处理机制从日志记录更改为向客户端发送错误消息，并在发送错误消息后中断循环。这样可以让客户端更及时地了解到…

…读取错误的发生，提高了错误处理的效率和用户体验。

pkg/controller/sse/sse.go

@@ -2,6 +2,7 @@ package sse
 
 import (
 	"bufio"
+	"fmt"
 	"io"
 	"log"
 	"net/http"
@@ -30,7 +31,10 @@ func WriteSSE(c *gin.Context, stream io.ReadCloser) {
 			if err == io.EOF {
 				break
 			}
-			log.Fatalf("Error reading log stream: %v", err)
+			// 处理读取错误，向客户端发送错误消息
+			c.SSEvent("error", fmt.Sprintf("Error reading stream: %v", err))
+			c.Writer.Flush()
+			break
 		}
 		// 发送 SSE 消息
 		c.SSEvent("message", line)