Go中扇入扇出核心靠channel+goroutine，需控制并发、防泄漏、正确关通道：扇出要限流、传参防闭包陷阱、统一关输出通道；扇入用中转goroutine合并多通道，必监听done；组合时须用context超时/取消，缓冲区大小需按场景权衡。
Go 里做扇入（fan-in）和扇出（fan-out）不靠第三方库，核心就靠 channel + goroutine 的组合，关键在控制并发粒度、避免 goroutine 泄漏、以及正确关闭通道。
扇出：用 goroutine 并发调用多个数据源
扇出本质是把一个输入分发给多个并行任务。常见于批量请求下游服务（如多个 API、DB 分片、文件读取）。
- 别直接为每个任务起 goroutine 而不设限——容易打爆资源；用带缓冲的
semaphorechannel 或sync.WaitGroup控制并发数 - 每个 goroutine 必须有自己的输入副本，否则闭包捕获循环变量会导致所有 goroutine 处理同一个值（经典陷阱）
- 输出 channel 不要由每个 goroutine 单独 close，只由发起方或专用 collector 关闭
示例：向 3 个 URL 并发发起 HTTP 请求
urls := []string{"https://a.com", "https://b.com", "https://c.com"}
out := make(chan string, len(urls))
var wg sync.WaitGroup
sem := make(chan struct{}, 2) // 限制最多 2 个并发
<p>for <em>, url := range urls {
wg.Add(1)
go func(u string) {
defer wg.Done()
sem <- struct{}{} // 获取信号量
defer func() { <-sem }() // 释放信号量
resp, </em> := http.Get(u)
out <- resp.Status
}(url) // 注意传参，避免闭包问题
}</p><p>go func() {
wg.Wait()
close(out)
}()</p><p>// 消费结果
for status := range out {
fmt.Println(status)
}扇入：合并多个 channel 的输出到一个 channel
扇入是把多个 producer 的 channel 统一收口，典型场景是等待多个异步操作完成、或聚合结果。
- 不要用
select轮询多个 channel（无法预知数量），改用reflect.Select或更稳妥的「goroutine 中转」模式 - 中转 goroutine 必须监听
donechannel 防止泄漏，尤其当上游 channel 可能永不关闭时 - 如果上游 channel 可能发送零值或错误，扇入后需额外标记来源，否则无法区分 “空响应” 和 “通道已关”
推荐做法：为每个输入 channel 启一个转发 goroutine
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
func fanIn(chs ...<-chan string) <-chan string {
out := make(chan string)
var wg sync.WaitGroup
<pre class="brush:php;toolbar:false;">for _, ch := range chs {
wg.Add(1)
go func(c <-chan string) {
defer wg.Done()
for s := range c {
out <- s
}
}(ch)
}
go func() {
wg.Wait()
close(out)
}()
return out}
扇入扇出组合时，done channel 是必须项
真实业务中，扇出任务可能超时、失败或被取消，此时必须中断所有未完成的 goroutine，否则会卡死或泄漏。
- 所有扇出 goroutine 都要监听
，并在退出前清理资源（如关闭 HTTP 连接、释放锁） - 扇入端不能只等
close(out)，要配合ctx.Done()提前退出range循环 - 别用
context.WithCancel后忘记调用 cancel 函数——泄漏 context 和 goroutine
例如，在扇出中加入上下文控制：
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
<p>for _, url := range urls {
go func(u string) {
select {
case out <- fetchWithCtx(ctx, u):
case <-ctx.Done():
return // 退出，不写入 out
}
}(url)
}注意 buffer size 和阻塞风险
channel 缓冲区大小不是越大越好，它直接影响内存占用和背压行为。
- 扇出侧若用无缓冲 channel，而消费者处理慢，所有 goroutine 会在
ch 处阻塞，导致无法调度 - 扇入侧若用无缓冲 channel，而某个上游迟迟不发数据，整个扇入流程会被拖住（除非用
select+default非阻塞写） - 生产环境建议：输出 channel 缓冲大小 = 预估最大并发数 × 单次产出量；输入 channel 缓冲至少为 1
最易忽略的是：扇入后没消费完就退出，导致后续扇出 goroutine 在写 channel 时 panic（向已关闭 channel 发送数据）。务必确保 consumer 逻辑完备，或用 recover 包裹关键写入。
