用 chan 实现带缓冲的生产者-消费者队列需：1. 使用 make(chan T, N) 创建缓冲通道；2. 生产者只发送、不关闭，消费者在独立 goroutine 中 range 读取；3. 生产者完成所有发送后再 close，确保不丢数据；4. 需超时或中断时用 select + done chan。
用 chan 实现带缓冲的生产者-消费者队列
Go 的 chan 本身不是“消息队列”组件，但配合缓冲区和 goroutine 可快速构建轻量级并发队列。关键不在于封装多复杂，而在于控制好阻塞点和关闭时机。
常见错误是直接用无缓冲 chan 做队列——一端没 goroutine 接收就会永久阻塞主线程。必须明确：队列 = 缓冲通道 + 独立消费 goroutine。
- 用
make(chan string, 100)创建带缓冲的通道，容量即最大待处理消息数 - 生产者只负责
send，不关心是否被立刻消费；消费者在单独 goroutine 中持续range或select读取 - 不要在多个 goroutine 中同时向同一
chan发送而不加限流——可能触发 panic（如向已关闭的 channel 发送）
如何安全关闭 channel 并通知消费者退出
关闭 channel 是信号，不是命令。close() 后仍可读取剩余数据，但不能再写入。消费者不能靠 “读到零值” 判断结束，必须配合 ok 语义或额外 done 信号。
典型陷阱：在生产者 goroutine 中 close(ch) 后，消费者可能还在 range ch，这是安全的；但如果生产者一边发一边关，且没等所有消息发完就关，会丢数据。
立即学习“go语言免费学习笔记（深入）”；
- 推荐模式：生产者完成所有
send后再close(ch) - 消费者用
for msg := range ch自动退出，无需额外判断 - 若需提前中断（如超时），改用
select+done chan struct{}，避免依赖close()
用 select 实现带超时和优先级的消息分发
纯 range 消费无法响应外部控制。真实场景常需：限制单条处理时间、支持紧急消息插队、允许优雅停止。这时必须上 select。
注意：多个 case 同时就绪时，select 随机选一个，不保证 FIFO。如需严格顺序，别用多 case 并发读同一 channel，而是用单个 case + 外部逻辑排序。
case msg := 正常接收case 防止单条卡死case 收到终止信号，先close(ch)再 break- 紧急通道建议单独建一个
urgentCh chan string，在select中放更高优先级case
func runWorker(ch, urgentCh <-chan string, done <-chan struct{}) {
for {
select {
case msg := <-urgentCh:
processUrgent(msg)
case msg := <-ch:
processNormal(msg)
case <-done:
return
}
}
}为什么不用第三方库？什么情况下该换
用原生 chan 能覆盖 70% 的内部调度需求：服务间轻量通信、任务批处理、状态广播。但它不提供持久化、ACK、重试、监控指标——这些是 MQ（如 Kafka、NATS）的职责。
当出现以下任一情况，说明该脱离 chan 了：
- 消息必须落盘，进程崩溃后不能丢
- 消费者处理失败需自动重投，且要控制重试次数/间隔
- 需要跨进程、跨机器分发，或有多个独立服务订阅同一主题
- 运维要求查看堆积量、消费延迟、成功率等指标
channel 是并发原语，不是消息中间件。把它当队列用可以，但别指望它扛住线上 MQ 场景。
