UDP服务器监听8080端口接收数据并回显，客户端发送消息并接收响应，使用Go的net包实现，适用于轻量级通信场景。
下面是一个基于UDP协议的简单客户端和服务器程序，使用Golang实现。UDP是无连接的协议，适合轻量级通信场景，比如心跳包、日志传输等。
1. UDP服务器实现
服务器监听指定端口，接收客户端发来的数据，并原样返回响应。
package main
import (
"fmt"
"net"
)
func main() {
// 绑定地址和端口
addr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
if err != nil {
fmt.Println("地址解析错误:", err)
return
}
// 创建UDP连接
conn, err := net.ListenUDP("udp", addr)
if err != nil {
fmt.Println("监听失败:", err)
return
}
defer conn.Close()
fmt.Println("UDP服务器已启动，监听 8080 端口...")
buffer := make([]byte, 1024)
for {
// 读取客户端数据
n, clientAddr, err := conn.ReadFromUDP(buffer)
if err != nil {
fmt.Println("读取数据出错:", err)
continue
}
fmt.Printf("收到来自 %s 的消息: %s\n", clientAddr, string(buffer[:n]))
// 回复客户端
_, err = conn.WriteToUDP([]byte("已收到: "+string(buffer[:n])), clientAddr)
if err != nil {
fmt.Println("发送响应失败:", err)
}
}
}
2. UDP客户端实现
客户端向服务器发送消息，并接收服务器的响应。
package main
import (
"fmt"
"net"
"bufio"
"os"
"strings"
)
func main() {
// 解析服务器地址
addr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
if err != nil {
fmt.Println("地址解析失败:", err)
return
}
// 连接到服务器
conn, err := net.DialUDP("udp", nil, addr)
if err != nil {
fmt.Println("连接失败:", err)
return
}
defer conn.Close()
fmt.Println("已连接到UDP服务器")
// 读取用户输入
input := bufio.NewReader(os.Stdin)
for {
fmt.Print("请输入消息: ")
message, _ := input.ReadString('\n')
message = strings.TrimSpace(message)
if message == "quit" {
break
}
// 发送数据
_, err := conn.Write([]byte(message))
if err != nil {
fmt.Println("发送失败:", err)
continue
}
// 接收响应
buffer := make([]byte, 1024)
n, err := conn.Read(buffer)
if err != nil {
fmt.Println("接收响应失败:", err)
continue
}
fmt.Printf("服务器回复: %s\n", string(buffer[:n]))
}
}
3. 运行说明
启动顺序和操作步骤：
立即学习“go语言免费学习笔记（深入）”；
- 先运行服务器：go run server.go
- 再运行客户端：go run client.go
- 在客户端输入任意消息，服务器会打印并回显
- 输入 quit 可退出客户端
4. 注意事项
UDP不保证可靠性，适用于对实时性要求高、可容忍少量丢包的场景。
- 服务器使用 ListenUDP 监听，客户端使用 DialUDP 连接
- ReadFromUDP 可获取客户端地址，用于回复
- WriteToUDP 需要指定目标地址，而 Write 则用于已连接的UDP连接
- UDP数据报有大小限制（通常64KB以内），避免发送过大数据
