Go语言通过net包实现TCP通信,首先创建服务器监听端口并用goroutine处理连接,客户端使用Dial建立连接发送数据。为解决TCP粘包问题,推荐消息头携带长度信息的方式。同时需设置读写超时防止资源泄漏,并加入异常重连机制提升稳定性。示例展示了基础通信流程与关键处理技巧。

在Go语言中实现TCP客户端与服务器通信非常直观,得益于标准库net包的强大支持。通过简单的API调用即可建立稳定的长连接,适用于即时通讯、数据同步等场景。本文将带你一步步实现一个基础但完整的TCP通信示例,并介绍常见问题的处理方式。
使用net.Listen函数监听指定地址和端口,等待客户端连接。每个新连接通过goroutine独立处理,保证并发性能。
示例代码:
func startServer() {
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal("监听失败:", err)
}
defer listener.Close()
log.Println("服务器启动,监听 :8080")
for {
conn, err := listener.Accept()
if err != nil {
log.Println("接受连接错误:", err)
continue
}
go handleClient(conn)
}
}
func handleClient(conn net.Conn) {
defer conn.Close()
buffer := make([]byte, 1024)
for {
n, err := conn.Read(buffer)
if err != nil {
log.Println("读取数据出错:", err)
return
}
message := string(buffer[:n])
log.Printf("收到: %s", message)
// 回显消息
conn.Write([]byte("echo: " + message))
}
}
客户端使用net.Dial连接服务器,发送请求并接收响应。同样可以持续读取服务端返回的数据。
立即学习“go语言免费学习笔记(深入)”;
示例代码:
func startClient() {
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
log.Fatal("连接失败:", err)
}
defer conn.Close()
// 发送消息
conn.Write([]byte("Hello, Server!"))
// 接收回响
buffer := make([]byte, 1024)
n, err := conn.Read(buffer)
if err != nil {
log.Println("接收数据失败:", err)
return
}
log.Printf("服务器回复: %s", string(buffer[:n]))
}
TCP是流式协议,多次发送的数据可能被合并或拆分,导致“粘包”问题。解决方法包括:
推荐使用第三种方式,灵活性高且适合复杂场景。例如,前4字节为uint32表示body长度,之后才是实际内容。
生产环境中必须考虑网络不稳定情况。可设置读写超时防止goroutine泄漏:
conn.SetReadDeadline(time.Now().Add(10 * time.Second))
当超时或连接中断时,Read会返回error,需及时退出循环并关闭连接。同时建议加入重连机制提升客户端健壮性。
基本上就这些。Golang的TCP编程简洁高效,配合goroutine轻松应对高并发。只要注意数据边界处理和连接管理,就能构建稳定可靠的网络服务。
以上就是Golang如何处理TCP客户端与服务器通信_Golang TCP通信实践的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号