保持活力：死亡对等点的监测

从现在开始，努力学习吧！本文《保持活力：死亡对等点的监测》主要讲解了等等相关知识点，我会在golang学习网中持续更新相关的系列文章，欢迎大家关注并积极留言建议。下面就先一起来看一下本篇正文内容吧，希望能帮到你！

我在 macos 本地主机上运行用 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)
    }
}

解决方案

对该问题的回答：

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

如果您使用正确的 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 年以来向 provide a way to set keepalive time and interval separately 提出的请求。

一些参考：

• rfc1122
• net: enable TCP keepalive on new connections from net.Dial
• net: enable TCP keepalives by default
• TCP keep-alive to determine if client disconnected in netty
• Using TCP keepalive with Go

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《保持活力：死亡对等点的监测》文章吧，也可关注golang学习网公众号了解相关技术文章。