如何在Go中使用UDP程式設計？-Golang-PHP中文網

首頁

後端開發

Golang

如何在Go中使用UDP程式設計？

王林

May 11, 2023 pm 05:07 PM

go語言使用方法 udp編程

UDP（用戶資料封包協定）是一種面向無連線的協議，它是傳輸層中非常重要的協定。它可以無需建立連接直接向目標主機傳輸數據，因此被廣泛應用在即時數據傳輸、遊戲等應用中，而且在某些場景下比TCP更適用。

在Go語言中，使用UDP程式設計也非常簡單，本文將介紹如何在Go語言中使用UDP程式設計。

了解UDP協定的資料報

在UDP協定中，資料被封裝變成了一個UDP資料包，也稱為資料報。資料封包中包含了來源連接埠號碼、目的連接埠號碼、長度、校驗和等資訊。

在Go語言中，使用net套件的UDPConn可以實作UDP資料封包的讀寫。

編寫UDP服務端程式

在UDP服務端程式中，首先需要建立一個UDP位址，即使用net套件中的ResolveUDPAddr方法，該方法接收兩個參數，分別是協定類型和伺服器位址。

然後，使用net套件中的ListenUDP方法監聽該位址，該方法會傳回一個UDPConn對象，利用該物件可以接收和傳送UDP資料封包。

接下來是讀取資料報的過程，使用UDPConn物件的ReadFromUDP方法讀取客戶端發送的資料報，該方法會阻塞直到接收到資料報，傳回一個錯誤物件和資料報對象。讀取到數據後，可以取出其中的數據，對數據進行處理，例如計算數據的雜湊值等。然後利用UDPConn物件的WriteToUDP方法向客戶端發送回應資料封包。

以下是一個簡單的UDP服務端程式：

package main

import (
    "fmt"
    "net"
)

func main() {
    ip := net.ParseIP("127.0.0.1")
    addr := &net.UDPAddr{
        IP:   ip,
        Port: 8080,
    }

    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        fmt.Println(err)
        return
    }

    defer conn.Close()
    fmt.Println("UDP server listening on port ", addr.Port)
    for {
        data := make([]byte, 1024)
        n, addr, err := conn.ReadFromUDP(data)
        if err != nil {
            fmt.Println("Error: ", err)
            continue
        }
        fmt.Printf("Received from %s:%d : %s
", addr.IP.String(), addr.Port, string(data[:n]))

        reply := []byte("Hello from UDP server")
        conn.WriteToUDP(reply, addr)
    }
}

登入後複製

寫UDP客戶端程式

在UDP客戶端程式中，首先需要建立一個UDP位址，即使用net套件中的ResolveUDPAddr方法，該方法接收兩個參數，分別是協定類型和伺服器位址。

然後，使用DialUDP方法連接到伺服器位址，該方法會傳回一個UDPConn對象，並利用該對象可以向伺服器傳送UDP資料封包。

接下來便是向服務端發送資料報，使用UDPConn物件的Write方法向服務端發送資料報，該方法會阻塞直到發送完資料報。

然後，使用UDPConn物件的ReadFromUDP方法讀取服務端的回應資料報，該方法會阻塞直到接收到資料報，傳回一個錯誤物件和資料報物件。讀取到資料後，可以取出其中的資料。

以下是一個簡單的UDP客戶端程式：

package main

import (
    "fmt"
    "net"
)

func main() {
    ip := net.ParseIP("127.0.0.1")
    addr := &net.UDPAddr{
        IP:   ip,
        Port: 8080,
    }

    conn, err := net.DialUDP("udp", nil, addr)
    if err != nil {
        fmt.Println(err)
        return
    }

    defer conn.Close()
    fmt.Printf("UDP client connected to %s:%d
", addr.IP.String(), addr.Port)

    message := []byte("Hello from UDP client")
    _, err = conn.Write(message)
    if err != nil {
        fmt.Println(err)
        return
    }

    buffer := make([]byte, 1024)
    n, _, err := conn.ReadFromUDP(buffer)
    if err != nil {
        fmt.Println(err)
        return
    }

    fmt.Printf("Response from server: %s
", string(buffer[:n]))
}

登入後複製