Golang实现TCP并发客户端技巧

conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
    log.Fatal(err)
}
defer conn.Close()
<p>// 发送数据（可在单独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)
}
}()</p><p>// 接收响应
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
fmt.Println("收到:", scanner.Text())
}
if err := scanner.Err(); err != nil {
fmt.Println("读取错误:", err)
}</p>

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()
<pre class="brush:php;toolbar:false;">    // 发送请求
    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()

type Message struct {
    Data   string
    Conn   net.Conn
}
<p>messages := make(chan Message, 100)</p><p>// 发送协程
go func() {
for msg := range messages {
msg.Conn.Write([]byte(msg.Data + "\n"))
}
}()</p><p>// 使用示例
conn, _ := net.Dial("tcp", "localhost:8080")
messages <- Message{Data: "Hello", Conn: conn}</p>

scanner := bufio.NewScanner(conn)
for scanner.Scan() {
    processMessage(scanner.Text())
}