在网络编程中，TCP 是最常见的传输协议之一。Go 提供了 net 包，可以方便地实现 TCP 服务器与客户端通信。本篇将以实战形式演示如何用 Go 创建一个 TCP 服务器，并让多个客户端与之通信。

一、实战背景

相比 HTTP 请求响应，TCP 通信更底层、更灵活，适合用在：

• 游戏服务器
• 实时聊天程序
• 长连接服务
• 数据同步服务

本案例将实现一个简单的 TCP 聊天服务器：

• 支持多个客户端连接
• 客户端发送内容，服务器打印并回应
• 演示并发连接处理

二、实战目标

构建一个简单的 TCP 网络程序，包含两个组件：

1. TCP服务器

   • 启动监听指定端口
   • 接收多个客户端连接
   • 每条连接独立处理，读取数据并回复

2. TCP客户端

   • 连接到服务器
   • 从终端输入消息并发送
   • 接收服务器返回的响应

三、完整代码实现

1. TCP服务器代码（server.go）

package mainimport ("bufio""fmt""net""strings"
)func handleConnection(conn net.Conn) {defer conn.Close()addr := conn.RemoteAddr().String()fmt.Println("客户端连接:", addr)reader := bufio.NewReader(conn)for {data, err := reader.ReadString('\n')if err != nil {fmt.Println("客户端断开:", addr)return}msg := strings.TrimSpace(data)fmt.Printf("收到[%s]: %s\n", addr, msg)// 回复消息response := fmt.Sprintf("服务端收到: %s\n", msg)conn.Write([]byte(response))}
}func main() {listener, err := net.Listen("tcp", ":8888")if err != nil {fmt.Println("启动失败:", err)return}defer listener.Close()fmt.Println("TCP服务器已启动，监听端口 8888...")for {conn, err := listener.Accept()if err != nil {fmt.Println("连接失败:", err)continue}go handleConnection(conn)}
}

2. TCP客户端代码（client.go）

package mainimport ("bufio""fmt""net""os""strings"
)func main() {conn, err := net.Dial("tcp", "127.0.0.1:8888")if err != nil {fmt.Println("连接服务器失败:", err)return}defer conn.Close()fmt.Println("已连接到服务器。请输入消息，输入 exit 退出：")reader := bufio.NewReader(os.Stdin)for {fmt.Print(">> ")input, _ := reader.ReadString('\n')input = strings.TrimSpace(input)if input == "exit" {fmt.Println("断开连接")return}// 发送消息conn.Write([]byte(input + "\n"))// 接收服务器响应response, _ := bufio.NewReader(conn).ReadString('\n')fmt.Println("服务器响应:", strings.TrimSpace(response))}
}

四、运行方式

启动服务器

go run server.go

输出示例：

TCP服务器已启动，监听端口 8888...

启动客户端（多个终端可同时运行）

go run client.go

输入消息：

>> hello
服务器响应: 服务端收到: hello

服务器端输出：

客户端连接: 127.0.0.1:53458
收到[127.0.0.1:53458]: hello

五、关键技术点解析

1. net.Listen("tcp", ":8888")

用于监听本地 8888 端口，协议为 TCP。支持 IPv4、IPv6。

2. listener.Accept()

阻塞方法，等待客户端连接。每当有新连接，就返回一个 net.Conn。

3. 并发处理连接

使用 go handleConnection(conn)，每个客户端独立处理，避免阻塞。

4. bufio.NewReader(conn).ReadString('\n')

按行读取客户端发送内容。注意客户端必须发送换行（\n）结束，否则会阻塞。

5. 客户端 net.Dial

客户端使用 net.Dial("tcp", addr) 建立连接。注意服务端地址和端口应正确。

六、可扩展方向

七、小结

通过本案例你掌握了：

✅ 如何编写基本的 TCP 服务端和客户端 ✅ 使用 Goroutine 实现并发连接处理 ✅ 使用 bufio.Reader/Writer 实现按行读写 ✅ 终端交互式发送/接收消息

这是构建分布式系统、即时通讯、远程控制服务的基础能力。