服務(wù)端

package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
    "strings"
)

func process(conn net.Conn){
    var buffer [128]byte

    //這個(gè)循環(huán)的目的是,如果客戶端發(fā)來的數(shù)據(jù)過長(zhǎng),將數(shù)據(jù)切片
    for{
        m,err := conn.Read(buffer[:])
        if err != nil{
            fmt.Println("read data failed")
            break
        }
        fmt.Println("客戶端發(fā)來的數(shù)據(jù)是:",string(buffer[:m]))

        reader := bufio.NewReader(os.Stdin)
        fmt.Print("請(qǐng)輸入服務(wù)端發(fā)送的數(shù)據(jù):")
        sendinfo,err := reader.ReadString('\n')
        if err != nil{
            fmt.Println("讀取服務(wù)端發(fā)送數(shù)據(jù)出錯(cuò)!")
            continue
        }
        sendinfo = strings.TrimSpace(sendinfo)
        if sendinfo == "exit"{
            fmt.Println("退出服務(wù)端")
            return
        }
        conn.Write([]byte(sendinfo))
    }
}

func main(){
    listener,err := net.Listen("tcp","127.0.0.1:9100")
    if err != nil{
        fmt.Println("start server 9100 failed")
        return
    }
    fmt.Println("start server 9100 success")

    for {
        conn,err := listener.Accept()
        if err != nil{
            fmt.Println("accept server fail")
            return
        }
        fmt.Println("accept server success")    //客戶端連接成功打印此日志
        go process(conn)
    }
}

客戶端

package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
    "strings"
)

func main(){
    conn,err := net.Dial("tcp","127.0.0.1:9100")
    if err != nil{
        fmt.Println("connect server 9100 fail")
        return
    }
    fmt.Println("connect server 9100 success")

    reader := bufio.NewReader(os.Stdin)
    for{
        fmt.Print("請(qǐng)輸入:")
        msg,_:=reader.ReadString('\n')
        msg=strings.TrimSpace(msg)
        if msg == "exit"{
            fmt.Println("exit client")
            return
        }
        conn.Write([]byte(msg))

        var buffer [128]byte
        for{
            n,err := conn.Read(buffer[:])
            if err != nil{
                fmt.Println("客戶端讀取數(shù)據(jù)出錯(cuò)")
                break
            }
            fmt.Println("客戶端讀取數(shù)據(jù)是:",string(buffer[:n]))
            break
        }

    }
}