## TCP協議 TCP/IP(Transmission Control Protocol/Internet Protocol) 即傳輸控制協議/網間協議，是一種面向連接（連接導向）的、可靠的、基于字節流的傳輸層（Transport layer）通信協議，因為是面向連接的協議，數據像水流一樣傳輸，會存在黏包問題 TCP服務端程序的處理流程： ~~~ 1.監聽端口 2.接收客戶端請求建立鏈接 3.創建goroutine處理鏈接。 ~~~ Go語言的net包實現的TCP服務端代碼如下： ~~~ // TCP server端 // 處理函數 func process(conn net.Conn) { defer conn.Close() // 關閉連接 for { reader := bufio.NewReader(conn) var buf [128]byte n, err := reader.Read(buf[:]) // 讀取數據 if err != nil { fmt.Println("read from client failed, err:", err) break } recvStr := string(buf[:n]) fmt.Println("收到client端發來的數據：", recvStr) conn.Write([]byte(recvStr)) // 發送數據 } } func main() { listen, err := net.Listen("tcp", "127.0.0.1:20000") if err != nil { fmt.Println("listen failed, err:", err) return } for { conn, err := listen.Accept() // 建立連接 if err != nil { fmt.Println("accept failed, err:", err) continue } go process(conn) // 啟動一個goroutine處理連接 } } ~~~ Go語言的net包實現的TCP客戶端代碼如下： ~~~ // 客戶端 func main() { conn, err := net.Dial("tcp", "127.0.0.1:20000") if err != nil { fmt.Println("err :", err) return } defer conn.Close() // 關閉連接 inputReader := bufio.NewReader(os.Stdin) for { input, _ := inputReader.ReadString('\n') // 讀取用戶輸入 inputInfo := strings.Trim(input, "\r\n") if strings.ToUpper(inputInfo) == "Q" { // 如果輸入q就退出 return } _, err = conn.Write([]byte(inputInfo)) // 發送數據 if err != nil { return } buf := [512]byte{} n, err := conn.Read(buf[:]) if err != nil { fmt.Println("recv failed, err:", err) return } fmt.Println(string(buf[:n])) } } ~~~