package main
 
import (
	"bufio"
	"fmt"
	"net"
	"os"
	"strings"
)
 
// TCP 服務端
func process(conn net.Conn) {
	// 函數(shù)執(zhí)行完之后關閉連接
	defer conn.Close()
	// 輸出主函數(shù)傳遞的conn可以發(fā)現(xiàn)屬于*TCPConn類型, *TCPConn類型那么就可以調(diào)用*TCPConn相關類型的方法, 其中可以調(diào)用read()方法讀取tcp連接中的數(shù)據(jù)
	fmt.Printf("服務端: %T\n", conn)
	for {
		var buf [128]byte
		// 將tcp連接讀取到的數(shù)據(jù)讀取到byte數(shù)組中, 返回讀取到的byte的數(shù)目
		n, err := conn.Read(buf[:])
		if err != nil {
			// 從客戶端讀取數(shù)據(jù)的過程中發(fā)生錯誤
			fmt.Println("read from client failed, err:", err)
			break
		}
		recvStr := string(buf[:n])
		fmt.Println("服務端收到客戶端發(fā)來的數(shù)據(jù)：", recvStr)
		// 由于是tcp連接所以雙方都可以發(fā)送數(shù)據(jù), 下面接收服務端發(fā)送的數(shù)據(jù)這樣客戶端也可以收到對應的數(shù)據(jù)
		inputReader := bufio.NewReader(os.Stdin)
		s, _ := inputReader.ReadString('\n')
		t := strings.Trim(s, "\r\n")
		// 向當前建立的tcp連接發(fā)送數(shù)據(jù), 客戶端就可以收到服務端發(fā)送的數(shù)據(jù)
		conn.Write([]byte(t))
	}
}
 
func main() {
	// 監(jiān)聽當前的tcp連接
	listen, err := net.Listen("tcp", "127.0.0.1:20000")
	fmt.Printf("服務端: %T=====\n", listen)
	if err != nil {
		fmt.Println("listen failed, err:", err)
		return
	}
	for {
		conn, err := listen.Accept() // 建立連接
		fmt.Println("當前建立了tcp連接")
		if err != nil {
			fmt.Println("accept failed, err:", err)
			continue
		}
		// 對于每一個建立的tcp連接使用go關鍵字開啟一個goroutine處理
		go process(conn) 
	}
}

package main
 
import (
	"bufio"
	"fmt"
	"net"
	"os"
	"strings"
)
 
func main() {
	// 連接到服務端建立的tcp連接
	conn, err := net.Dial("tcp", "127.0.0.1:20000")
	// 輸出當前建Dial函數(shù)的返回值類型, 屬于*net.TCPConn類型
	fmt.Printf("客戶端: %T\n", conn)
	if err != nil {
		// 連接的時候出現(xiàn)錯誤
		fmt.Println("err :", err)
		return
	}
	// 當函數(shù)返回的時候關閉連接
	defer conn.Close() 
	// 獲取一個標準輸入的*Reader結(jié)構體指針類型的變量
	inputReader := bufio.NewReader(os.Stdin)
	for {
		// 調(diào)用*Reader結(jié)構體指針類型的讀取方法
		input, _ := inputReader.ReadString('\n') // 讀取用戶輸入
		// 去除掉\r \n符號
		inputInfo := strings.Trim(input, "\r\n")
		// 判斷輸入的是否是Q, 如果是Q則退出
		if strings.ToUpper(inputInfo) == "Q" { // 如果輸入q就退出
			return
		}
		_, err = conn.Write([]byte(inputInfo)) // 發(fā)送數(shù)據(jù)
		if err != nil {
			return
		}
		buf := [512]byte{}
		// 讀取服務端發(fā)送的數(shù)據(jù)
		n, err := conn.Read(buf[:])
		if err != nil {
			fmt.Println("recv failed, err:", err)
			return
		}
		fmt.Println("客戶端接收服務端發(fā)送的數(shù)據(jù): ", string(buf[:n]))
	}
}