我不确定如何创建和传递上下文

学习Golang要努力，但是不要急！今天的这篇文章《我不确定如何创建和传递上下文》将会介绍到等等知识点，如果你想深入学习Golang，可以关注我！我会持续更新相关文章的，希望对大家都能有所帮助！

我有一个 http 服务器，当它收到请求时，会调用底层 grpc 服务器。

我选择使用接口抽象出 grpc 调用，以便更轻松地测试 http 服务器。

问题是我不断收到错误：

rpc 错误：代码 = 已取消 desc = grpc：客户端连接正在关闭 或者 rpc 错误：代码 = 已取消 desc = 上下文已取消

据我了解，这两个都与传递到 grpc 调用的上下文有关。我希望上下文在整个 http 和 grpc 调用中都处于活动状态。

type settergetter interface {
    getter(key string) (val string)
}
type service struct {
    sg  settergetter
    ctx context.context
}

func (s *service) gethandler(rw http.responsewriter, r *http.request) {
    key := r.url.query()["key"][0]
    res := s.sg.getter(key)
    fmt.fprintf(rw, "successfully got value: %s\n", res)
}

func main() {
    s := new(service)

    ctx, cancel := context.withtimeout(context.background(), 10*time.second)
    defer cancel()

    s.sg = gc.newclientwrapper(ctx)

    http.handlefunc("/get", s.gethandler)

    log.fatal(http.listenandserve(port, nil))
}

我的 getter 实现如下所示：

type clientwrapper struct {
    sc  pb.servicesclient
    ctx context.context
}

func newclientwrapper(ctx context.context) *clientwrapper {
    cw := new(clientwrapper)

    conn, err := grpc.dial(address, grpc.withinsecure(), grpc.withblock())
    if err != nil {
        err = fmt.errorf("error could not dial address: %v", err)
    }
    defer conn.close()

    cw.ctx = ctx

    cw.sc = pb.newservicesclient(conn)

    return cw
}

func (cw *clientwrapper) getter(key string) (val string) {
    // make the grpc request
    res, err := cw.sc.get(cw.ctx, &pb.getrequest{key: key})
    if err != nil {
        return ""
    }
    getval := res.getvalue()
    return getval 
}

所以我在这里在我的 http 服务器主菜单中创建一个上下文，并继续传递它。我这样做是因为如果我删除界面并将所有内容放入主文件中，它就会起作用。

我还尝试在http处理程序中创建上下文并将其传递给getter，并且我还尝试在getter本身中创建它。

我认为正确的方法是使用请求创建的上下文在http请求中创建上下文，然后将其传递给grpc getter。像这样：

func (s *Service) getHandler(rw http.ResponseWriter, r *http.Request) {   

    // Create it like such
    ctx, cancel := context.WithTimeout(r.Context(), 100*time.Second)

    key := r.URL.Query()["key"][0]
    // And pass it onwards (of course we need to change function signature for this to work)
    res := s.sg.Getter(ctx, key)
    fmt.Fprintf(rw, "Successfully got value: %s\n", res)
}

那么我应该如何在这里创建上下文，才不会出现这些错误？

解决方案

如果您的目标是让长时间运行的任务在后台运行，且在请求完成后不会取消，则不要使用请求的上下文。请改用 context.background()。

例如：

func (s *Service) getHandler(rw http.ResponseWriter, r *http.Request) {   
    ctx, cancel := context.WithTimeout(context.Background(), 100*time.Second)
    // ...

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。