GO语言学习 - 创建TCP监听

package main

import (
    "fmt"
    "io"
    _ "io"
    "net" //做网络socket开发时，net包含有我们需要的所有方法和函数
    "os"
)

func process(conn net.Conn) {
    // 循环接收客户端发送的数据
    defer conn.Close() //关闭conn

    for {
        //创建一个新的切片
        buf := make([]byte, 1024)
        //conn.Read(buf)
        // 1.等待客户端通过conn发送信息
        // 2.如果客户端没有write[发送]，那么协程就阻塞
        // fmt.Printf("服务器在等待客户端%s发送信息\n", conn.RemoteAddr().String())
        n, err := conn.Read(buf) //从conn读取
        if err != nil {
            fmt.Printf("客户端退出 err = %v\n", err)
            return
        }
        // 3.显示客户端发送的内容到服务器的终端
        fmt.Print(string(buf[:n]))
    }
}

func main() {
    file, err := os.Open("conf.txt")
    if err != nil {
        panic(err.Error())
    }
    defer file.Close()
    bytes, err := io.ReadAll(file)
    if err != nil {
        panic(err.Error())
    }

    address := string(bytes)
    fmt.Println("服务端开始监听.." + address)
    listen, err := net.Listen("tcp", address)
    if err != nil {
        fmt.Println("listen err = ", err)
        return
    }
    defer listen.Close()

    for {
        fmt.Println("等待客户端来连接..")
        conn, err := listen.Accept()
        if err != nil {
            fmt.Println("Accept() err = ", err)
        } else {
            fmt.Printf("Accept() suc con = %v 客户端ip = %v\n", conn, conn.RemoteAddr().String())
        }
        go process(conn)
    }
}