goroutines 与数据列表并行运行 post api

Question

这是我第一次使用 go，我来自 python 背景，我正在尝试使用具有不同帖子数据集的 goroutine 并行运行这个帖子 api( https://reqres.in/api/users )这是此代码中的变量 jsonStr 。非常感谢您与数据列表并行运行此 api 的任何帮助我的数据data = [{"name": "bonny gaud", "movies": ["Terminator", "Transformer"], {"name": "Sarah Palin", "movies": ["No country for old", "占士邦”] }我的代码：package mainimport (    "fmt"    "io/ioutil"    "net/http"    "time"    "bytes")func main() {    start := time.Now()    url := "https://reqres.in/api/users"    fmt.Println("URL:>", url)    var jsonStr = []byte(`{"name": "paul rudd", "movies": ["I Love You Man", "Role Models"] }`)    req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonStr))    req.Header.Set("X-Custom-Header", "myvalue")    req.Header.Set("Content-Type", "application/json")    client := &http.Client{}    resp, err := client.Do(req)    if err != nil {        panic(err)    }    defer resp.Body.Close()    fmt.Println("response Status:", resp.Status)    fmt.Println("response Headers:", resp.Header)    body, _ := ioutil.ReadAll(resp.Body)    fmt.Println("response Body:", string(body))    fmt.Print("Everything:", time.Since(start))    fmt.Print(string(body))}

Answer 1

您可以使用 waitGroup 或 errGroup。这是示例：

package main

import (

    "bytes"

    "fmt"

    "golang.org/x/sync/errgroup"

    "io/ioutil"

    "net/http"

    "time"

)

func main() {

    dataSets := []string{`{"name": "paul rudd", "movies": ["I Love You Man", "Role Models"] }`,

        `{"name": "paul rudd", "movies": ["I Love You Man", "Role Models"] }`}

    var eg errgroup.Group

    client := http.DefaultClient

    for _, jsonStr := range dataSets {

        eg.Go(func() error {

            return callClient(client, jsonStr)

        })

    }

    if err := eg.Wait(); err != nil {

        fmt.Printf("Encountered error: %v", err)

    }

    fmt.Println("Successfully finished.")

}

func callClient(client *http.Client, jsonStr string) error {

    start := time.Now()

    url := "https://reqres.in/api/users"

    fmt.Println("URL:>", url)

    req, err := http.NewRequest("POST", url, bytes.NewBuffer([]byte(jsonStr)))

    req.Header.Set("X-Custom-Header", "myvalue")

    req.Header.Set("Content-Type", "application/json")

    resp, err := client.Do(req)

    if err != nil {

        return fmt.Errorf("send request: %w", err)

    }

    defer resp.Body.Close()

    fmt.Println("response Status:", resp.Status)

    fmt.Println("response Headers:", resp.Header)

    body, err := ioutil.ReadAll(resp.Body)

    if err != nil {

        return fmt.Errorf("read body: %w", err)

    }

    fmt.Println("response Body:", string(body))

    fmt.Print("Everything:", time.Since(start))

    fmt.Print(string(body))

    return nil

}