如何在Go中使用UDP编程？-Golang-PHP中文网

如何在Go中使用UDP编程？

王林

发布： 2023-05-11 17:07:36

原创

2352人浏览过

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服务端程序：

豆包AI编程

豆包推出的AI编程助手

483

查看详情

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]))
}

登录后复制