使用golang对每个请求执行上下文超时

我正在尝试处理每个请求的上下文超时.我们有以下服务器结构:

流程概述:

Go Server:基本上,充当[反向代理].2

Auth服务器:检查请求身份验证.

Application Server:核心请求处理逻辑.

现在,如果授权服务器无法在规定的时间内处理请求,那么我想从内存中关闭goroutine.

这是我尝试过的:

ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
req, _ := http.NewRequest("GET", authorizationServer, nil)
req.Header = r.Header
req.WithContext(ctx)
res, error := client.Do(req)
select {
case <-time.After(10 * time.Second):
    fmt.Println("overslept")
case <-ctx.Done():
    fmt.Println(ctx.Err()) // prints "context deadline exceeded"
}

在此处,如果请求未在规定时间内处理,则上下文将返回" 超出截止日期 ".但它继续处理该请求并在指定时间内返回响应.那么当超过时间时,如何停止请求流(goroutine).

虽然我已经实现了完整的请求需要在60秒内使用此代码进行处理:

var netTransport = &http.Transport{
    Dial: (&net.Dialer{
        Timeout: 60 * time.Second,
    }).Dial,
    TLSHandshakeTimeout: 60 * time.Second,
}
client := &http.Client{
    Timeout:   time.Second * 60,
    Transport: netTransport,
    CheckRedirect: func(req *http.Request, via []*http.Request) error {
        return http.ErrUseLastResponse
    },
}

那么我还需要任何单独的上下文实现吗？在此先感谢您的帮助.

注1:如果我们可以使用上下文管理由HTTP服务器创建的每个请求(goroutine)的超时,那将是非常棒的.

1> Bogdan Iulia..：

---

您的代码中发生的事情是非常正确的,并且行为符合预期.

5 secondsrequestselect

contextdefer

ctx.Err()deadline exceededcontext

ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()

go func () {
    select {
    case <-time.After(10 * time.Second):
        fmt.Println("overslept")
    case <-ctx.Done():
        fmt.Println(ctx.Err()) // prints "context deadline exceeded"
    }
}()
req, _ := http.NewRequest("GET", authorizationServer, nil)
req.Header = r.Header
req = req.WithContext(ctx)
res, error := client.Do(req)

从上下文文档:

// Err returns a non-nil error value after Done is closed. Err returns
// Canceled if the context was canceled or DeadlineExceeded if the
// context's deadline passed. No other values for Err are defined.
// After Done is closed, successive calls to Err return the same value.

DeadlineExceeeded

errorclient.Docontext