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 参考
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
微服务框架
日志
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
DNS
eBPF
GoZero
Gost
gopsutil
HIDS
ELKEID
XDP
TC