Go异步请求处理需分离耗时操作、避免阻塞主线程并控制资源，核心是合理使用channel+worker模式、context超时控制及规避goroutine常见陷阱。
用 Go 实现异步请求处理，核心不是“把请求扔给 goroutine 就完事”，而是合理分离耗时操作、避免阻塞主线程、控制资源消耗。关键在于理解 HTTP 处理生命周期、goroutine 生命周期和状态管理之间的关系。
明确哪些操作该异步化
不是所有逻辑都适合丢进 goroutine。真正需要异步的是：
– 外部 API 调用（如支付回调、短信发送）
– 文件写入或大对象序列化
– 数据库写操作（尤其是非关键日志、审计记录）
– 通知类任务（邮件、站内信）
同步响应必须返回的内容（如订单创建成功、用户登录态）仍需在主 goroutine 中完成并返回。
用 channel + goroutine 安全解耦响应与后续任务
避免直接在 handler 里起 goroutine 后不跟踪、不超时、不错误反馈。推荐用带缓冲的 channel 做任务队列，配合 worker 模式：
// 全局任务通道（容量限制防内存爆炸） var taskCh = make(chan func(), 100)// 启动固定 worker func init() { for i := 0; i < 5; i++ { go func() { for task := range taskCh { task() // 执行实际耗时逻辑 } }() } }
// handler 中 func createOrder(w http.ResponseWriter, r *http.Request) { // 1. 必须同步完成：校验、生成订单、写主库 order, err := saveOrder(r) if err != nil { http.Error(w, err.Error(), http.StatusBadRequest) return }
// 2. 异步触发：发通知、更新统计、调第三方 select { case taskCh <- func() { sendSMS(order.Phone, "下单成功") updateDashboardStats(order.ID) }: default: // 队列满，降级：记录告警，但不阻塞响应 log.Warn("task queue full, skip async tasks") } // 3. 立即返回成功结果 json.NewEncoder(w).Encode(map[string]interface{}{"id": order.ID, "status": "created"})}
用 context 控制超时与取消
外部调用必须设超时，否则一个慢请求可能拖垮整个服务：
立即学习“go语言免费学习笔记（深入）”；
– 不要用 time.Sleep 模拟等待，用 context.WithTimeout
– 对 http.Client 设置 Timeout 或用 context 传入 Request
– goroutine 内部定期检查 ctx.Done()，及时退出
ctx, cancel := context.WithTimeout(r.Context(), 2*time.Second) defer cancel()resp, err := http.DefaultClient.Do(req.WithContext(ctx)) if err != nil { if errors.Is(err, context.DeadlineExceeded) { log.Warn("third-party call timeout") return // 不重试，不阻塞 } return }
避免常见陷阱
– 不要在 goroutine 中直接操作 http.ResponseWriter：response 已随 handler 返回而结束，再写会 panic
– 不要在闭包中直接引用循环变量：用显式参数传值，例如 go func(o Order) { ... }(order)
– 不要无限制起 goroutine：用 worker pool 或带缓冲 channel 限流
– 注意结构体字段并发安全：若异步任务要修改共享数据，加 mutex 或改用原子操作
