Golang初级项目如何处理并发请求

应节制使用goroutine,结合业务节奏限流;HTTP层用http.Server参数限流,子任务并发需设超时;WaitGroup适用于仅等待完成,channel适用于结果聚合,注意Add/Done配对和channel阻塞风险。

goroutine 启动并发任务,但别无脑加 go

新手常把每个请求都套一层 go handleRequest(),结果瞬间起几百个 goroutine,没控制、没回收、没超时,服务直接卡死或 OOM。goroutine 轻量不等于免费,它仍占栈内存(初始 2KB)、有调度开销,且大量并发会压垮下游依赖(比如数据库连接池)。

正确做法是结合业务节奏做节流:

  • HTTP handler 中优先用 http.Server 自带的连接数限制(MaxConnsPerHostReadTimeout)挡在最外层
  • 真正需要并发执行子任务时(如同时查 3 个微服务),才用 go 启动有限数量的 goroutine
  • 必须配 context.WithTimeoutcontext.WithCancel,防止子任务失控

sync.WaitGroupchan 选哪个收集结果?

两者都能等并发任务结束,但语义和风险不同。WaitGroup 更适合“只等完成,不关心返回值”的场景;而需要汇总多个子任务结果(比如并行调三个 API 拿数据再合并),用 channel 更自然、更安全。

常见错误是 WaitGroup 使用前忘记 wg.Add(n),或在 goroutine 里调 wg.Done() 前 panic 导致漏减 —— 这会让 wg.Wait() 永远阻塞。

立即学习“go语言免费学习笔记(深入)”;

channel 方案要注意:不带缓冲的 channel 写入会阻塞,如果某个 goroutine 失败没写入,其他成功者可能卡住。稳妥写法是配合 select + default 或带超时的 send:

results := make(chan string, 3)
for i := 0; i < 3; i++ {
    go func(id int) {
        result, err := fetchFromService(id)
        if err != nil {
            return // 不写入 channel
        }
        select {
        case results <- result:
        default: // 防止阻塞
        }
    }(i)
}

HTTP 服务中如何避免并发导致的数据竞争?

典型坑:全局变量(如计数器 var reqCount int)被多个 goroutine 直接读写,出现脏数据或 panic。Go 编译器不会报错,但运行时行为不可预测。

解决路径很明确:

  • 优先用局部变量 + 参数传递,把状态关进 goroutine 自己的 scope
  • 必须共享状态时,用 sync.Mutexsync.RWMutex(读多写少用后者)
  • 简单原子操作(如计数、开关)直接上 sync/atomic,比锁更快更轻量
  • 绝对不要用 map 作为并发写入的全局缓存 —— 即使加了锁,也要注意 map 的扩容机制不是线程安全的,建议换 sync.Map 或封装读写逻辑

为什么 for range 启动 goroutine 容易出 bug?

这是 Go 并发最经典的陷阱之一。写成这样:

for i := 0; i < 3; i++ {
    go func() {
        fmt.Println(i) // 总是输出 3 3 3
    }()
}

问题在于所有 goroutine 共享同一个变量 i 的地址,循环结束时 i == 3,而 goroutine 执行时才去读 —— 读到的全是最终值。

修复方法只有两个有效解:

  • 把变量作为参数传进 goroutine:go func(val int) { fmt.Println(val) }(i)
  • 在循环内定义新变量:for i := 0; i

别依赖 IDE 自动修复或“应该没问题”的直觉 —— 这类 bug 在压测时才暴露,且极难复现。

并发不是加几个 go 就完事,关键在边界控制、状态隔离和错误传播。越早把 context、channel、sync 工具用对,后期排查 CPU 爆高、连接堆积、数据错乱的成本就越低。