Go TCP服务端最简流程是net.Listen监听+Accept循环,每个连接需启goroutine处理,否则阻塞;地址格式须含端口如":8080";Read/Write需循环处理,推荐bufio封装;关闭时需WaitGroup协调并发连接并显式close conn。

Go语言用net.Listen启动TCP服务端最简流程
Go实现TCP服务端的核心就是net.Listen + listener.Accept循环,不需要额外框架或中间件。监听成功后,每个客户端连接会返回一个net.Conn,后续读写都基于它。
常见错误是忘记启动goroutine处理每个连接,导致服务端阻塞在第二个Accept调用上——所有新连接排队等待,实际只服务了一个客户端。
-
net.Listen("tcp", ":8080")中地址格式必须含端口,":8080"合法,"localhost:8080"也行,但"8080"会报lookup 8080: no such host - 监听地址若为
"127.0.0.1:8080",则外部机器无法连接;生产环境通常用":8080"(即0.0.0.0:8080) - 端口被占用时,
Listen返回*net.OpError,错误信息含"bind: address already in use",需检查lsof -i :8080或netstat -tuln | grep 8080
用conn.Read和conn.Write收发数据要注意什么
TCP是流式协议,Read不保证一次读完所有发送的数据,Write也不保证一次发完全部字节。必须循环处理,或借助bufio封装。
直接用conn.Read([]byte)时,返回的n是本次实际读到的字节数,可能远小于缓冲区长度;err == io.EOF表示对端关闭连接,不是错误。
立即学习“go语言免费学习笔记(深入)”;
- 不要假设
Read会填满整个切片:即使客户端发了1024字节,Read可能只返回200,下一次再返回剩余部分 -
Write返回的n可能小于待写长度,需检查并重试未写完的部分,否则数据截断 - 若需按行或按固定包头解析,建议用
bufio.NewReader(conn)配合ReadString('\n')或ReadBytes('\n'),避免手动拼接
如何安全关闭TCP服务端并释放资源
Go没有内置“优雅关闭”API,需自行协调:停止接受新连接、等待已有连接处理完毕、最后关闭listener。关键点在于用sync.WaitGroup跟踪活跃连接数,并用context控制超时。
直接调用listener.Close()只会让后续Accept返回错误,已建立的Conn不受影响,也不会自动关闭。
- 在
Accept循环中检测listener.Close()后的错误,如err == net.ErrClosed,就跳出循环 - 每个处理连接的goroutine应在开始时
wg.Add(1),退出前wg.Done() - 关闭前调用
wg.Wait(),但要设超时(比如5秒),防止某个连接卡死导致服务无法退出 - 每个
Conn也应显式调用conn.Close(),否则文件描述符泄漏
一个可运行的最小TCP回声服务端示例
以下代码包含监听、并发处理、基础错误判断和连接关闭逻辑,去掉注释即可编译运行:
package mainimport ( "bufio" "fmt" "log" "net" "time" )
func handleConn(conn net.Conn) { defer conn.Close() reader := bufio.NewReader(conn) for { msg, err := reader.ReadString('\n') if err != nil { if err != bufio.ErrBufferFull { log.Printf("read error from %v: %v", conn.RemoteAddr(), err) } return } fmt.Fprintf(conn, "echo: %s", msg) } }
func main() { listener, err := net.Listen("tcp", ":8080") if err != nil { log.Fatal(err) } defer listener.Close() log.Println("Server started on :8080")
for { conn, err := listener.Accept() if err != nil { if netErr, ok := err.(net.Error); ok && netErr.Temporary() { log.Printf("temporary accept error: %v", err) time.Sleep(100 * time.Millisecond) continue } log.Printf("accept error: %v", err) break } go handleConn(conn) }}
这个例子没做优雅关闭,适合学习流程;真实项目中需加入
context.WithTimeout和sync.WaitGroup控制生命周期。最容易被忽略的是bufio.Reader的缓冲区大小默认只有4096字节,遇到超长单行会触发ErrBufferFull,需要提前预估协议最大消息长度并设置bufio.NewReaderSize。










