Golang如何处理并发HTTP请求

Go语言通过Goroutine和标准库实现高效并发HTTP处理。1. 使用sync.WaitGroup可并发发起多个HTTP请求,提升效率;2. 通过带缓冲channel作为信号量限制并发数,防止资源耗尽;3. http.Server默认为每个请求分配Goroutine,天然支持并发;4. 建议重用http.Client、设置超时、使用context控制生命周期,并配置连接池优化性能。

golang如何处理并发http请求

Go语言通过轻量级的Goroutine和强大的标准库,让处理并发HTTP请求变得简单高效。你不需要引入额外框架,就能轻松实现高并发的HTTP服务或客户端请求处理。

使用Goroutine发起并发HTTP请求

在Go中,每个HTTP请求可以放在一个独立的Goroutine中执行,这样多个请求能同时进行,而不是串行等待。

以下是一个并发发起多个HTTP GET请求的示例:

package main

import ("fmt""io/ioutil""net/http""sync")

func fetch(url string, wg *sync.WaitGroup) {defer wg.Done()resp, err := http.Get(url)if err != nil {fmt.Printf("Error fetching %s: %v\n", url, err)return}defer resp.Body.Close()

body, _ := ioutil.ReadAll(resp.Body)fmt.Printf("Fetched %d bytes from %s\n", len(body), url)

}

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

func main() {urls := []string{"https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c","https://www.php.cn/link/ef246753a70fce661e16668898810624","https://www.php.cn/link/4d2fe2e8601f7a8018594d98f28706f2",}

var wg sync.WaitGroupfor _, url := range urls {    wg.Add(1)    go fetch(url, &wg)}wg.Wait()

}

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

说明:使用 sync.WaitGroup 等待所有Goroutine完成。每个请求在独立的Goroutine中执行,实现并发。

限制并发数量避免资源耗尽

无限制地启动Goroutine可能导致系统资源耗尽或被目标服务器限流。可以通过带缓冲的channel控制最大并发数。

Otter.ai Otter.ai

一个自动的会议记录和笔记工具,会议内容生成和实时转录

Otter.ai 91 查看详情 Otter.ai

func limitedFetch(urls []string) {    const maxConcurrent = 3    sem := make(chan struct{}, maxConcurrent)    var wg sync.WaitGroup
for _, url := range urls {    wg.Add(1)    go func(u string) {        defer wg.Done()        sem <- struct{}{} // 获取信号量        defer func() { <-sem }() // 释放信号量        resp, err := http.Get(u)        if err != nil {            fmt.Printf("Error: %v\n", err)            return        }        defer resp.Body.Close()        fmt.Printf("Success: %s\n", u)    }(url)}wg.Wait()

}

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

说明:使用容量为3的channel作为信号量,确保最多只有3个请求同时运行。

服务端并发处理HTTP请求

Go的 http.Server 默认为每个请求分配一个Goroutine,天然支持并发处理。

你只需注册处理函数,Go会自动并发执行:

func handler(w http.ResponseWriter, r *http.Request) {    // 模拟耗时操作    time.Sleep(1 * time.Second)    fmt.Fprintf(w, "Hello from %s", r.URL.Path)}

func main() {http.HandleFunc("/", handler)http.ListenAndServe(":8080", nil)}

多个客户端同时访问时,每个请求由独立的Goroutine处理,互不阻塞。

优化建议

重用 http.Client 实例,避免重复创建带来的开销设置合理的超时时间,防止请求长时间挂起使用 context 控制请求生命周期,支持取消和超时生产环境考虑使用连接池(Transport 层配置)提升性能

基本上就这些。Go的并发模型简洁有力,配合HTTP包能快速构建高性能网络程序。关键在于合理控制并发度,避免过度消耗资源。

以上就是Golang如何处理并发HTTP请求的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1111524.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月2日 13:19:17
下一篇 2025年12月2日 13:19:38

相关推荐

发表回复

登录后才能评论
关注微信