【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
", 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
", 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