UDP 是用户数据报协议，是一种无连接传输协议，不需要建立连接就可以直接发送和接收数据，属于不可靠的，没有时序的通信，UDP 实时性好，适合直播环境。

1. 服务端配置

示例

package main

import (
    "fmt"
    "net"
)

/* UDP 服务端 */

func main() {
          
   
    // 1. 监听
    listener,err := net.ListenUDP("udp",&net.UDPAddr {
          
   
        IP:		net.ParseIP("127.0.0.1"),
        Port:	30000,
    })
    if err != nil {
          
   
        fmt.Println("启动 server 失败,err:",err)
        return
    }
    // 退出时关闭资源
    defer listener.Close()
    // 循环收发数据
    for {
          
   
        var buf [1024]byte
        // 因为是无连接，所以需要知道对方地址 Addr
        n,addr,err := listener.ReadFromUDP(buf[:])
        if err != nil {
          
   
            fmt.Println("接收消息失败,err:",err)
            return
        }
        fmt.Printf("接收到来自 %v 的消息:%v
",addr,string(buf[:n]))
        // 回复消息
        n,err = listener.WriteToUDP([]byte("hi"),addr)
        if err != nil {
          
   
            fmt.Println("回复失败,err:",err)
            return
        }
    }
}

2. 客户端配置

示例

package main

import (
	"fmt"
	"net"
)

/* UDP 客户端 */

func main() {
          
   
	// 连接 UDP 服务器
	conn,err := net.Dial("udp","127.0.0.1:30000")
	if err != nil {
          
   
		fmt.Println("连接失败,err:",err)
		return
	}
	defer conn.Close()
	// 发送消息
	n,err := conn.Write([]byte("hello"))
	if err != nil {
          
   
		fmt.Println("发送失败,err:",err)
		return
	}
	// 接收消息
	var buf [1024]byte
	n,err = conn.Read(buf[:])	// n 为返回的有效字节个数
	if err != nil {
          
   
		fmt.Println("接收消息失败,err:",err)
		return
	}
	fmt.Println("收到回复:",string(buf[:n]))
}

实现效果

3. 实现双向聊天

修改客户端

package main

import (
	"bufio"
	"fmt"
	"net"
	"os"
)

/* UDP 客户端 */

func main() {
          
   
	for {
          
   
		// 连接 UDP 服务器
		conn, err := net.Dial("udp", "127.0.0.1:30000")
		if err != nil {
          
   
			fmt.Println("连接失败,err:", err)
			return
		}
		defer conn.Close()
		defer conn.Close()

		reader := bufio.NewReader(os.Stdin)
		input, err := reader.ReadString(
)
		if err != nil {
          
   
			fmt.Println("获取信息失败,err:", err)
			return
		}
		_, err = conn.Write([]byte(input))
		if err != nil {
          
   
			fmt.Println("发送消息失败,err:", err)
			return
		}
	}
}

实现效果

4. 优化多客户端实现通讯

修改服务端

package main

import (
	"fmt"
	"net"
)

/* UDP 服务端 */

func process(listener net.UDPConn) {
          
   
	defer listener.Close()
	// 循环收发数据
	for {
          
   
		var buf [1024]byte
		// 因为是无连接，所以需要知道对方地址 Addr
		n, addr, err := listener.ReadFromUDP(buf[:])
		if err != nil {
          
   
			fmt.Println("接收消息失败,err:", err)
			return
		}
		fmt.Printf("接收到来自 %v 的消息:%v
", addr, string(buf[:n]))
		// 回复消息
		n, err = listener.WriteToUDP([]byte("hi"), addr)
		if err != nil {
          
   
			fmt.Println("回复失败,err:", err)
			return
		}
	}
}

func main() {
          
   
	// 1. 监听
	listener,err := net.ListenUDP("udp",&net.UDPAddr {
          
   
		IP:		net.ParseIP("127.0.0.1"),
		Port:	30000,
	})
	if err != nil {
          
   
		fmt.Println("启动 server 失败,err:",err)
		return
	}
	process(*listener)
}

开两个客户端看看效果

PS：可以将服务端和客户端打成 exe 文件，发给不同的人，修改 IP，实现群聊效果。go 语言不同于 java，python …，golang 可以直接打成 exe 文件，不需要依赖环境直接运行，但同时也有安全性问题。