标签: go-context

我目前正在努力将我们的代码从全局符号包迁移到 mongo-driver，不确定我应该在哪里使用context.TODO()and context.Background()，它\xe2\x80\x99s 真的很令人困惑，我知道它都返回非零空，所以我应该context.Background()在主函数和init()函数中使用？还有用context.TODO()在其他地方吗？有人能帮忙吗？

尝试检查我应该使用哪个参数context.TODO()或context.Background().

如果连接在 10 秒前关闭，如何取消进一步处理？

有c.Request.Context().Done()但找不到如何使用它的示例。

func main() {
    r := gin.Default()
    r.GET("/ping", func(c *gin.Context) {
        time.Sleep(10 * time.Second) // or some db operation
        log.Print("Processing")
        c.JSON(200, gin.H{
            "message": "pong",
        })
    })
    r.Run()
}

我正在尝试在令牌身份验证中间件中提取 user_id 并将其传递给gqlgen的 graphql 解析器函数（以填充 GraphQL 架构的created_by 和updated_by 列）。身份验证部分工作没有任何问题。

Gin 中间件：

    var UID = "dummy"
    func TokenAuthMiddleware() gin.HandlerFunc {
        return func(c *gin.Context) {
            err := auth.TokenValid(c.Request)
            if err != nil {
                c.JSON(http.StatusUnauthorized, "You need to be authorized to access this route")
                c.Abort()
                return
            }
            //
            UID, _ = auth.ExtractTokenID(c.Request)
            //c.Set("user_id", UID)
            
            c.Next()
        }
    }

    func GetUID() string {
        return UID
    }

graphql 解析器：

    var ConstID = middleware.GetUID()
    
    func (r *mutationResolver) CreateFarmer(ctx context.Context, input model.NewFarmer) (*model.Farmer, error) {
        //Fetch …

感谢这里的任何帮助！我确信我错过了一些非常基本的东西。

我遇到的问题是我试图在演示 Web 应用程序中获取脱离上下文的值，并且收到错误：

2021/04/11 11:35:54 http: panic serving [::1]:60769: interface conversion: interface {} is nil, not []string

在我的主要函数中，我使用以下内容设置上下文：

package main

type ctxKey struct{}

func someHttpHandleFunc() {
  // .....
  ctx := context.WithValue(r.Context, ctxKey{}, matches[1:])
  route.handle(w, r.WithContext(ctx))
}

然后在我的处理程序中，我有以下内容：

package some_package

type ctxKey struct{}
func getField(r *http.Request, index int) string {
    fields := r.Context().Value(ctxKey{}).([]string)
    return fields[index]
}

我知道我错过了一些简单的东西，因为如果我尝试上面的代码并将我的getField()函数放在package main一切正常的情况下。

作为参考，这是一个学习练习，我正在尝试自学 Go 路由。我确实知道有可用的路由包 - 但我的目标是学习。我正在尽力遵循Go 中 HTTP 路由的不同方法。我还阅读了上下文值的陷阱以及如何在 Go 中避免或减轻它们。后者似乎直接解决了我遇到的问题，但我似乎无法根据现有的情况找出如何解决它。

我正在使用Echo 框架，并希望在设置一些自定义值后传递 Go 内置的底层context.Context echo.Context。

为了实现它，我想我可以首先应用 的Set(key string, val interface{})方法echo.Context，然后提取底层的context.Context.

问题是可以这样做吗？换句话说，是否像echo.Context.Set(...)直接设置值一样？或者我应该采取额外的步骤来复制我的自定义条目。context.ContextWithValue

PS我不想传递echo.Context到我的应用程序的更深层次，这就是为什么我不想直接使用它但得到引用context.Context

我一直在阅读一些关于使用 golang 的 context 包的文章。我最近在博客中看到以下文章：http://p.agnihotry.com/post/understanding_the_context_package_in_golang/

这篇文章对 go 中的上下文取消函数做了以下说明：

“如果您愿意，您可以传递取消函数，但是，强烈不建议这样做。这可能会导致取消的调用者没有意识到取消上下文可能对下游产生什么影响。可能还会派生出其他上下文这可能会导致程序以意想不到的方式运行。简而言之，永远不要传递取消函数。”

但是，如果我希望激活父 context.Done() 通道，将取消函数作为参数传递似乎是唯一的选择（请参阅下面的代码片段）。例如，下面代码片段中的代码 Done 通道仅在执行 function2 时激活。

package main

import (
    "context"
    "fmt"
    "time"
)

func function1(ctx context.Context) {
    _, cancelFunction := context.WithCancel(ctx)
    fmt.Println("cancel called from function1")
    cancelFunction()
}

func function2(ctx context.Context, cancelFunction context.CancelFunc) {
    fmt.Println("cancel called from function2")
    cancelFunction()
}

func main() {
    //Make a background context
    ctx := context.Background()
    //Derive a context with cancel
    ctxWithCancel, cancelFunction := context.WithCancel(ctx)

    go function1(ctxWithCancel)
    time.Sleep(5 * time.Second)

    go function2(ctxWithCancel, cancelFunction) …

我正在研究oklog/run包的一个简单示例，并且在尝试返回错误日志时在 VS Code 中看到此编译错误：

log.Errorf("abnormal termination: %s", err) (no value) used as value\n

在 group.Run 的描述中说

\n

“..Run 仅在所有 actor 退出时返回。Run 返回第一个退出的 actor 返回的错误。”

\n

我\xe2\x80\x99m想知道这是否与它有关，比如它可以\xe2\x80\x99t编译当前不存在的错误，因为run.Group尚未全部返回？

感谢您提供的任何帮助。

代码：

package main\n\nimport (\n    "context"\n    "time"\n\n    "github.com/oklog/run"\n    "github.com/pkg/errors"\n    log "github.com/sirupsen/logrus"\n)\n\nfunc logAForever(ctx context.Context) {\n    for {\n        select {\n        case err := <-ctx.Done():\n            log.Error(err)\n            return\n        default:\n            log.Info("A")\n            time.Sleep(1 * time.Second)\n        }\n    }\n}\n\nfunc logBFor10Sec(ctx context.Context) {\n    for i := 1; i < 10; i++ {\n        log.Info("B")\n        time.Sleep(1 …

我已经做了很多关于上下文的研究，但我似乎找不到普遍接受的答案，而且我是Go的新手。

在我当前的代码中，我var ctx = context.Background()已经在各个地方使用了它。

我担心的是，我的所有代码不是都修改相同的上下文吗，因为它是全局变量？。

是的，我知道上下文是请求范围的。

这是我的上下文代码的一部分。

var ctx = context.Background()

var db *firestore.Client

var auth *aut.Client

func init() {
    app, err := firebase.NewApp(ctx, nil)
    if err != nil {
        log.Fatal(err)
    }
    db, err = app.Firestore(ctx)
    if err != nil {
        log.Fatal(err)
    }
    auth, err = app.Auth(ctx)
    if err != nil {
        log.Fatal(err)
    }
}

func SetRate(r int) (err error) {
    //TODO: create last updated field
    _, err = db.Collection("Rate").Doc("rate").Set(ctx, map[string]int{"USDT": r})
    if …

我在这里使用半代码只是为了表明我对代码中发生的事情的意图，而不是使问题中的事情复杂化。

我有一个main.go文件调用连接到 mongoDB 数据库的方法：

mStore := store.NewMongoStore()

在我有用于连接数据库的NewMongoStore上下文中：client.Connect

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

现在，main.go我通过这种方式将商店传递给我的路由器控制器文件：

routes.GenericRoute(router, mStore)

在GenericRoute我获取 mStore 并将其传递给函数处理程序：

func GenericRoute(router *gin.Engine, mStore store.Store) {
    router.POST("/users", controllers.CreateUser(mStore))
}

现在，CreateUser我再次创建一个上下文，如下所示，将文档插入到 MongoDB 中：

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

insertedId, err := repo.CreateUser(ctx, newUser{"John", "Doe"})

在这里，我传递了上下文来createUser插入新文档。

正如你所看到的，在某些部分我已经传递了上下文，而在某些部分我没有。我真的不知道我应该做什么？处理上下文的正确方法是什么？我是否应该始终传递上下文，或者创建像这样的新上下文而不在方法参数中传递上下文是完全可以的。

这种编码的最佳实践是什么？从性能角度来看，哪一个更好？