也许它很简单,但是我不能理解它。我一直在看围棋编程语言的书,其中一个练习题是
在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并从其端关闭连接?
我对套接字或连接是如何工作的没有任何高级知识。我喜欢钻研源代码,但那些文件描述符和其他东西现在对我来说太难了。抱歉英语不好:)
1条答案
按热度按时间rpppsulh1#
问题出在服务器端。
在接收到
FIN
(由客户端的SHUT_WR
引起)之后,服务器的input.Scan()
循环被中断,并且这是正确的行为,因为当写入器(客户端)通知它没有更多的数据要写入时,没有理由继续阅读。之后
c.Close()
立即关闭连接,这是一个错误,因为在写goroutine的同时go echo(c, input.Text(), 1*time.Second)
使用了那个连接并得到错误use of closed network connection
,所以服务器自己关闭了它的goroutine的连接,为了解决这个问题,服务器应该在写goroutine完成它的工作后才关闭连接。修复可能类似于:
或者仅删除单个连接中的并发:
P.S.我的实验与这个问题有关,你可以找到here。