本文详解如何通过 goroutine 和 channel 正确实现从 os.Stdin 实时读取并立即写入 os.Stdout，避免因通道操作顺序不当导致的延迟输出或死锁问题。
本文详解如何通过 goroutine 和 channel 正确实现从 os.stdin 实时读取并立即写入 os.stdout，避免因通道操作顺序不当导致的延迟输出或死锁问题。
在 Go 中，利用 channel 进行 I/O 流的解耦与异步处理是常见模式，但初学者常因对 select 语义和 channel 缓冲机制理解不足而陷入阻塞陷阱。原代码的核心问题在于：
case mes <- <-ch:
该语句并非原子操作——Go 会先执行 （从 <code>ch 接收值），再尝试将该值发送至 mes。由于 mes 是带缓冲的 chan message（容量为 1），且 select 仅保护“外层”发送操作是否就绪， 本身仍会阻塞，直到 <code>read() goroutine 发送第二个消息，从而造成输出延迟（即输入第二行后才打印第一行）。
✅ 正确方案一：单通道直连（推荐）
最简洁、安全的方式是省略中间 channel，直接消费 read() 返回的只读通道：
package main
import (
"bufio"
"fmt"
"io"
"os"
)
func read(r io.Reader) <-chan string {
lines := make(chan string)
go func() {
defer close(lines)
scanner := bufio.NewScanner(r)
for scanner.Scan() {
// 使用 scan.Text() 而非 scan.Bytes()
// 避免底层字节切片被后续 Scan 覆盖
lines <- scanner.Text()
}
// 可选：检查 scanner.Err() 并处理错误
if err := scanner.Err(); err != nil {
fmt.Fprintf(os.Stderr, "scan error: %v\n", err)
}
}()
return lines
}
func main() {
ch := read(os.Stdin)
for line := range ch {
fmt.Println("Message to stdout")
fmt.Println(line)
}
}✅ 优势：无缓冲竞争、无 goroutine 泄漏、逻辑清晰；
range自动处理 channel 关闭，无需手动sig同步。
✅ 正确方案二：双通道 + 显式 goroutine 转发
若需保留 mes 作为独立处理通道（例如后续扩展为多消费者或添加过滤逻辑），应将接收与发送拆分到独立 goroutine 中，确保 ch → mes 的转发不阻塞主循环：
func main() {
mes := make(chan string, 1) // 缓冲可防短暂背压
ch := read(os.Stdin)
// 启动转发 goroutine：安全地将 ch 中的消息推入 mes
go func() {
for msg := range ch {
fmt.Println("Message to channel 2")
mes <- msg // 此处可能阻塞，但仅影响转发 goroutine，不影响主循环
}
close(mes) // 转发结束，关闭 mes 以终止主循环
}()
// 主循环：只消费 mes
for line := range mes {
fmt.Println("Message to stdout")
fmt.Println(line)
}
}⚠️ 关键注意事项
-
永远优先用
scanner.Text()：scanner.Bytes()返回的切片指向内部缓冲区，下一次Scan()会覆盖其内容，导致数据错乱。 -
显式错误处理：生产环境应在
read()goroutine 中检查scanner.Err()并记录/传播错误。 -
避免无缓冲 channel 的双向依赖：如
mes无缓冲，且主循环与转发 goroutine 相互等待，极易引发死锁。 -
及时关闭 channel：使用
close()通知消费者数据流结束，使range循环自然退出。
通过以上任一方案，即可实现预期行为：每输入一行（回车后），立即输出两行日志（"Message to channel 2" 和 "Message to stdout"）及对应内容，真正达成低延迟、可组合的流式 I/O 处理。
