golang TCP

service.go

package main

import (
    "net"
    "fmt"
)

// TCP service

func main() {
    // 1.監(jiān)聽(tīng)本地端口
    linser, err := net.Listen("tcp", "127.0.0.1:27666")
    if err != nil{
        fmt.Println("Linsten 127.0.0.1:27666 faild, error of:", err)
        return
    }

    // 2.等待客戶端連接
    client_conn, err := linser.Accept()
    if err != nil {
        fmt.Println("conn error of:", err)
        return
    }

    // 3.接收客戶端信息
    var msg[128]byte
    n, err := client_conn.Read(msg[:])
    if err != nil {
        fmt.Println("Read error of:", err)
        return
    }
    fmt.Println("The client msg of:", string(msg[:n]))

    // 4.給客戶端回應(yīng)消息
    _, err =client_conn.Write([]byte("666!"))
    if err != nil{
        fmt.Println("Write err of:", err)
        return
    }

    client_conn.Close()
    linser.Close()
}

client.go

package main

import (
    "net"
    "fmt"
)

// TCP client

func main() {
    // 1.連接服務(wù)端
    conn_service, err := net.Dial("tcp", "127.0.0.1:27666")
    if err != nil {
        fmt.Println("conned 127.0.0.1:27666 faild of:", err)
        return
    }

    // 2.給服務(wù)端發(fā)生消息
    _, err = conn_service.Write([]byte("Hello World!"))
    if err != nil {
        fmt.Println("Wirte err of: ", err)
        return
    }

    // 3.接收服務(wù)端消息
    var msg [128]byte // 聲明一個(gè)接收信息的變量
    n, err := conn_service.Read(msg[:])
    if err != nil {
        fmt.Println("Read error of:", err)
        return
    }
    fmt.Println("The service msg:",string(msg[:n]))

    // 4.關(guān)閉連接
    conn_service.Close()
}

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

友情鏈接更多精彩內(nèi)容