Update.

Author: xOS

cmd/dashboard/controller/controller.go

@@ -26,6 +26,26 @@ import (
 	"github.com/xos/serverstatus/service/singleton"
 )
 
+// handleBrokenPipe 中间件处理broken pipe错误
+func handleBrokenPipe(c *gin.Context) {
+	defer func() {
+		if err := recover(); err != nil {
+			// 检查是否为broken pipe错误
+			if errStr := fmt.Sprintf("%v", err); strings.Contains(errStr, "broken pipe") ||
+				strings.Contains(errStr, "connection reset") ||
+				strings.Contains(errStr, "use of closed network connection") {
+				// 静默处理broken pipe错误，不记录日志
+				c.Abort()
+				return
+			}
+			// 其他错误正常处理
+			log.Printf("HTTP处理错误: %v", err)
+			c.Abort()
+		}
+	}()
+	c.Next()
+}
+
 func ServeWeb(port uint) *http.Server {
 	gin.SetMode(gin.ReleaseMode)
 	r := gin.Default()
@@ -34,6 +54,7 @@ func ServeWeb(port uint) *http.Server {
 		pprof.Register(r)
 	}
 	r.Use(natGateway)
+	r.Use(handleBrokenPipe) // 添加broken pipe错误处理中间件
 	tmpl := template.New("").Funcs(funcMap)
 	var err error
 	// 直接用本地模板目录

cmd/dashboard/rpc/rpc.go

@@ -62,6 +62,13 @@ func DispatchTask(serviceSentinelDispatchBus <-chan model.Monitor) {
 		round := 0
 		endIndex := workedServerIndex
 		singleton.SortedServerLock.RLock()
+
+		// 安全检查：确保SortedServerList不为空
+		if len(singleton.SortedServerList) == 0 {
+			singleton.SortedServerLock.RUnlock()
+			continue
+		}
+
 		// 如果已经轮了一整圈又轮到自己，没有合适机器去请求，跳出循环
 		for round < 1 || workedServerIndex < endIndex {
 			// 如果到了圈尾，再回到圈头，圈数加一，游标重置
@@ -70,29 +77,50 @@ func DispatchTask(serviceSentinelDispatchBus <-chan model.Monitor) {
 				round++
 				continue
 			}
+
+			// 安全检查：确保服务器不为nil
+			currentServer := singleton.SortedServerList[workedServerIndex]
+			if currentServer == nil {
+				workedServerIndex++
+				continue
+			}
+
 			// 如果服务器不在线，跳过这个服务器
-			if singleton.SortedServerList[workedServerIndex].TaskStream == nil {
+			if currentServer.TaskStream == nil {
 				workedServerIndex++
 				continue
 			}
+
+			// 安全检查：确保SkipServers不为nil
+			skipServers := task.SkipServers
+			if skipServers == nil {
+				skipServers = make(map[uint64]bool)
+			}
+
 			// 如果此任务不可使用此服务器请求，跳过这个服务器（有些 IPv6 only 开了 NAT64 的机器请求 IPv4 总会出问题）
-			if (task.Cover == model.MonitorCoverAll && task.SkipServers[singleton.SortedServerList[workedServerIndex].ID]) ||
-				(task.Cover == model.MonitorCoverIgnoreAll && !task.SkipServers[singleton.SortedServerList[workedServerIndex].ID]) {
+			if (task.Cover == model.MonitorCoverAll && skipServers[currentServer.ID]) ||
+				(task.Cover == model.MonitorCoverIgnoreAll && !skipServers[currentServer.ID]) {
 				workedServerIndex++
 				continue
 			}
-			if task.Cover == model.MonitorCoverIgnoreAll && task.SkipServers[singleton.SortedServerList[workedServerIndex].ID] {
-				singleton.SortedServerList[workedServerIndex].TaskStream.Send(task.PB())
+			if task.Cover == model.MonitorCoverIgnoreAll && skipServers[currentServer.ID] {
+				if err := currentServer.TaskStream.Send(task.PB()); err != nil {
+					log.Printf("DispatchTask: 发送任务到服务器 %d 失败: %v", currentServer.ID, err)
+				}
 				workedServerIndex++
 				continue
 			}
-			if task.Cover == model.MonitorCoverAll && !task.SkipServers[singleton.SortedServerList[workedServerIndex].ID] {
-				singleton.SortedServerList[workedServerIndex].TaskStream.Send(task.PB())
+			if task.Cover == model.MonitorCoverAll && !skipServers[currentServer.ID] {
+				if err := currentServer.TaskStream.Send(task.PB()); err != nil {
+					log.Printf("DispatchTask: 发送任务到服务器 %d 失败: %v", currentServer.ID, err)
+				}
 				workedServerIndex++
 				continue
 			}
 			// 找到合适机器执行任务，跳出循环
-			singleton.SortedServerList[workedServerIndex].TaskStream.Send(task.PB())
+			if err := currentServer.TaskStream.Send(task.PB()); err != nil {
+				log.Printf("DispatchTask: 发送任务到服务器 %d 失败: %v", currentServer.ID, err)
+			}
 			workedServerIndex++
 			break
 		}