本文详解如何通过 goroutine + channel 模式，使 go 程序能同时监听标准输入和 tcp 连接的读取事件，并借助 select 实现非阻塞、响应式的双向通信。
本文详解如何通过 goroutine + channel 模式，使 go 程序能同时监听标准输入和 tcp 连接的读取事件，并借助 select 实现非阻塞、响应式的双向通信。
在 Go 中，select 语句仅支持对 channel 的发送（不能直接嵌入阻塞式 I/O 调用（如 ReadString()）。这是初学者常遇的核心误区：select { case line, _ := reader.ReadString('\n'): ... } 会编译失败，因为 ReadString 是函数调用，不是 channel 操作。
正确解法是将每个 bufio.Reader 的读取逻辑封装进独立 goroutine，并通过无缓冲 channel 向主循环传递数据。这样既解耦了 I/O 阻塞，又保持了 select 的并发调度能力。
以下是一个完整、健壮的双通道聊天客户端示例：
package main
import (
"bufio"
"fmt"
"net"
"os"
)
func main() {
conn, err := net.Dial("tcp", "localhost:8998")
if err != nil {
fmt.Printf("无法连接服务器: %v\n", err)
return
}
defer conn.Close()
// 创建两个用于通信的 channel
outgoing := make(chan string)
incoming := make(chan string)
// 启动 goroutine：持续读取用户输入并发送到 outgoing 通道
go func() {
reader := bufio.NewReader(os.Stdin)
for {
line, err := reader.ReadString('\n')
if err != nil {
fmt.Printf("读取输入失败: %v\n", err)
return
}
outgoing ")
if _, err := fmt.Fprint(conn, out); err != nil {
fmt.Printf("发送失败: %v\n", err)
return
}
case in := <p>✅ <strong>关键要点说明：</strong> </p>
- goroutine 是必需的：ReadString 是阻塞调用，必须在独立协程中运行，否则主循环会被卡住；
- channel 不可缺少：它作为 goroutine 与主逻辑之间的“安全桥梁”，select 只能监听 channel；
- 错误处理不可省略：I/O 操作可能因连接关闭、EOF 或中断而失败，需及时退出 goroutine 避免泄漏；
- 避免死锁风险：不要在主循环中同步写入未缓冲的 channel（如原问题中 outgoing
- 资源清理建议：实际项目中应使用 context 控制 goroutine 生命周期，并确保 conn.Close() 和 os.Stdin 异常时 graceful shutdown。
该模式是 Go 网络编程的经典范式——将阻塞 I/O 封装为异步事件流，再由 select 统一调度，既简洁又高效。掌握它，你就能轻松构建 telnet 客户端、实时日志监控器、多路复用代理等典型并发应用。
