我正在嘗試編寫(xiě)一個(gè)簡(jiǎn)單的tcp服務(wù)器和客戶端程序。當(dāng)我同時(shí)運(yùn)行下面的服務(wù)器和客戶端代碼時(shí)，客戶端將僅接收來(lái)自服務(wù)器的時(shí)間消息并退出，并且服務(wù)器繼續(xù)接受新連接。我預(yù)期的程序行為是我希望服務(wù)器也從客戶端接收“hello world”消息并關(guān)閉連接，客戶端也使用“響應(yīng)連接”功能也是如此。但問(wèn)題是，當(dāng)我啟動(dòng)客戶端時(shí)，服務(wù)器似乎卡在了conn。讀取“響應(yīng)連接”函數(shù)內(nèi)的函數(shù)，當(dāng)我首先停止客戶端時(shí)，錯(cuò)誤為“EOF退出狀態(tài)1”，這對(duì)于調(diào)試來(lái)說(shuō)確實(shí)是模棱兩可的。當(dāng)我首先停止服務(wù)器時(shí)，客戶端將從服務(wù)器接收時(shí)間數(shù)據(jù)。如果您有任何想法，請(qǐng)幫助回答，因?yàn)槲彝耆荊olang的新手。非常感謝！服務(wù)器.gopackage mainimport ( "fmt" "io" "log" "net" "time")type connection struct { host string port string network string}func checkError(err error) { if err != nil { log.Fatalln(err) }}func responseConnection(conn net.Conn) { defer conn.Close() // <-- When responseConnection() is used, add this buf := make([]byte, 0, 4096) tmp := make([]byte, 256) for { n, err := conn.Read(tmp) if err != nil { checkError(err) if err != io.EOF { fmt.Println("Error reading: ", err) } // fmt.Println(err) break } buf = append(buf, tmp[:n]...) } fmt.Println("Data from client ========> ", string(buf)) // c <- buf}func handleConnection(conn net.Conn) { defer conn.Close() // <- When responseConnection() is used, remove this dayTime := time.Now().String() conn.Write([]byte(dayTime)) // responseConnection(conn) fmt.Println("The end of handleConnection")}func main() { localConn := connection{ host: "", port: "5555", network: "tcp", } // servicePort := ":5555" tcpAddr, err := net.ResolveTCPAddr(localConn.network, ":"+localConn.port) checkError(err) l, err := net.ListenTCP("tcp", tcpAddr) fmt.Println("Server starts listening on port", localConn.port) checkError(err) for { fmt.Println("Accepting a new connection....") conn, err := l.Accept() checkError(err) handleConnection(conn) // responseConnection(conn) }}
TCP 客戶端或服務(wù)器卡在處理數(shù)據(jù)
滄海一幻覺(jué)
2022-09-19 10:43:17
