go语言TCP编程入门

时间:2022-07-24
本文章向大家介绍go语言TCP编程入门,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。

服务端

服务端的处理流程

  • 监听端口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=%vn", 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, " rn")
        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("程序退出")
}