Go通过goroutine和channel高效处理HTTP并发,示例代码展示默认并发处理、信号量限制并发数、context控制超时及sync.Mutex避免数据竞争,强调资源控制与同步。

在Golang中处理HTTP请求并发非常高效,得益于其轻量级的goroutine和强大的标准库。只要合理设计,就能轻松应对高并发场景。
Go的net/http包默认每个请求都在独立的goroutine中处理,这意味着你写的HTTP处理器天然支持并发。
例如:
func handler(w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Hello from %s", r.URL.Path) }func main() { http.HandleFunc("/", handler) http.ListenAndServe(":8080", nil) }
上面的代码中,每当有请求到达,Go运行时会自动启动一个goroutine来执行handler函数,无需额外配置。
立即学习“go语言免费学习笔记(深入)”;
虽然goroutine很轻量,但无限制地并发可能导致内存暴涨或系统负载过高。可以通过以下方式控制并发:
示例:限制最多10个并发处理
var sem = make(chan struct{}, 10)func limitedHandler(w http.ResponseWriter, r *http.Request) { sem <- struct{}{} // 获取信号量 defer func() { <-sem }() // 处理完成后释放
// 模拟处理逻辑 time.Sleep(2 * time.Second) fmt.Fprintf(w, "Processed: %s", r.URL.Path)
}
在并发场景中,使用context可以优雅地处理超时、取消和传递请求范围的数据。
比如设置请求超时:
ctx, cancel := context.WithTimeout(r.Context(), 3*time.Second) defer cancel()req, _ := http.NewRequestWithContext(ctx, "GET", "https://www.php.cn/link/46b315dd44d174daf5617e22b3ac94ca", nil) resp, err := http.DefaultClient.Do(req)
这样即使下游服务响应慢,也不会导致整个服务被拖垮。
多个goroutine可能同时访问全局变量或结构体字段,必须做好同步。
错误示例(未加锁):
var counter int func badHandler(w http.ResponseWriter, r *http.Request) { counter++ // 数据竞争! }正确做法:
var mu sync.Mutex var counter intfunc goodHandler(w http.ResponseWriter, r *http.Request) { mu.Lock() counter++ mu.Unlock() }
基本上就这些。Go的并发模型简单直接,关键是控制好资源使用、避免数据竞争,并善用context做流程控制。
以上就是如何在Golang中处理HTTP请求并发的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号