go语言TCP编程入门

package main
import (
    "fmt"
    "io"
    "net"
)
func process(conn net.Conn) {
    defer conn.Close()
    for {
        buf := make([]byte, 1024)
        //等待客户端通过conn发送信息
        //如果客户端没有Write[发送]，那么协程就阻塞在这里
        //fmt.Printf("服务器在等待客户端%s, 发送信息\n", conn.RemoteAddr().String())
        n, err := conn.Read(buf)
        if err == io.EOF {
            fmt.Println("客户端退出")
            return
        }
        if err != nil {
            fmt.Println("服务器Read err", err)
            return
        }
        //显示客户端发送的内容到服务器的终端
        fmt.Println(string(buf[:n]))
    }
}

func Server() {
    //Listen函数创建的服务器
    //头层皮：网络协议
    //127.0.0.1:8888    8888本机ip和端口
    l, err := net.Listen("tcp", "127.0.0.1:8888")
    if err != nil {
        fmt.Println("error:", err)
        return
    }
    defer l.Close()
    //循环等待客户端访问
    for {
        conn, err := l.Accept()
        if err != nil {
            fmt.Println("accept error", err)
        }
        fmt.Printf("访问客户端信息：con = %v 客户端ip=%v\n", conn, conn.RemoteAddr())
        go process(conn)
    }
}
func main() {
    Server()
}

import (
    "bufio"
    "fmt"
    "net"
    "os"
    "strings"
)
func main() {
    con, err := net.Dial("tcp", "0.0.0.0:8888")
    if err != nil {
        fmt.Println("connect err", err)
        return
    }
    fmt.Println("con 成功=", con)

    for {
        //客户端可以发送单行数据，然后就退出
        reader := bufio.NewReader(os.Stdin) //os.Stdin代表标准输入[终端]

        //从终端读取一行用户输入，并准备发送给服务端
        line, err := reader.ReadString('\n')
        if err != nil {
            fmt.Println("readstring err = ", err)
        }
        line = strings.Trim(line, " \r\n")
        if line == "exit" {
            break
        }
        //再将line发送给服务器
        n, err := con.Write([]byte(line))
        if err != nil {
            fmt.Println("con.write err = ", err)
        }
        fmt.Printf("发送了%d字节到服务器\n", n)
    }
    fmt.Println("程序退出")
}