Go语言通过net包实现TCP通信，先启动服务器监听端口，再运行客户端连接并收发消息。服务器使用net.Listen监听，Accept接收连接，并用goroutine处理每个连接；客户端通过net.Dial连接服务器，发送数据并读取回显。程序以换行符分隔消息，支持多客户端并发，体现Go的高并发优势。
Go 语言的 net 包提供了强大且简洁的 API 来实现 TCP 网络通信。通过它，你可以轻松构建高性能的 TCP 客户端与服务器。下面通过一个完整示例，展示如何使用 net 包实现基本的 TCP 通信。
1. 实现 TCP 服务器
使用 net.Listen 监听指定地址和端口，接受客户端连接，并并发处理每个连接。
package main
import (
"bufio"
"fmt"
"log"
"net"
")
func handleConnection(conn net.Conn) {
defer conn.Close()
fmt.Printf("来自 %s 的连接已建立\n", conn.RemoteAddr().String())
reader := bufio.NewReader(conn)
for {
message, err := reader.ReadString('\n')
if err != nil {
fmt.Printf("连接断开: %s\n", conn.RemoteAddr().String())
break
}
fmt.Printf("收到消息: %s", message)
// 回显消息给客户端
conn.Write([]byte("echo: " + message))
}
}
func main() {
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal("监听失败:", err)
}
defer listener.Close()
fmt.Println("TCP 服务器启动，监听端口 :8080")
for {
conn, err := listener.Accept()
if err != nil {
log.Println("接受连接出错:", err)
continue
}
// 每个连接开启一个 goroutine 处理
go handleConnection(conn)
}
}
2. 实现 TCP 客户端
客户端使用 net.Dial 连接到服务器，发送消息并接收响应。
package main
import (
"bufio"
"fmt"
"log"
"net"
"os"
")
func main() {
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
log.Fatal("连接失败:", err)
}
defer conn.Close()
fmt.Println("已连接到服务器")
go func() {
reader := bufio.NewReader(conn)
for {
msg, err := reader.ReadString('\n')
if err != nil {
return
}
fmt.Print("服务端回显: ", msg)
}
}()
// 从标准输入读取用户输入
inputReader := bufio.NewReader(os.Stdin)
for {
line, _ := inputReader.ReadString('\n')
conn.Write([]byte(line))
}
}
3. 运行与测试
先启动服务器，再运行多个客户端进行测试：
立即学习“go语言免费学习笔记（深入）”；
- 终端 1 执行：go run server.go
- 终端 2 执行：go run client.go
- 在客户端输入任意文本并回车，服务器会打印收到的消息，客户端会收到“echo”回应
支持多个客户端同时连接，每个连接由独立 goroutine 处理，体现 Go 并发优势。
4. 关键点说明
- 协议选择：net.Listen 和 net.Dial 第一个参数为 "tcp"
- 并发模型：Accept 后用 go 启动新协程处理，不阻塞主循环
- 连接关闭：务必调用 conn.Close() 释放资源
- 数据边界：本例以换行符 '\n' 分隔消息，实际应用中可使用固定长度、JSON 或 Protobuf
- 错误处理：网络中断时 Read/Write 会返回错误，需合理退出或重连
