1、TCP編程

1.1.1 Go語(yǔ)言實(shí)現(xiàn)TCP通信

TCP協(xié)議
TCP/IP(Transmission Control Protocol/Internet Protocol) 即傳輸控制協(xié)議/網(wǎng)間協(xié)議，是一種面向連接（連接導(dǎo)向）的、可靠的、基于字節(jié)流的傳輸層（Transport layer）通信協(xié)議，因?yàn)槭敲嫦蜻B接的協(xié)議，數(shù)據(jù)像水流一樣傳輸，會(huì)存在黏包問(wèn)題。

TCP服務(wù)端
一個(gè)TCP服務(wù)端可以同時(shí)連接很多個(gè)客戶端，例如世界各地的用戶使用自己電腦上的瀏覽器訪問(wèn)淘寶網(wǎng)。因?yàn)镚o語(yǔ)言中創(chuàng)建多個(gè)goroutine實(shí)現(xiàn)并發(fā)非常方便和高效，所以我們可以每建立一次鏈接就創(chuàng)建一個(gè)goroutine去處理。

TCP服務(wù)端程序的處理流程：

1.監(jiān)聽(tīng)端口
2.接收客戶端請(qǐng)求建立鏈接
3.創(chuàng)建goroutine處理鏈接。

我們使用Go語(yǔ)言的net包實(shí)現(xiàn)的TCP服務(wù)端代碼如下：

// tcp/server/main.go

// TCP server端

// 處理函數(shù)
func process(conn net.Conn) {
    defer conn.Close() // 關(guān)閉連接
    for {
        reader := bufio.NewReader(conn)
        var buf [128]byte
        n, err := reader.Read(buf[:]) // 讀取數(shù)據(jù)
        if err != nil {
            fmt.Println("read from client failed, err:", err)
            break
        }
        recvStr := string(buf[:n])
        fmt.Println("收到client端發(fā)來(lái)的數(shù)據(jù)：", recvStr)
        conn.Write([]byte(recvStr)) // 發(fā)送數(shù)據(jù)
    }
}

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) // 啟動(dòng)一個(gè)goroutine處理連接
    }
}

將上面的代碼保存之后編譯成server或server.exe可執(zhí)行文件。

TCP客戶端
一個(gè)TCP客戶端進(jìn)行TCP通信的流程如下：

1.建立與服務(wù)端的鏈接
2.進(jìn)行數(shù)據(jù)收發(fā)
3.關(guān)閉鏈接

使用Go語(yǔ)言的net包實(shí)現(xiàn)的TCP客戶端代碼如下：

// tcp/client/main.go

// 客戶端
func main() {
    conn, err := net.Dial("tcp", "127.0.0.1:20000")
    if err != nil {
        fmt.Println("err :", err)
        return
    }
    defer conn.Close() // 關(guān)閉連接
    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)) // 發(fā)送數(shù)據(jù)
        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]))
    }
}

將上面的代碼編譯成client或client.exe可執(zhí)行文件，先啟動(dòng)server端再啟動(dòng)client端，在client端輸入任意內(nèi)容回車(chē)之后就能夠在server端看到client端發(fā)送的數(shù)據(jù)，從而實(shí)現(xiàn)TCP通信。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-701772.html

到了這里，關(guān)于Go語(yǔ)言網(wǎng)絡(luò)編程（socket編程）TCP的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！