在Golang中处理异步HTTP请求主要依靠goroutine实现并发执行，结合channel完成结果传递和流程控制，这种方式可以充分利用Golang的并发特性，避免请求阻塞主流程。
核心基础组件
goroutine
goroutine是Golang提供的轻量级线程，通过go关键字即可启动，异步HTTP请求的核心就是把每个HTTP请求的执行放到独立的goroutine中，实现非阻塞调用。
channel
channel用于goroutine之间的通信，我们可以将每个异步HTTP请求的响应结果或者错误信息通过channel传递到主流程或者其他处理逻辑中，实现结果的统一收集。
基础实现示例
下面是一个简单的异步HTTP请求处理示例，同时发起多个请求，等待所有请求完成并收集结果：
package main
import (
"fmt"
"io/ioutil"
"net/http"
"sync"
"time"
)
// 定义请求结果结构体
type RequestResult struct {
URL string
Body string
Err error
Cost time.Duration
}
func asyncHTTPRequest(url string, resultChan chan<- RequestResult, wg *sync.WaitGroup) {
// 请求完成后减少等待组计数
defer wg.Done()
start := time.Now()
// 发起HTTP请求
resp, err := http.Get(url)
if err != nil {
resultChan <- RequestResult{URL: url, Err: err, Cost: time.Since(start)}
return
}
defer resp.Body.Close()
// 读取响应内容
body, err := ioutil.ReadAll(resp.Body)
if err != nil {
resultChan <- RequestResult{URL: url, Err: err, Cost: time.Since(start)}
return
}
resultChan <- RequestResult{URL: url, Body: string(body), Err: nil, Cost: time.Since(start)}
}
func main() {
// 待请求的URL列表
urls := []string{
"http://ipipp.com",
"http://127.0.0.1:8080",
"http://192.168.0.1/api/test",
}
// 创建结果通道
resultChan := make(chan RequestResult, len(urls))
// 创建等待组
var wg sync.WaitGroup
// 启动异步请求
for _, url := range urls {
wg.Add(1)
go asyncHTTPRequest(url, resultChan, &wg)
}
// 等待所有请求完成
go func() {
wg.Wait()
close(resultChan)
}()
// 收集结果
for result := range resultChan {
if result.Err != nil {
fmt.Printf("请求 %s 失败，耗时 %v，错误：%v\n", result.URL, result.Cost, result.Err)
} else {
fmt.Printf("请求 %s 成功，耗时 %v，响应长度：%d\n", result.URL, result.Cost, len(result.Body))
}
}
}实际开发注意事项
超时控制
默认情况下http.Get没有超时限制，实际使用中需要自定义http.Client设置超时时间，避免请求长时间挂起占用资源：
// 创建带超时的HTTP客户端，超时时间3秒
client := &http.Client{
Timeout: 3 * time.Second,
}
resp, err := client.Get(url)并发数量限制
如果同时发起大量异步请求，可能会对目标服务造成压力，也可能耗尽本地资源，可以通过带缓冲的channel实现并发数量限制：
// 限制最大并发数为5
semaphore := make(chan struct{}, 5)
func asyncHTTPRequestWithLimit(url string, resultChan chan<- RequestResult, wg *sync.WaitGroup) {
defer wg.Done()
// 获取并发令牌
semaphore <- struct{}{}
// 请求完成后释放令牌
defer func() { <-semaphore }()
// 后续请求逻辑和之前一致
}错误处理
异步场景下的错误不会直接抛出到主流程，需要统一在结果中返回，做好错误分类，比如网络错误、超时错误、响应状态码错误等，根据业务需求做对应处理。