Golang中Grpc http2Server为何要使用context.Background()?

Golang中Grpc http2Server为何要使用context.Background()? 为什么服务器请求上下文不是从用户提供的上下文派生而来? 相反,它在这里被私有地创建为 context.Background(): …/go/pkg/mod/google.golang.org/grpc@v1.27.0/internal/transport/http2_server.go:219

	t := &http2Server{
		ctx:               context.Background(),
		done:              done,
		conn:              conn,
		remoteAddr:        conn.RemoteAddr()
         ...

更多关于Golang中Grpc http2Server为何要使用context.Background()?的实战教程也可以访问 https://www.itying.com/category-94-b0.html

1 回复

更多关于Golang中Grpc http2Server为何要使用context.Background()?的实战系列教程也可以访问 https://www.itying.com/category-94-b0.html


在gRPC的HTTP/2服务器实现中,使用context.Background()作为基础上下文是设计上的有意选择,主要原因如下:

  1. 生命周期管理http2Server结构体代表一个持久的HTTP/2连接,其生命周期独立于单个RPC调用。使用context.Background()确保连接级别的上下文不会被单个请求的取消或超时影响。

  2. 连接级别操作:这个上下文用于管理连接级别的操作(如流控制、连接保持、关闭等),而不是处理具体的RPC请求。每个具体的RPC请求会从这个基础上下文派生自己的子上下文。

  3. 资源清理:当连接关闭时,这个基础上下文可以用于协调所有相关资源的清理工作。

示例代码展示这种分层结构:

// 连接级别的上下文(持久存在)
type http2Server struct {
    ctx context.Context
    // ... 其他字段
}

// 处理单个RPC请求时,会创建请求特定的上下文
func (t *http2Server) HandleStream(stream *http2.Stream) {
    // 从连接上下文派生请求上下文
    ctx := metadata.NewIncomingContext(t.ctx, stream.Header())
    
    // 设置请求超时(如果有)
    if timeout := stream.Header().Get("grpc-timeout"); timeout != "" {
        var cancel context.CancelFunc
        ctx, cancel = context.WithTimeout(ctx, parseTimeout(timeout))
        defer cancel()
    }
    
    // 处理RPC请求
    handleRPC(ctx, stream)
}

// 初始化http2Server时使用Background上下文
func newHTTP2Server(conn net.Conn) *http2Server {
    return &http2Server{
        ctx:        context.Background(), // 连接级别上下文
        conn:       conn,
        remoteAddr: conn.RemoteAddr(),
        // ... 其他初始化
    }
}

每个RPC请求实际上会通过processStream方法创建自己的上下文:

func (t *http2Server) processStream(stream *http2.Stream) error {
    // 创建请求特定的上下文
    ctx := t.newContextWithStream(stream)
    
    // 应用服务器拦截器(如果有)
    ctx = t.applyServerInterceptors(ctx)
    
    // 处理请求
    return t.handleRPC(ctx, stream)
}

func (t *http2Server) newContextWithStream(stream *http2.Stream) context.Context {
    // 从Background派生,但添加stream特定信息
    ctx := context.WithValue(t.ctx, streamKey{}, stream)
    ctx = context.WithValue(ctx, localAddrKey{}, t.conn.LocalAddr())
    ctx = context.WithValue(ctx, remoteAddrKey{}, t.conn.RemoteAddr())
    return ctx
}

这种设计确保了连接级别的操作和请求级别的操作有清晰的上下文分离,避免了单个请求的取消影响整个连接。

回到顶部