0

我在 macOS localhost 上运行用 Go (1.12) 编写的客户端和套接字服务器。

服务器在 net.TCPConn 上设置 SetKeepAlive 和 SetKeepAlivePeriod。
客户端发送一个数据包然后关闭连接（FIN）或客户端突然终止。

Tcpdump 显示即使在客户端关闭连接后，服务器也会继续发送保持活动探测。
它不应该检测到对等方“已死”并关闭连接吗？

这个问题很笼统，如果我缺少一些基础知识，请随时澄清。

package main

import (
    "flag"
    "fmt"
    "net"
    "os"
    "time"
)

func main() {
    var client bool
    flag.BoolVar(&client, "client", false, "")
    flag.Parse()

    if client {
        fmt.Println("Client mode")
        conn, err := net.Dial("tcp", "127.0.0.1:12345")
        checkErr("Dial", err)

        written, err := conn.Write([]byte("howdy"))
        checkErr("Write", err)

        fmt.Printf("Written: %v\n", written)
        fmt.Println("Holding conn")

        time.Sleep(60 * time.Second)

        err = conn.Close()
        checkErr("Close", err)

        fmt.Println("Closed conn")

        return
    }

    fmt.Println("Server mode")
    l, err := net.Listen("tcp", "127.0.0.1:12345")
    checkErr("listen", err)
    defer l.Close()

    for {
        c, err := l.Accept()
        checkErr("accept", err)
        defer c.Close()

        tcpConn := c.(*net.TCPConn)
        err = tcpConn.SetKeepAlive(true)
        checkErr("SetKeepAlive", err)
        err = tcpConn.SetKeepAlivePeriod(5 * time.Second)
        checkErr("SetKeepAlivePeriod", err)

        b := make([]byte, 1024)

        n, err := c.Read(b)
        checkErr("read", err)

        fmt.Printf("Received: %v\n", string(b[:n]))
    }
}

func checkErr(location string, err error) {
    if err != nil {
        fmt.Printf("%v: %v\n", location, err)
        os.Exit(-1)
    }
}
4

1 回答 1

2

对这个问题的回答：

仅当您需要打开连接但空闲时才需要发送 keepalive。在这种情况下，存在连接断开的风险，因此保持活动将尝试检测断开的连接。

如果您使用适当的 con.Close() 在服务器端关闭了连接，则不会触发保持活动（您确实将其推迟到主函数的末尾）。

如果您测试您的服务器代码，它将在您设置的超时后开始发送保持活动状态。

您注意到，只有在所有保持活动证明（内核默认为 9）和证明之间的时间（8x）之后，您才会在服务器端读取 io.EOF 错误（是的，服务器停止发送）！

目前 GO 实现在 Linux 和 OSX 上是相同的，它设置了TCP_KEEPINTVL和TCP_KEEPIDLE为您传递给setKeepAlivePeriod函数的值，因此，行为将取决于内核版本。

func setKeepAlivePeriod(fd *netFD, d time.Duration) error {
    // The kernel expects seconds so round to next highest second.
    d += (time.Second - time.Nanosecond)
    secs := int(d.Seconds())
    if err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, secs); err != nil {
        return wrapSyscallError("setsockopt", err)
    }
    err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, syscall.TCP_KEEPIDLE, secs)
    runtime.KeepAlive(fd)
    return wrapSyscallError("setsockopt", err)
}

自 2014 年以来，有一个请求提供了一种单独设置 keepalive 时间和间隔的方法。

一些参考资料：

于 2019-06-12T22:07:35.690 回答