Go语言通过Goroutine和net包实现并发TCP客户端，1. 每个连接使用独立Goroutine可实现长连接并发，发送与接收分离避免阻塞；2. 并发发起多个连接可用于模拟多客户端，适合压力测试；3. 使用Channel可安全传递消息和控制并发，集中管理写操作；4. 通过bufio.Scanner或自定义协议头处理粘包问题，确保数据完整。合理利用Goroutine、Channel和协议解析可高效构建稳定TCP客户端。
在Go语言中实现并发TCP客户端，关键在于利用Goroutine和标准库中的net包。通过为每个连接或每条消息启动独立的Goroutine，可以轻松实现高并发的TCP通信。下面介绍几种常见的并发处理方式。
1. 每个连接使用独立Goroutine
适用于需要维持多个长连接的场景。每个TCP连接在一个独立的Goroutine中运行，互不阻塞。
示例代码：
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
log.Fatal(err)
}
defer conn.Close()
// 发送数据（可在单独Goroutine中）
go func() {
for i := 1; i <= 5; i++ {
msg := fmt.Sprintf("Message %d", i)
conn.Write([]byte(msg + "\n"))
time.Sleep(100 * time.Millisecond)
}
}()
// 接收响应
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
fmt.Println("收到:", scanner.Text())
}
if err := scanner.Err(); err != nil {
fmt.Println("读取错误:", err)
}
这种方式让发送和接收分离，避免因读写阻塞影响并发性能。
2. 并发发起多个TCP连接
当你需要模拟多个客户端同时连接服务器时，可以为每个连接启动一个Goroutine。
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
fmt.Printf("连接失败 %d: %v\n", id, err)
return
}
defer conn.Close()
// 发送请求
conn.Write([]byte(fmt.Sprintf("Client %d\n", id)))
// 读取响应
buf := make([]byte, 512)
n, _ := conn.Read(buf)
fmt.Printf("Client %d 收到: %s", id, string(buf[:n]))
}(i)}
wg.Wait()
这种模式常用于压力测试或分布式任务分发。
3. 使用Channel控制并发与数据传递
通过Channel可以在Goroutine之间安全传递连接状态或消息，避免竞态条件。
例如：创建一个消息通道，由主协程统一发送：
type Message struct { Data string Conn net.Conn }
messages := make(chan Message, 100)
// 发送协程 go func() { for msg := range messages { msg.Conn.Write([]byte(msg.Data + "\n")) } }()
// 使用示例 conn, _ := net.Dial("tcp", "localhost:8080") messages <- Message{Data: "Hello", Conn: conn}
ct {
Data string
Conn net.Conn
}
这种方式适合集中管理大量连接的写操作。
4. 处理粘包问题（提升可靠性）
TCP是流式协议，可能出现粘包或拆包。建议使用带长度前缀或分隔符的协议格式。
例如使用\n作为分隔符，配合bufio.Scanner安全读取：
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
processMessage(scanner.Text())
}
或者自定义协议头（如4字节表示长度），手动解析数据包。
基本上就这些。Golang的并发模型让TCP客户端开发变得简洁高效。关键是合理使用Goroutine、避免资源竞争，并处理好连接生命周期和协议解析。
