服务端

服务端的处理流程

• 监听端口8888
• 接收客户端的tcp连接
• 创建gorountine，处理该链接的请求（通常客户端会通过链接发送请求包）

客户端

客户端的处理流程

• 建立与服务端的链接
• 发送请求数据 (终端)，接收服务器端返回的结果数据
• 关闭链接

简单的程序示意图

服务端与客户端的关系

服务端功能

• 编写一个服务端程序，在8888端口监听
• 可以和多个客户端创建链接
• 链接成功后，客户端可以发送数据，服务端接收数据，并且显示在终端上
• 先可以使用talnet来测试，然后编写客户端程序来测试

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()
}

客户端功能

• 编写一个客户端程序，能链接到服务端的8888窗口
• 客户端可以发送单行数据，然后就退出
• 能通过终端输入数据（ 输入一行发送一行），并发送给服务器端
• 在终端输入exit，表示退出程序

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("程序退出")
}