【go语言学习】网络编程之UDP

一、UDP协议

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

二、UDP服务端

server端实现步骤：

1、net.ResolveUDPAddr() 设置端口

func ResolveUDPAddr(network, address string) (*UDPAddr, error) {}

2、net.ListenUDP() 监听UDP服务

func ListenUDP(network string, laddr *UDPAddr) (*UDPConn, error) {}

3、net.UDPConn.ReadFromUDP() 读数据

func (c *UDPConn) ReadFromUDP(b []byte) (int, *UDPAddr, error) {}

4、net.UDPConn.WriteToUDP() 写数据

func (c *UDPConn) WriteToUDP(b []byte, addr *UDPAddr) (int, error) {}

示例代码：

package main

import (
    "fmt"
    "net"
)

func main() {
    // 1.获取udpAddr
    udpAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:3000")
    if err != nil {
        fmt.Println("net resolveUDPAddr failed, err:", err)
        return
    }
    // 2.监听端口
    udpconn, err := net.ListenUDP("udp", udpAddr)
    if err != nil {
        fmt.Println("net dialUDP failed, err:", err)
        return
    }
    // 打印一句提示信息
    fmt.Println("DUP服务监听端口：127.0.0.1:3000")
    //3.处理收发数据
    for {
        sHandler(udpconn)
    }
}

// 读写数据
func sHandler(conn *net.UDPConn) {
    // 1.读取数据
    buf := make([]byte, 1024)
    n, addr, err := conn.ReadFromUDP(buf)
    if err != nil {
        fmt.Println("conn readFromUDP failed, err:", err)
    }
    fmt.Printf("data:%v, addr:%v, count:%v\n", string(buf[:n]), addr, n)
    // 2.发送数据
    _, err = conn.WriteToUDP(buf[:n], addr)
    if err != nil {
        fmt.Println("conn writeToUDP failed, err:", err)
    }
}

三、UDP客户端

Client端实现步骤：

1、net.ResolveUDPAddr() 设置端口

func ResolveUDPAddr(network, address string) (*UDPAddr, error) {}

2、net.DialUDP() 建立连接

func DialUDP(network string, laddr, raddr *UDPAddr) (*UDPConn, error) {}

3、net.UDPConn.Write() 写数据

func (c *conn) Write(b []byte) (int, error) {}

4、net.UDPConn.ReadFromUDP() 读数据

func (c *UDPConn) ReadFromUDP(b []byte) (int, *UDPAddr, error) {}

示例代码：

package main

import (
    "fmt"
    "net"
)

func main() {
    // 1.获取udpAddr
    udpAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:3000")
    if err != nil {
        fmt.Println("net resolveUDPAddr failed, err:", err)
        return
    }
    // 2.连接，获得udpconn
    udpconn, err := net.DialUDP("udp", nil, udpAddr)
    if err != nil {
        fmt.Println("net dialUDP failed, err:", err)
    }
    // 3.处理数据收发
    cHandler(udpconn)
}

// 读写数据
func cHandler(conn *net.UDPConn) {
    // 1.写入数据
    _, err := conn.Write([]byte("client"))
    if err != nil {
        fmt.Println("conn write failed, err:", err)
        return
    }
    // 2.读取数据
    buf := make([]byte, 1024)
    n, addr, err := conn.ReadFromUDP(buf)
    if err != nil {
        fmt.Println("conn read failed, err:", err)
        return
    }
    fmt.Printf("来自服务端的信息:%v, addr:%v, count:%v\n", string(buf[:n]), addr, n)

先后启动server和client，server端输出：

DUP服务监听端口：127.0.0.1:3000
来自客户端的消息:client, addr:127.0.0.1:52878, count:6

client端输出：

来自服务端的信息:client, addr:127.0.0.1:3000, count:6

最后编辑于：2020.10.10 19:03:48