Go语言如何实现TCP服务端_TCP网络通信流程说明

15次阅读

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

Go语言如何实现TCP服务端_TCP网络通信流程说明

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 :8080netstat -tuln | grep 8080

conn.Readconn.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 main 

import ( "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.WithTimeoutsync.WaitGroup控制生命周期。最容易被忽略的是bufio.Reader的缓冲区大小默认只有4096字节,遇到超长单行会触发ErrBufferFull,需要提前预估协议最大消息长度并设置bufio.NewReaderSize

text=ZqhQzanResources