在Go语言中实现高并发请求可以通过goroutine和channel来实现异步操作。下面是一个简单的示例代码:
package main
import (
"fmt"
"net/http"
"time"
)
func main() {
start := time.Now()
urls := []string{
"https://www.google.com",
"https://www.facebook.com",
"https://www.youtube.com",
}
// 创建一个无缓冲的channel
ch := make(chan string)
for _, url := range urls {
go fetch(url, ch)
}
for range urls {
fmt.Println(<-ch)
}
fmt.Printf("总共耗时: %.2fs\n", time.Since(start).Seconds())
}
func fetch(url string, ch chan string) {
start := time.Now()
resp, err := http.Get(url)
if err != nil {
ch <- fmt.Sprint(err)
return
}
resp.Body.Close()
elapsed := time.Since(start).Seconds()
ch <- fmt.Sprintf("请求 %s 耗时 %.2fs", url, elapsed)
}
在这个示例中,我们定义了一个包含三个URL的切片,然后使用goroutine并发地请求这些URL。每个goroutine都会调用fetch函数来发送HTTP请求并计算耗时,然后将结果发送到一个无缓冲的channel中。最后我们通过从channel中读取结果来打印每个请求的耗时,并计算总共的耗时。
通过使用goroutine和channel,我们可以实现高并发地发送HTTP请求并处理响应,从而提高程序的性能和效率。
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,请发送邮件至 55@qq.com 举报,一经查实,本站将立刻删除。转转请注明出处:https://www.szhjjp.com/n/1054708.html