golang http异步请求

在现代 Web 开发中，处理 HTTP 请求是一个非常关键的任务。Golang 的高性能使其成为构建可扩展 Web 服务器和应用程序的理想语言。而在 Golang 中，使用标准库中的 net/http 包来处理 HTTP 请求是一种常见的做法。

使用 net/http 发起 HTTP 请求

net/http 包提供了一个方便的工具来发起 HTTP 请求。要发起一个 HTTP GET 请求，我们可以使用 http.Get 函数。这个函数的返回值是一个指向 http.Response 结构体的指针，其中包含了许多有关响应的信息，如状态码、响应头和响应体。

下面是一个简单的例子，演示了如何使用 http.Get 发起一个 HTTP GET 请求：

```go resp, err := http.Get("http://www.example.com") defer resp.Body.Close() if err != nil { log.Fatal(err) } body, err := ioutil.ReadAll(resp.Body) if err != nil { log.Fatal(err) } fmt.Println(string(body)) ```

异步发起多个 HTTP 请求

在现实世界的应用中，我们经常需要同时发起多个 HTTP 请求，并等待所有请求完成后再进行下一步操作。Golang 的 goroutine 和 channel 提供了一种优雅的方式来实现并发。

我们可以使用 goroutine 来并行发起多个 HTTP 请求，并使用 channel 来接收每个请求的响应。下面是一个例子：

```go urls := []string{ "http://www.example.com", "http://www.example.org", "http://www.example.net", } ch := make(chan string) for _, url := range urls { go func(url string) { resp, err := http.Get(url) defer resp.Body.Close() if err != nil { log.Fatal(err) } body, err := ioutil.ReadAll(resp.Body) if err != nil { log.Fatal(err) } ch <- string(body) }(url) } for range urls { fmt.Println(<-ch) } ```

使用 Go 的 Concurrency 模式

上面的例子中，我们使用了 goroutine 和 channel 来实现并发的 HTTP 请求。这种方式很简单且有效，但在实际应用中，我们经常需要更复杂的操作，例如限制并发量、设置超时等。这时候，我们可以使用 Go 的 Concurrency 模式来处理 HTTP 请求。

Concurrency 模式通过将任务拆分为多个阶段，并使用通道进行协调，在一定程度上提高了程序的可读性和可维护性。下面是一个使用 Concurrency 模式的例子：

```go type Request struct { URL string Response string } func worker(in <-chan Request, out chan<- Request) { for req := range in { resp, err := http.Get(req.URL) defer resp.Body.Close() if err != nil { log.Fatal(err) } body, err := ioutil.ReadAll(resp.Body) if err != nil { log.Fatal(err) } req.Response = string(body) out <- req } } func main() { urls := []string{ "http://www.example.com", "http://www.example.org", "http://www.example.net", } in := make(chan Request) out := make(chan Request) for i := 0; i < 3; i++ { go worker(in, out) } go func() { for _, url := range urls { in <- Request{URL: url} } close(in) }() for i := 0; i < len(urls); i++ { req := <-out fmt.Println(req.Response) } } ```

通过使用 Concurrency 模式，我们可以轻松实现更复杂的控制流程，例如设置超时、限制并发量等。这种方式使得我们能够更好地管理和控制 HTTP 请求，并提供更好的用户体验。