Golang 频道流

Question

我对 Golang 比较陌生，对流不是很了解。我有一个正在调用 Rest 的函数（断路器函数）。我让它工作，但它只流式传输 "responseBody" 回来。我实际上想将 Body 和 Header 的整个流请求一起流回。

当我尝试在 "header" 上使用类似的方法时，出现 header 不可流式传输的错误。

有没有 good/best 方法来完成这个？谢谢你。下面是我的函数。

func CallWithRetries(req *http.Request, output chan []byte) error {
    r := retrier.New(retrier.ConstantBackoff(RETRIES, 100 * time.Millisecond), nil)
    attempt := 0
    err := r.Run(func() error {
        attempt++
        resp, err := Client.Do(req)
        if err == nil && resp.StatusCode < 299 {
            responseBody, err := ioutil.ReadAll(resp.Body)
            if err == nil {
                output <- responseBody
                return err
            }
            return err
        } else if err == nil {
            customLogger.LogDebug("Status code was: " , transactionId)
            err = fmt.Errorf("Status was %v", resp.StatusCode)
        }
        return err
    })
    return err
}

Answer 1

您正在查找 httputil.DumpResponse 函数。

代码可能会更改为类似于

func CallWithRetries(req *http.Request, output chan []byte) error {
    r := retrier.New(retrier.ConstantBackoff(RETRIES, 100*time.Millisecond), nil)
    attempt := 0
    err := r.Run(func() error {
        attempt++
        resp, err := Client.Do(req)
        if err == nil && resp.StatusCode < 299 {
            dump, err := httputil.DumpResponse(resp, true)
            if err == nil {
                output <- dump
                return err
            }
            return err
        } else if err == nil {
            customLogger.LogDebug("Status code was: ", transactionId)
            err = fmt.Errorf("Status was %v", resp.StatusCode)
        }
        return err
    })
    return err
}

旁注，

您可能要考虑关闭响应正文，如文档中所述https://golang.org/pkg/net/http/#Client.Get
看起来 err 变量被隐藏了，应该修改它以避免任何意外。

此版本的代码尝试尽早 return 错误，并关闭响应主体。未经测试，仅即时编写，谨慎使用。

func CallWithRetries(req *http.Request, output chan []byte) error {
    r := retrier.New(retrier.ConstantBackoff(RETRIES, 100*time.Millisecond), nil)
    attempt := 0
    return r.Run(func() error {
        attempt++
        var resp *http.Response
        {
            r, err := Client.Do(req)
            if err != nil {
                return err
            }
            defer r.Body.Close()
            if resp.StatusCode > 299 {
                customLogger.LogDebug("Status code was: ", transactionId)
                return fmt.Errorf("Status was %v", resp.StatusCode)
            }
            resp = r
        }
        var out []byte
        {
            x, err := httputil.DumpResponse(resp, true)
            if err != nil {
                return err
            }
            out = x
        }
        output <- out
        return nil
    })
}

Golang 频道流

Golang Channel Streams

rest

stream

go

circuit-breaker