go语言中怎么使用goroutine实现并行请求

首先,让我们来看一下如何使用 goroutine 实现并行请求。

package main

import (
    "fmt"
    "net/http"
)

func main() {
    urls := []string{
        "http://example.com/1",
        "http://example.com/2",
        "http://example.com/3",
    }

    for _, url := range urls {
        go func(url string) {
            res, err := http.Get(url)
            if err != nil {
                fmt.Println("Error:", err)
                return
            }

            fmt.Println("Response:", res.Status)
        }(url)
    }

    fmt.Scanln()
}

在这个例子中,我们定义了一个 URLs 数组,它包含了我们需要请求的 URL。我们遍历这个数组,并使用 go 关键字在每个 URL 上启动一个新的 goroutine。这个 goroutine 发送一个 HTTP GET 请求,并在请求结束后将响应结果输出到终端。

这样的同时请求会让我们的程序变得更快,但同时也会有一些问题。首先,如果我们启动了太多的 goroutine,我们可能会超过操作系统允许的最大并发数。其次,我们需要等待所有请求完成才能得到结果,这可能会导致响应时间过长,也就是说我们需要一些更加高效的处理方式。

接下来,我们来看一下如何使用 goroutine 和 channel 实现更加高效的并行请求。

package main

import (
    "fmt"
    "net/http"
)

func main() {
    urls := []string{
        "http://example.com/1",
        "http://example.com/2",
        "http://example.com/3",
    }

    ch := make(chan string)

    for _, url := range urls {
        go func(url string) {
            res, err := http.Get(url)
            if err != nil {
                fmt.Println("Error:", err)
                return
            }

            ch <- fmt.Sprintf("Response from %s: %s", url, res.Status)
        }(url)
    }

    for i := 0; i < len(urls); i++ {
        fmt.Println(<-ch)
    }
}

在这个例子中,我们定义了一个名为 ch 的 channel,我们在每个 goroutine 中将结果发送到 channel 中。在主线程中,我们使用循环来接收 channel 里面的所有结果,并将它们打印到终端中。

使用 channel 的优点是我们能够控制 goroutine 的数量,并且我们不需要等待所有的 goroutine 完成请求才能得到结果。相比起等待所有的请求完全结束,这样的并行请求可以让我们更快地得到结果,并且也避免了因为请求的响应时间过长而导致的卡顿现象。

原创文章,作者:LKOIG,如若转载,请注明出处:https://www.beidanyezhu.com/a/31881.html

(0)
LKOIG的头像LKOIG
上一篇 2025-02-26
下一篇 2025-03-04

相关推荐

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

分享本页
返回顶部