UDP编程示例

1、UDP协议

UDP协议（User Datagram Protocol）中文名称是用户数据报协议，是OSI（Open System Interconnection，开放式系统互联）参考模型中一种无连接的传输层协议，不需要建立连接就能直接进行数据发送和接收，属于不可靠的、没有时序的通信，但是UDP协议的实时性比较好，通常用于视频直播相关领域。

2、UDP服务端

使用Go语言的net包实现的UDP服务端代码如下：

func main(){
    // 开启 udp 监听
    listen,err := net.ListenUDP("udp", &net.UDPAddr{
        IP: net.IPv4(0,0,0,0),
        Port: 6666,
    })
    if err != nil {
        fmt.Println("listen failed, err:", err)
        return
    }
    defer listen.Close()

    for{
        var data[1024]byte
        // 接收数据
        n,addr,err := listen.ReadFromUDP(data[:])
        if err != nil {
            fmt.Println("read udp failed, err:", err)
            continue
        }
        str := string(data[:n])
        fmt.Printf("data:%v addr:%v count:%v\n", str, addr, n)
        str = fmt.Sprintf("接收client数据：%v", str)

        // 发送数据
        _, err = listen.WriteToUDP([]byte(str), addr)
        if err != nil {
            fmt.Println("write to udp failed, err:", err)
            continue
        }
    }
}

3、UDP客户端

使用Go语言的net包实现的UDP客户端代码如下：

func main(){
    // 连接 udp 服务端
    socket,err := net.DialUDP("udp", nil, &net.UDPAddr{
        IP: net.IPv4(0,0,0,0),
        Port: 6666,
    })
    if err != nil {
        fmt.Println("连接服务端失败，err:", err)
        return
    }
    defer socket.Close()

    // 发送数据
    sendData := []byte("Hello server")
    _, err = socket.Write(sendData)
    if err != nil {
        fmt.Println("发送数据失败，err:", err)
        return
    }

    // 接收数据
    data := make([]byte, 4096)
    n, remoteAddr, err := socket.ReadFromUDP(data)
    if err != nil {
        fmt.Println("接收数据失败，err:", err)
        return
    }

    fmt.Printf("recv:%v addr:%v count:%v\n", string(data[:n]), remoteAddr, n)
}

也可以使用如下方式多次发送：

func main(){
    // 连接 udp 服务端
    socket,err := net.DialUDP("udp", nil, &net.UDPAddr{
        IP: net.IPv4(0,0,0,0),
        Port: 6666,
    })
    if err != nil {
        fmt.Println("连接服务端失败，err:", err)
        return
    }
    defer socket.Close()

    inputReader := bufio.NewReader(os.Stdin)
    for{
        // 读取用户输入
        input, _ := inputReader.ReadString('\n')
        inputInfo := strings.Trim(input, "\r\n")
        // 如果输入exit就退出
        if strings.ToLower(inputInfo) == "exit" {
            return
        }

        // 发送数据
        _, err = socket.Write([]byte(inputInfo))
        if err != nil {
            fmt.Println("发送数据失败，err:", err)
            return
        }

        // 接收数据
        data := make([]byte, 4096)
        n, remoteAddr, err := socket.ReadFromUDP(data)
        if err != nil {
            fmt.Println("接收数据失败，err:", err)
            return
        }
        fmt.Printf("recv:%v addr:%v count:%v\n", string(data[:n]), remoteAddr, n)
    }
}