健康检查失败时，会自动尝试再次连接

2025-11-16 18:10:28 +08:00 · 2021-07-08 18:37:11 +08:00
parent 5512efbb70
commit 17008d6b03
1 changed files with 5 additions and 1 deletions
--- a/internal/tasks/health_check_executor.go
+++ b/internal/tasks/health_check_executor.go
@@ -185,7 +185,11 @@ func (this *HealthCheckExecutor) checkNode(healthCheckConfig *serverconfigs.Heal
 				if err != nil {
 					return nil, err
 				}
-				return net.Dial(network, result.NodeAddr+":"+port)
+				conn, err := net.Dial(network, result.NodeAddr+":"+port)
+				if err == nil {
+					return conn, nil
+				}
+				return net.DialTimeout(network, result.NodeAddr+":"+port, timeout)
 			},
 			MaxIdleConns:          1,
 			MaxIdleConnsPerHost:   1,