Go异步请求处理需分离耗时操作、避免阻塞主线程并控制资源，核心是合理使用channel+worker模式、context超时控制及规避goroutine常见陷阱。
用 Go 实现异步请求处理，核心不是“把请求扔给 goroutine 就完事”，而是合理分离耗时操作、避免阻塞主线程、控制资源消耗。关键在于理解 HTTP 处理生命周期、goroutine 生命周期和状态管理之间的关系。
明确哪些操作该异步化
不是所有逻辑都适合丢进 goroutine。真正需要异步的是：
– 外部 API 调用（如支付回调、短信发送）
– 文件写入或大对象序列化
– 数据库写操作（尤其是非关键日志、审计记录）
– 通知类任务（邮件、站内信）
同步响应必须返回的内容（如订单创建成功、用户登录态）仍需在主 goroutine 中完成并返回。
用 channel + goroutine 安全解耦响应与后续任务
避免直接在 handler 里起 goroutine 后不跟踪、不超时、不错误反馈。推荐用带缓冲的 channel 做任务队列，配合 worker 模式：
// 全局任务通道（容量限制防内存爆炸）
var taskCh = make(chan func(), 100)
<p>// 启动固定 worker
func init() {
for i := 0; i < 5; i++ {
go func() {
for task := range taskCh {
task() // 执行实际耗时逻辑
}
}()
}
}</p><p>// 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
}</p><pre class="brush:php;toolbar:false;">// 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()
<p>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 或改用原子操作
