Go语言 无法理解网络.TCPConn关闭写入和关闭读取

olmpazwi  于 2023-02-01  发布在  Go
关注(0)|答案(1)|浏览(284)

也许它很简单,但是我不能理解它。我一直在看围棋编程语言的书,其中一个练习题是
在netcat3中,接口值conn具有具体类型 * net. TCPConn,表示TCP连接。TCP连接由两部分组成,可以使用其CloseRead和CloseWrite方法独立关闭这两部分。修改netcat3的主goroutine,只关闭连接的write部分,这样程序就可以继续打印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也会结束,并且进程完成,没有错误?服务器端说:
写入传输控制协议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并从其端关闭连接?
我对套接字或连接是如何工作的没有任何高级知识。我喜欢钻研源代码,但那些文件描述符和其他东西现在对我来说太难了。抱歉英语不好:)

rpppsulh

rpppsulh1#

问题出在服务器端。

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的同时go echo(c, input.Text(), 1*time.Second)使用了那个连接并得到错误use of closed network connection,所以服务器自己关闭了它的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()
}

P.S.我的实验与这个问题有关,你可以找到here

相关问题