Golang网络编程与Socket应用详解

package main

import (
    "bufio"
    "fmt"
    "net"
")

func handleConn(conn net.Conn) {
    defer conn.Close()
    reader := bufio.NewReader(conn)
    for {
        msg, err := reader.ReadString('\n')
        if err != nil {
            break
        }
        fmt.Print("收到:", msg)
        conn.Write([]byte("echo: " + msg))
    }
}

func main() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        panic(err)
    }
    defer listener.Close()
    fmt.Println("服务器启动在 :8080")

    for {
        conn, err := listener.Accept()
        if err != nil {
            continue
        }
        go handleConn(conn) // 每个连接启用一个goroutine
    }
}

package main

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

func main() {
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        panic(err)
    }
    defer conn.Close()

    go func() {
        scanner := bufio.NewScanner(os.Stdin)
        for scanner.Scan() {
            msg := scanner.Text() + "\n"
            conn.Write([]byte(msg))
        }
    }()

    reader := bufio.NewReader(conn)
    for {
        msg, err := reader.ReadString('\n')
        if err != nil {
            break
        }
        fmt.Println(msg)
    }
}

conn, err := net.ListenUDP("udp", &net.UDPAddr{Port: 8080})
if err != nil {
    panic(err)
}
defer conn.Close()

buf := make([]byte, 1024)
for {
    n, clientAddr, err := conn.ReadFromUDP(buf)
    if err != nil {
        continue
    }
    fmt.Printf("来自 %s: %s", clientAddr, string(buf[:n]))
    conn.WriteToUDP([]byte("pong"), clientAddr)
}