如何处理 HTTP 超时错误和访问 golang 中的状态码

Question

我有一些用 Go 编写的代码（见下文），它应该“扇出”HTTP 请求，然后整理/汇总详细信息。

我是 golang 的新手，所以希望我成为一个 nOOb 并且我的知识是有限的

程序的输出目前是这样的：

{
    "Status":"success",
    "Components":[
        {"Id":"foo","Status":200,"Body":"..."},
        {"Id":"bar","Status":200,"Body":"..."}, 
        {"Id":"baz","Status":404,"Body":"..."}, 
        ...
    ]
}

有一个正在运行的本地服务器故意变慢（休眠 5 秒，然后返回响应）。但我列出了其他网站（参见下面的代码），有时也会触发错误（如果它们出错，那很好）。

我现在的问题是如何最好地处理这些错误，特别是“超时”相关的错误；因为我不确定如何识别失败是超时还是其他错误？

目前我一直收到一个全面错误：

Get http://localhost:8080/pugs: read tcp 127.0.0.1:8080: use of closed network connection

http://localhost:8080/pugs 通常是失败的 url（希望是超时！）。但是正如您从代码（如下）中看到的那样，我不确定如何确定错误代码与超时有关，也不确定如何访问响应的状态代码（我目前只是将其设置为@987654326 @ 但显然这是不对的 - 如果服务器出错，我会期待像 500 这样的状态代码，显然我想在我发回的汇总响应中反映这一点。

完整的代码可以在下面看到。任何帮助表示赞赏。

    package main

    import (
            "encoding/json"
            "fmt"
            "io/ioutil"
            "net/http"
            "sync"
            "time"
    )

    type Component struct {
            Id  string `json:"id"`
            Url string `json:"url"`
    }

    type ComponentsList struct {
            Components []Component `json:"components"`
    }

    type ComponentResponse struct {
            Id     string
            Status int
            Body   string
    }

    type Result struct {
            Status     string
            Components []ComponentResponse
    }

    var overallStatus string = "success"

    func main() {
            var cr []ComponentResponse
            var c ComponentsList

            b := []byte(`{"components":[{"id":"local","url":"http://localhost:8080/pugs"},{"id":"google","url":"http://google.com/"},{"id":"integralist","url":"http://integralist.co.uk/"},{"id":"sloooow","url":"http://stevesouders.com/cuzillion/?c0=hj1hfff30_5_f&t=1439194716962"}]}`)

            json.Unmarshal(b, &c)

            var wg sync.WaitGroup

            timeout := time.Duration(1 * time.Second)
            client := http.Client{
                    Timeout: timeout,
            }

            for i, v := range c.Components {
                    wg.Add(1)

                    go func(i int, v Component) {
                            defer wg.Done()

                            resp, err := client.Get(v.Url)

                            if err != nil {
                                fmt.Printf("Problem getting the response: %s\n", err)

                                cr = append(cr, ComponentResponse{
                                    v.Id,
                                    404,
                                    err.Error(),
                                })
                            } else {
                                    defer resp.Body.Close()
                                    contents, err := ioutil.ReadAll(resp.Body)
                                    if err != nil {
                                            fmt.Printf("Problem reading the body: %s\n", err)
                                    }

                                    cr = append(cr, ComponentResponse{
                                            v.Id,
                                            resp.StatusCode,
                                            string(contents),
                                    })
                            }
                    }(i, v)
            }
            wg.Wait()

            j, err := json.Marshal(Result{overallStatus, cr})
            if err != nil {
                    fmt.Printf("Problem converting to JSON: %s\n", err)
                    return
            }

            fmt.Println(string(j))
    }

Answer 1

我添加这个是为了完成，因为正确答案是 Dave C 在接受答案的 cmets 中提供的。

我们可以尝试将错误转换为 net.Error 并检查是否超时。

resp, err := client.Get(url)
if err != nil {
    // if there is an error check if its a timeout error
    if e, ok := err.(net.Error); ok && e.Timeout() {
        // handle timeout
           return
    } 
    // otherwise handle other types of error
}

Answer 2

如果你想扇出然后聚合结果并且你想要特定的超时行为 net/http 包没有给你，那么你可能想要使用 goroutines 和通道。

我今天刚刚观看了这个视频，它将带您了解使用 Go 的并发特性的那些场景。另外，演讲者 Rob Pike 很有权威——他解释得比我好。

https://www.youtube.com/watch?v=f6kdp27TYZs

Answer 3

Go 1.5 版本通过更具体地说明它处理的错误类型解决了这个问题。

因此，如果您看到此示例 https://github.com/Integralist/Go-Requester/blob/master/requester.go#L38，您将看到我能够将正则表达式模式应用于错误消息，以破译错误是否确实超时

status := checkError(err.Error())

func checkError(msg string) int {
    timeout, _ := regexp.MatchString("Timeout", msg)

    if timeout {
        return 408
    }

  return 500
}