Go语言网络编程

共计 2986 个字符，预计需要花费 8 分钟才能阅读完成。

网络编程三要素：

• IP 地址：通过 IP 地址找到指定计算机
• 端口：通过端口找到指定进程
• 协议：定义通信规则，符合协议则可以通信，不符合不能通信

TCP/IP 协议：

• 建立连接：三次握手
• 释放连接：四次挥手

TCP 编程

client\main.go

package main

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

func main() {println(" 客户端启动...")
  conn, err := net.Dial("tcp", "127.0.0.1:8080") // 可简写为:8080，冒号前面默认是本机地址
  if err != nil {println(" 客户端连接失败:", err.Error())
    return
  }
  defer conn.Close()
  println(" 连接成功，conn:", conn.LocalAddr().String())

  // 客户端发送数据
  print(" 发送数据：")
  reader := bufio.NewReader(os.Stdin) // 从标准输入读取数据
  str, err := reader.ReadString('\n')
  if err != nil {println(" 终端输入数据失败:", err.Error())
    return
  }
  // 将 str 发送给服务端
  n, err := conn.Write([]byte(str))
  if err != nil {println(" 客户端发送数据失败:", err.Error())
  }

  fmt.Printf(" 客户端发送数据成功，一共发送了 %d 字节数据，并退出 ", n)
}

server\main.go

package main

import "net"

func process(conn net.Conn) {defer conn.Close()
  buf := make([]byte, 1024)
  n, err := conn.Read(buf) // 读取客户端数据，放入切片
  if err != nil {println(" 读取数据失败:", err.Error())
    return
  }
  println(" 接收到数据:", string(buf[:n]))
}

func main() {println(" 服务端启动...")
  listen, err := net.Listen("tcp", "127.0.0.1:8080")
  if err != nil {println(" 服务端监听失败:", err.Error())
    return
  }
  defer listen.Close()
  println(" 监听成功，listen:", listen.Addr().String())

  // 等待客户端连接
  for {conn, err := listen.Accept()
    if err != nil {println(" 客户端连接失败:", err.Error())
    } else {println(" 客户端连接成功:", conn.RemoteAddr().String())
      go process(conn) // 启动一个协程处理客户端请求
    }
  }
}

UDP 编程

server

package main

import (
  "fmt"
  "net"
)

func main() {listen, err := net.ListenUDP("udp", &net.UDPAddr{IP: net.IPv4zero, Port: 30000})
  if err != nil {fmt.Println("Listen error:", err)
    return
  }
  defer listen.Close()

  for {var data [1024]byte
    n, addr, err := listen.ReadFromUDP(data[:]) // 接收数据
    if err != nil {fmt.Println("ReadFromUDP error:", err)
      continue
    }
    fmt.Println("Received from", addr, "data:", string(data[:n]))

    _, err = listen.WriteToUDP([]byte("Hello, client!"), addr) // 发送数据
    if err != nil {fmt.Println("WriteToUDP error:", err)
      continue
    }
  }
}

client

package main

import (
  "fmt"
  "net"
)

func main() {
  socket, err := net.DialUDP("udp", nil, &net.UDPAddr{IP:   net.IPv4(0, 0, 0, 0),
    Port: 30000,
  })
  if err != nil {fmt.Println("Error connecting to server:", err)
    return
  }
  defer socket.Close()

  sendData := []byte("Hello, world!")
  _, err = socket.Write(sendData)
  if err != nil {fmt.Println("Error sending data to server:", err)
    return
  }

  data := make([]byte, 1024)
  n, _, err := socket.ReadFromUDP(data)
  if err != nil {fmt.Println("Error reading data from server:", err)
    return
  }
  fmt.Println("Received data from server:", string(data[:n]))
}

http 编程

client

package main

import (
  "fmt"
  "io"
  "net/http"
)

func main() {clint := http.Client{}
  resp, err := clint.Get("http://www.baidu.com")
  if err != nil {println("clint.Get error:", err)
    return
  }
  defer resp.Body.Close()

  fmt.Println(resp.Status)                     // 200 OK
  fmt.Println(resp.StatusCode)                 // 200
  fmt.Println(resp.Header.Get("Content-Type")) // application/x-gzip

  println(resp.Request.URL.String()) // http://www.baidu.com

  body, err := io.ReadAll(resp.Body)
  if err != nil {panic(err)
  }
  fmt.Println(string(body))
}

server

func main() {
  // 注册路由
  http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {fmt.Fprintln(w, " 主页 ")
  })
  http.HandleFunc("/name", func(w http.ResponseWriter, r *http.Request) {fmt.Fprintln(w, "name")
  })

  fmt.Println("http server start...")
  if err := http.ListenAndServe(":8080", nil); err != nil {fmt.Println("http start failed, err:", err)
    return
  }
}