golang tcp 心跳包检测

在 Golang 中，可以通过定时发送心跳包并在一定时间内接收到响应确认来检测 TCP 连接是否正常。以下是一个简单的示例代码：

package main

import (
    "fmt"
    "net"
    "time"
)

func main() {
    conn, err := net.Dial("tcp", "127.0.0.1:8080")
    if err != nil {
        fmt.Println("Failed to connect:", err)
        return
    }
    defer conn.Close()

    // 发送心跳包的间隔时间
    interval := 5 * time.Second
    // 超时时间
    timeout := 10 * time.Second
    // 心跳包数据
    heartbeat := []byte("heartbeat")

    for {
        // 发送心跳包
        _, err := conn.Write(heartbeat)
        if err != nil {
            fmt.Println("Failed to send heartbeat:", err)
            return
        }

        // 设置读取超时时间
        conn.SetReadDeadline(time.Now().Add(timeout))

        // 接收响应
        buf := make([]byte, 1024)
        n, err := conn.Read(buf)
        if err != nil {
            fmt.Println("Failed to receive response:", err)
            return
        }

        // 检查响应是否正确
        if string(buf[:n]) != "heartbeat" {
            fmt.Println("Received invalid response:", string(buf[:n]))
            return
        }

        // 等待下一次发送心跳包
        time.Sleep(interval)
    }
}

在上面的代码中，我们使用 `net.Dial` 建立 TCP 连接，然后在一个无限循环中发送心跳包并接收响应。我们可以通过调整 `interval` 和 `timeout` 变量的值来控制心跳包的发送频率和超时时间。如果在超时时间内没有接收到响应，就意味着 TCP 连接出现了问题。