gRPC 知识点备忘录（持续更新） - 熊喵君的博客

0x00 前言

本篇文章主要记录在使用 gRPC 中的一些收获及容易混淆的知识点。

0x01 原理篇

0x02 应用篇

关于 context 的问题

RPC 方法的第一个参数 ctx context.Context 中，到底存储了什么？以下面的 SayHello 为例：

// SayHello implements helloworld.GreeterServer
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
    // 服务端尝试接收 metadata 数据
    fmt.Println("ctx=",ctx)
    md, ok := metadata.FromIncomingContext(ctx)
    if !ok {
            fmt.Printf("get metadata error")
    }else{
            fmt.Println("metadata=",md)
    }
    if t, ok := md["timestamp"]; ok {
            fmt.Printf("timestamp from metadata:\n")
            for i, e := range t {
                    fmt.Printf("%d. %s\n", i, e)
            }
    }
    return &pb.HelloReply{Message: "Hello" + in.Name}, nil
}

这段代码输出的结果如下：

ctx= context.Background.WithCancel.WithValue(peer.peerKey{}, &peer.Peer{Addr:(*net.TCPAddr)(0xc0000fc1e0), AuthInfo:credentials.AuthInfo(nil)}).WithValue(metadata.mdIncomingKey{}, metadata.MD{":authority":[]string{"127.0.0.1:50001"}, "content-type":[]string{"application/grpc"}, "timestamp":[]string{"Jun  9 01:35:01.069962038"}, "user-agent":[]string{"grpc-go/1.27.0-dev"}}).WithValue(grpc.streamKey{}, <stream: 0xc000142000, /proto.Greeter/SayHello>)
metadata= map[:authority:[127.0.0.1:50001] content-type:[application/grpc] timestamp:[Jun  9 01:35:01.069962038] user-agent:[grpc-go/1.27.0-dev]]
timestamp from metadata:
 0. Jun  9 01:35:01.069962038

按照 ctx 的结果来画下继承关系（注意：紫色的位置是当前打印的 ctx 所处于的位置），由于可以向上查找，所以 metadata.FromIncomingContext(ctx) 可以查找到上一级 metadata.mdIncomingKey{} 对应的 Value 值：

再看看 metadata.FromIncomingContext(ctx) 的实现，其中 gRPC 封装了取 mdIncomingKey{}Value 的接口给到用户（mdIncomingKey{} 开头是小写，用户无法直接调用）：

type mdIncomingKey struct{}

func FromIncomingContext(ctx context.Context) (md MD, ok bool) {
        // 似曾相识
	md, ok = ctx.Value(mdIncomingKey{}).(MD)
	return
}

0x03 参考

从实践到原理，带你参透 gRPC

FEATURED TAGS

Latex gRPC 负载均衡 OpenSSH Authentication Consul Etcd Kubernetes 性能优化 Python 分布式锁 WebConsole 后台开发 Golang OpenSource Nginx Vault 网络安全 Perl 分布式理论 Raft 正则表达式 Redis 分布式限流 go-redis 微服务反向代理 ReverseProxy Cache 缓存连接池 OpenTracing GOMAXPROCS GoMicro 微服务框架日志 zap Pool Kratos Hystrix 熔断并发 Pipeline 证书 Prometheus Metrics PromQL Breaker 定时器 Timer Timeout Kafka Xorm MySQL Fasthttp bytebufferpool 任务队列队列异步队列 GOIM Pprof errgroup consistent-hash Zinx 网络框架设计模式 HTTP Gateway Queue Docker 网关 Statefulset NFS Machinery Teleport Zero Trust Oxy 存储 Confd 热更新 OAuth SAML OpenID Openssl AES 微服务网关 IM KMS 安全数据结构 hashtable Sort Asynq 基数树 Radix Crontab 热重启系统编程 sarama Go-Zero RDP VNC 协程池 UDP hashmap 网络编程自适应技术环形队列 Ring Buffer Circular Buffer InnoDB timewheel GroupCache Jaeger GOSSIP CAP Bash websocket 事务 GC TLS singleflight 闭包 Helm network iptables MITM HTTPS Tap Tun 路由 wireguard gvisor Git NAT 协议栈 Envoy FRP DPI gopacket Cgroup Namespace DNS eBPF GoZero Gost Clash gopsutil HIDS ELKEID XDP TC Linux

FRIENDS

Apple Developer