如何在 Go Web 应用中合理使用 goroutine 处理异步请求-Golang-PHP中文网

如何在 Go Web 应用中合理使用 goroutine 处理异步请求

在 go http 服务中，每个请求已由框架自动分配独立 goroutine，因此通常无需为整个请求流程额外启协程；但当需并行执行多个 i/o 操作（如同时查库与调用 api），或需在响应后异步执行非关键任务（如日志、通知）时，才应谨慎启用新 goroutine。

在 go http 服务中，每个请求已由框架自动分配独立 goroutine，因此通常无需为整个请求流程额外启协程；但当需并行执行多个 i/o 操作（如同时查库与调用 api），或需在响应后异步执行非关键任务（如日志、通知）时，才应谨慎启用新 goroutine。

Go 的 net/http 包在接收到 HTTP 请求后，会自动为每个请求启动一个独立的 goroutine 来执行对应的 handler 函数。这意味着你无需、也不应手动为整个请求处理逻辑再包裹一层 go 语句——这样做不仅无性能收益，反而可能引发竞态、上下文丢失、资源泄漏等严重问题：

// ❌ 错误示例：完全没必要，且危险
func badHandler(w http.ResponseWriter, r *http.Request) {
    go func() {
        // 此处 w 和 r 可能已被回收，写入响应将 panic 或静默失败
        time.Sleep(100 * time.Millisecond)
        w.Write([]byte("done")) // 危险！w 已不可用
    }()
}

✅ 正确做法是：信任 HTTP 服务器的 goroutine 调度，在单个 handler 内按需组织逻辑。只有两类典型场景值得显式启动新 goroutine：

1. 并行执行多个阻塞型 I/O 操作

当多个操作彼此独立、耗时较长（如数据库查询 + 第三方 API 调用 + 缓存校验），且结果需汇总后统一响应时，应使用 sync.WaitGroup 或 errgroup.Group 实现并发：

func parallelHandler(w http.ResponseWriter, r *http.Request) {
    var wg sync.WaitGroup
    var mu sync.Mutex
    var result struct {
        DBData  string
        APIData string
        Err     error
    }

    wg.Add(2)

    go func() {
        defer wg.Done()
        data, err := queryDB(r.Context())
        mu.Lock()
        if err != nil {
            result.Err = err
        } else {
            result.DBData = data
        }
        mu.Unlock()
    }()

    go func() {
        defer wg.Done()
        data, err := callRemoteAPI(r.Context())
        mu.Lock()
        if err != nil && result.Err == nil {
            result.Err = err
        } else if err == nil {
            result.APIData = data
        }
        mu.Unlock()
    }()

    wg.Wait()

    if result.Err != nil {
        http.Error(w, result.Err.Error(), http.StatusInternalServerError)
        return
    }

    json.NewEncoder(w).Encode(map[string]string{
        "db":  result.DBData,
        "api": result.APIData,
    })
}

⚠️ 注意：务必传递 r.Context() 给下游操作，并在 goroutine 中监听取消信号；避免直接捕获 w 或 r 引用——它们不具备 goroutine 安全性。

2. 响应后异步执行“尽力而为”任务

例如记录审计日志、触发告警、更新统计指标等，这些操作不应阻塞用户响应。此时可启动 goroutine，但需确保不依赖 w/r，且最好使用带超时或错误抑制的封装：

func asyncPostResponseHandler(w http.ResponseWriter, r *http.Request) {
    // ✅ 正常处理并立即响应
    resp := map[string]string{"status": "ok"}
    w.Header().Set("Content-Type", "application/json")
    json.NewEncoder(w).Encode(resp)

    // ✅ 响应后异步执行（注意：不再使用 w/r）
    go func() {
        // 使用独立 context（如 background context），避免因客户端断开导致阻塞
        ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
        defer cancel()

        if err := logRequest(ctx, r); err != nil {
            // 记录到本地日志即可，不向上抛错
            log.Printf("failed to log request: %v", err)
        }
    }()
}