无法理解 net.TCPConn CloseWrite 和 CloseRead

**摘要：** 在网络编程中，`net.TCPConn` 提供了 `CloseWrite` 和 `CloseRead` 方法，允许独立关闭连接的一端。在本文中，作者探讨了使用 `CloseWrite` 方法后，读取端也结束的原因。作者发现，这是由于服务器端错误地关闭了连接，导致并发写入例程接收到错误。为了解决这个问题，作者建议仅在写入例程完成工作后关闭连接，或直接删除连接内的并发。

也许很简单，但我无法理解。我一直在阅读go编程语言书籍，练习之一是

在netcat3中，接口值conn具有具体类型 *net.tcpconn，代表一个tcp连接。一个 tcp 连接包括 可以使用其 closeread 和 独立关闭的两半 closewrite 方法。修改netcat3的main goroutine，只关闭 写一半的连接，以便程序继续打印最后的回显 即使标准输入已关闭，也可从 reverb1 服务器获取。

我坚持了下来。我必须使用来自 https://github.com/adonovan/gopl.io/blob/master/ch8/reverb2/reverb.go 的简单 tcp 服务器

并且需要修改客户端

https://github.com/adonovan/gopl.io/blob/master/ch8/netcat3/netcat.go

我的代码：

package main

import (
    "io"
    "log"
    "net"
    "os"
)

//!+
func main() {
    //conn, err := net.Dial("tcp", "localhost:8000")
    tcpAdr, _ := net.ResolveTCPAddr("tcp", "localhost:8000")
    conn, err := net.DialTCP("tcp", nil, tcpAdr)
    if err != nil {
        log.Fatal(err)
    }
    done := make(chan struct{})
    go func() {
        _, e := io.Copy(os.Stdout, conn) // NOTE: ignoring errors
        log.Println("done", e)
        done <- struct{}{} // signal the main goroutine
    }()
    mustCopy(conn, os.Stdin)
    conn.CloseWrite()
    <-done // wait for background goroutine to finish
    conn.CloseRead()
}

//!-

func mustCopy(dst io.Writer, src io.Reader) {
    if _, err := io.Copy(dst, src); err != nil {
        log.Fatal(err)
    }
}

问题是：

为什么，如果我在 mustcopy() 成功结束后调用 conn.closewrite() ，匿名函数 gorutine 中的 io.copy 也会结束并且进程完成且没有错误？服务器端说：

write tcp 127.0.0.1:8000->127.0.0.1:58797：使用封闭的网络连接

就像我正在使用 conn.close() 一样。在我看来 conn.closewrite() 不应阻止读取端。经过几个小时的谷歌搜索后，我发现在 syscallshotdown(shut_wr) 调用之后，连接正在发送名为 fin 的内容

如果 tcp 堆栈仅收到 shut_wr 的关闭，则它应将此连接标记为无法发送更多数据。所有挂起的写请求都将完成，但后续的写请求将失败。此外，fin 数据包将被发送到另一方，通知他们我们没有更多数据要发送。

是我的问题吗？客户端关闭写连接 -> 发送 fin -> 服务器响应 fin 发送 fin 到主机 -> 客户端读连接接受 fin 并从其一侧关闭连接？

我对套接字或连接如何工作没有任何高级知识。我喜欢挖掘源代码，但那些文件描述符和其他东西现在对我来说太难了。抱歉英语不好:)

正确答案

问题出在服务器端。

func handleconn(c net.conn) {
    input := bufio.newscanner(c)
    for input.scan() {
        go echo(c, input.text(), 1*time.second)
    }
    // note: ignoring potential errors from input.err()
    c.close()
}

收到fin（由客户端的shut_wr引起）后，服务器的input.scan()循环被中断，这是一个正确的行为，因为当写入器（客户端）通知它没有更多的信息时，没有理由继续读取要写入的数据。

之后 c.close() 立即关闭连接，这是一个错误，因为同时编写 goroutine(s) go echo(c, input.text(), 1*time.second) 使用该连接并收到错误 use 关闭的网络连接 。因此服务器本身会关闭其 goroutine 的连接。为了解决这个问题，服务器应该仅在编写 goroutine 完成其工作后关闭连接。

修复可能如下所示：

func handleconn(c net.conn) {
    input := bufio.newscanner(c)
    var wg sync.waitgroup
    for input.scan() {
        wg.add(1)
        go func(text string) {
            defer wg.done()
            echo(c, text, 1*time.second)
        }(input.text())
    }
    // note: ignoring potential errors from input.err()
    wg.wait()
    c.close()
}

或者只是删除单个连接内的并发：

func handleConn(c net.Conn) {
    input := bufio.NewScanner(c)
    for input.Scan() {
        echo(c, input.Text(), 1*time.Second)
    }
    // NOTE: ignoring potential errors from input.Err()
    c.Close()
}

附注我与该问题相关的实验您可以找到 here。

好了，本文到此结束，带大家了解了《无法理解 net.TCPConn CloseWrite 和 CloseRead》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！