Go语言通过net包实现TCP/UDP通信，支持并发处理、资源释放、错误处理与超时控制，适用于高性能网络服务开发。
Go语言（Golang）通过标准库中的net包提供了强大且简洁的Socket编程支持。它封装了底层网络通信细节，使开发者能轻松实现TCP、UDP等协议的网络通信。
使用net包实现TCP Socket通信
TCP是一种面向连接的协议，适合需要可靠传输的场景。Golang中通过net.Listen监听端口，用listener.Accept()接收客户端连接。
以下是一个简单的TCP服务器示例：
package main
import (
"bufio"
"fmt"
"net"
")
func main() {
// 监听本地8080端口
listener, err := net.Listen("tcp", ":8080")
if err != nil {
fmt.Println("启动失败:", err)
return
}
defer listener.Close()
fmt.Println("服务器已启动，等待连接...")
for {
// 等待客户端连接
conn, err := listener.Accept()
if err != nil {
fmt.Println("连接出错:", err)
continue
}
// 启动协程处理每个连接
go handleConnection(conn)
}
}
func handleConnection(conn net.Conn) {
defer conn.Close()
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
message := scanner.Text()
fmt.Printf("收到消息: %s\n", message)
// 回显消息
conn.Write([]byte("echo: " + message + "\n"))
}
}
对应的TCP客户端代码：
立即学习“go语言免费学习笔记（深入）”；
package main
import (
"bufio"
"fmt"
"net"
"os"
")
func main() {
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
fmt.Println("连接失败:", err)
return
}
defer conn.Close()
go func() {
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
fmt.Println(scanner.Text())
}
}()
// 从标准输入读取用户输入
input := bufio.NewScanner(os.Stdin)
for input.Scan() {
msg := input.Text()
conn.Write([]byte(msg + "\n"))
}
}
UDP Socket编程
UDP是无连接协议，适用于对实时性要求高、可容忍部分丢包的场景。Golang中使用net.ListenPacket创建UDP服务。
UDP服务器示例：
package main
import (
"fmt"
"net"
")
func main() {
addr, _ := net.ResolveUDPAddr("udp", ":8080")
conn, _ := net.ListenUDP("udp", addr)
defer conn.Close()
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]))
// 回复客户端
conn.WriteToUDP([]byte("收到:"+string(buffer[:n])), clientAddr)
}
}
UDP客户端：
package main
import (
"fmt"
"net"
")
func main() {
addr, _ := net.ResolveUDPAddr("udp", "localhost:8080")
conn, _ := net.DialUDP("udp", nil, addr)
defer conn.Close()
message := "Hello UDP Server"
conn.Write([]byte(message))
response := make([]byte, 1024)
n, _ := conn.Read(response)
fmt.Println("响应:", string(response[:n]))
}
关键要点与最佳实践
在Golang中进行Socket编程时，有几个核心点需要注意：
- 并发处理：每个客户端连接应放在独立的goroutine中处理，充分发挥Go的并发优势
-
资源释放：及时调用
Close()释放连接资源，建议配合defer使用 -
错误处理：网络操作容易出错，需对返回的
err值做判断 - 数据边界：TCP是流式协议，注意处理粘包问题，可通过加长度头或使用分隔符解决
- 超时控制：生产环境建议设置读写超时，避免连接长时间占用
