在Go语言中，可以使用net包和time包来实现基于TCP的心跳机制。下面是一个示例代码： ```go package main import ( "fmt" "net" "time" ) func main() { serverAddr := "127.0.0.1:8080" // 服务器地址 interval := 5 * time.Second // 心跳间隔 // 启动心跳检测 go startHeartbeat(serverAddr, interval) // 其他业务逻辑... } func startHeartbeat(addr string, interval time.Duration) { for { conn, err := net.Dial("tcp", addr) if err != nil { fmt.Printf("无法连接到服务器: %v\n", err) time.Sleep(interval) continue } defer conn.Close() // 发送心跳消息 heartbeatMsg := []byte("heartbeat") _, err = conn.Write(heartbeatMsg) if err != nil { fmt.Printf("发送心跳消息失败: %v\n", err) time.Sleep(interval) continue } // 等待心跳响应 response := make([]byte, len(heartbeatMsg)) _, err = conn.Read(response) if err != nil { fmt.Printf("接收心跳响应失败: %v\n", err) time.Sleep(interval) continue } // 检查心跳响应 if string(response) != string(heartbeatMsg) { fmt.Println("心跳响应错误") } // 等待心跳间隔 time.Sleep(interval) } } ``` 以上代码中，我们通过net包的Dial函数建立与服务器的TCP连接。然后在一个无限循环中，发送心跳消息并等待服务器的心跳响应。如果连接失败或者发送/接收心跳消息失败，程序会等待指定的心跳间隔后重试。这样就实现了基于TCP的心跳机制。 需要注意的是，上述代码只提供了一个简单的示例，实际使用中可能需要更复杂的逻辑来处理连接异常、处理心跳超时等情况。