用带缓冲channel实现多生产者多消费者队列，tasks := make(chan string, 100) 创建共享队列，生产者并发写入、消费者for range监听，关闭由生产者统一执行。
用 Go 的 channel 实现多生产者多消费者消息队列，核心是利用 channel 的并发安全特性和 goroutine 的轻量调度，无需额外锁机制就能自然解耦生产和消费。
用带缓冲 channel 作为共享任务队列
缓冲 channel 是关键——它让多个生产者能非阻塞地写入（只要未满），也让多个消费者能并发读取。定义方式简单直接：
-
tasks := make(chan string, 100)：创建容量为 100 的字符串通道，避免瞬时高峰导致生产者卡住
- 所有生产者都往这个 同一个 channel 发送消息，所有消费者都从它接收，天然支持多对多
- 注意不要在消费者中调用 close()，只能由生产者侧统一关闭（比如所有任务生成完毕后）
启动多个消费者 goroutine 并安全退出
每个消费者是一个独立 goroutine，用 for range 持续监听 channel，channel 关闭后自动退出：
- 写法示例：func consumer(id int, ch
- 启动 5 个消费者：for i := 0; i
- 若需等待全部消费者完成，配合 sync.WaitGroup 在主 goroutine 中 wg.Wait()
多生产者协同写入与优雅关闭
多个生产者可并行运行，但 channel 关闭必须由单一控制点执行，否则 panic。推荐做法：
- 用 sync.WaitGroup 跟踪所有生产者是否完成
- 另起一个 goroutine 等待 wg.Done() 后调用 close(tasks)
- 例如：生产者发完 100 条消息后 wg.Done()；关闭协程收到信号即 close(tasks)，通知所有消费者结束
增强健壮性的小技巧
真实场景中可加几处优化，不增加复杂度但提升可用性：
- 用 select + timeout 防止单次发送/接收无限等待，比如超时 5 秒就跳过
- 封装成结构体（如 type MQ struct { ch chan string; wg sync.WaitGroup }），便于后续扩展统计、重试或限流
- 消息类型建议自定义结构体（如 type Message { ID string; Bo
dy []byte; Timestamp int64 }），比裸字符串更易维护
dy []byte; Timestamp int64 }），比裸字符串更易维护