Go语言TCP编程核心是net.Dial(客户端连接)和net.Listen(服务端监听),配合net.Conn读写、超时控制与goroutine并发处理实现高效通信。

Go 语言通过 net 包提供了简洁、高效的 TCP 网络编程支持。核心是 net.Dial(发起连接)和 net.Listen(监听连接),两者配合即可完成客户端与服务端的通信。
使用 net.Dial 建立 TCP 客户端连接
net.Dial 是客户端主动连接远程服务器的标准方式,返回一个 net.Conn 接口,可用于读写数据。
基本用法:
conn, err := net.Dial("tcp", "127.0.0.1:8080", nil)
if err != nil {
log.Fatal(err)
}
defer conn.Close()
// 发送数据
conn.Write([]byte("Hello Server\n"))
// 接收响应
buf := make([]byte, 1024)
n, _ := conn.Read(buf)
fmt.Println("收到:", string(buf[:n]))
- 第一个参数是网络类型,TCP 固定为
"tcp"(IPv4)或"tcp4"/"tcp6" - 第二个参数是地址,格式为
"host:port",如"google.com:80"或"192.168.1.100:3000" - 第三个参数可传
*net.Dialer自定义超时、KeepAlive、本地地址等(常用于控制连接行为)
使用 net.Listen 启动 TCP 服务端
net.Listen 在指定地址上启动监听,返回 net.Listener,之后调用 Accept() 阻塞等待新连接。
立即学习“go语言免费学习笔记(深入)”;
简单服务端示例:
ln, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer ln.Close()
fmt.Println("服务器运行在 :8080")
for {
conn, err := ln.Accept()
if err != nil {
log.Println("接受连接失败:", err)
continue
}
// 每个连接开 goroutine 处理,避免阻塞后续连接
go handleConnection(conn)
}
handleConnection 示例:
func handleConnection(conn net.Conn) {
defer conn.Close()
buf := make([]byte, 1024)
n, _ := conn.Read(buf)
fmt.Printf("收到:%s", string(buf[:n]))
conn.Write([]byte("OK\n"))
}
- 监听地址用
":8080"表示监听本机所有 IPv4/IPv6 地址的 8080 端口 - 用
"127.0.0.1:8080"则只监听本地回环,更安全 - 务必用
go handleConnection(conn)启协程处理每个连接,否则串行处理会卡死
常见实用技巧与注意事项
实际开发中,几个关键点容易忽略但影响稳定性:
-
设置连接超时:用
&net.Dialer{Timeout: 5 * time.Second}避免Dial卡死 -
设置读写超时:调用
conn.SetReadDeadline()和conn.SetWriteDeadline()防止 I/O 挂起 -
正确关闭连接:服务端需在处理完后
conn.Close(),客户端同理;多次关闭无害,但漏关会导致资源泄漏 -
错误处理别忽略:
Read返回0, io.EOF表示对端关闭,应退出循环而非报错
完整可运行的小例子(服务端 + 客户端)
把下面两段代码分别保存为 server.go 和 client.go,先运行服务端再运行客户端,就能看到通信效果。
服务端(server.go):
package mainimport ( "fmt" "io" "log" "net" )
func main() { ln, _ := net.Listen("tcp", ":9000") defer ln.Close() fmt.Println("服务启动,监听 :9000")
for { conn, err := ln.Accept() if err != nil { log.Println(err) continue } go func(c net.Conn) { defer c.Close() io.Copy(c, c) // 回显所有收到的数据 }(conn) }}
客户端(client.go):
package mainimport ( "fmt" "io" "log" "net" )
func main() { conn, err := net.Dial("tcp", "127.0.0.1:9000", nil) if err != nil { log.Fatal(err) } defer conn.Close()
conn.Write([]byte("Hi there!\n")) io.Copy(os.Stdout, conn) // 把响应输出到终端}
注意:客户端示例中用了
os.Stdout,需补上import "os"。基本上就这些。Golang 的 TCP 编程模型干净直接,
Dial和Listen是入口,剩下的就是按需读写、超时控制和并发管理。不复杂但容易忽略细节,比如超时和 goroutine 泄漏,上线前务必检查。










