Go 适合高并发 I/O 密集型服务,goroutine 天然支持短连接与流式请求;需配置 HTTP 连接池、设置超时熔断;channel + select 优于回调,应使用缓冲 channel 并检查关闭状态。

高并发 I/O 密集型服务(如 API 网关、消息代理)
Go 的 goroutine + net/http 默认模型天然适合处理大量短连接或流式请求。每个请求由独立 goroutine 处理,阻塞在 Read 或 Write 时不会拖垮整个服务。
实操建议:
- 避免在 HTTP handler 中做同步重试或长轮询 —— 改用
context.WithTimeout控制单次调用生命周期 - 连接池必须显式配置:
http.DefaultTransport.MaxIdleConns和MaxIdleConnsPerHost不设默认值,不设会快速耗尽文件描述符 - 对下游依赖(如 Redis、gRPC)务必设置超时和熔断,
goroutine泛滥本身不危险,但未回收的等待态goroutine会堆积内存
需要细粒度协作与状态共享的后台任务(如订单履约、数据同步)
当多个子任务需按依赖顺序执行、共享中间结果、且存在取消/重试逻辑时,channel + select 比回调或线程锁更清晰。
常见错误现象:用 for range chan 读取无缓冲 channel 导致 sender 永久阻塞;或在 select 中漏写 default 分支,使协程卡死在等待。
立即学习“go语言免费学习笔记(深入)”;
实操建议:
- 优先使用带缓冲的
channel(如make(chan Result, 100)),尤其用于生产者-消费者解耦 - 所有
channel写入前检查是否已关闭,用select+case ch +default:避免 panic - 跨 goroutine 共享状态时,
sync.Map仅适用于读多写少;高频更新请用sync.RWMutex显式保护结构体字段
实时流处理与事件驱动架构(如日志采集、指标聚合)
Go 的并发模型擅长将“接收 → 解析 → 路由 → 聚合”拆成独立 stage,用 channel 连接,天然形成 pipeline。
性能影响点:channel 传递大对象(如 []byte)会触发频繁内存拷贝;若 stage 间处理速度差异大,缓冲区可能成为瓶颈。
实操建议:
- 用指针或
unsafe.Slice(Go 1.20+)传递大 payload,避免复制;但需确保上游不再修改原始内存 - 每个 stage 启动固定数量 goroutine(如
for i := 0; i ),而非为每条消息启一个 - 监控
len(ch)和cap(ch),当len(ch) == cap(ch)持续出现,说明下游消费慢,需降速或扩容
不适合的场景:纯 CPU 密集型计算且无法分片
Go 的 GPM 调度器在 CPU 密集任务中会让其他 goroutine 饿死 —— 因为 P 被长期占用,M 无法被抢占调度。
例如:单个 goroutine 执行未分块的矩阵乘法、视频帧编码、密码学哈希遍历。此时并发反而降低吞吐,且 runtime.Gosched() 主动让出效果有限。
实操建议:
- 必须并行 CPU 计算时,先手动分片(如把 100 万条记录切成 100 个 1 万条的 chunk),再用
sync.WaitGroup并发处理 - 调用 C 代码(如 FFmpeg)或外部二进制时,用
exec.CommandContext并传入context,防止子进程失控拖垮主程序 - 避免在
for循环内直接启动 goroutine 处理索引变量 ——for i := range data { go f(i) }中所有 goroutine 可能都读到同一个i的最终值
真正难的不是开多少 goroutine,而是确定哪些操作该阻塞、哪些该非阻塞,以及 channel 的生命周期谁来 close、何时 close。漏关 channel 或过早关闭,是线上 goroutine 泄漏最常见原因。











