当前位置：首页 > news >正文

grpc 哼哈二将，你值得拥有

news 2025/10/21 23:20:16

kong网关转发http服务，各大博主都已经聊包浆了。
kong网关原生支持代理gRPC请求，本文通过一个示例来记录通过kong网关管理gRPC服务，并且使用grpcbin和grpcurl哼哈二将来模拟和验证grpc服务能力。

kong网关核心的控制面实体：

service ：上游服务的抽象
route ：客户端请求被分流的规则
upstream （+ target）：支持负载均衡、健康检查
consumer：用于标识使用API服务的外部客户端，一般需要结合plugins来识别

我们首先忽略网关，搭建一个grpc点对点服务调用。

1. grpc点对点

grpc 是基于http2的高性能rpc框架，根据http2是否启用TLS演化出grpc和grpcs

docker run -it -d --rm -p 9000:9000 -p 9001:9001 moul/grpcbin
启动了grpc服务，占用端口9000和9001：

2025/10/21 06:21:09 listening on :9000 (insecure gRPC)
2025/10/21 06:21:09 listening on :9001 (secure gRPC + secure HTTP/2)

安装grpcurl，访问grpc服务：

grpcurl -v -d '{"greeting": "Kong!"}' \-plaintext localhost:9000 hello.HelloService.SayHello    或grpcurl -v -d '{"greeting": "Kong!"}' \-insecure localhost:9001 hello.HelloService.SayHello

参数解释如下：

plaintext: Use plain-text HTTP/2 when connecting to server (no TLS)

insecure： Skip server certificate and domain verification. (NOT SECURE!) Not
valid with -plaintext option.

grpc点对点的结果如下：

1.1 grpc over http2

客户端创建grpc通道，内部会创建到服务器的HTTP/2连接，通道创建完后，就可以重用连接来发送多个到服务端的远程调用（多路复用），这些远程调用会映射为HTTP/2中的流，远程调用中的消息以HTTP/2帧的形式进行发送，帧可能会携带一条gRPC 长度前缀的消息，也可能在 gRPC消息非常大的情况下，一条消息跨多帧。

简单的grpc一元调用形成的HTTP2帧序列：

1.2 gRPC 服务反射协议

你还可以使用

grpcurl -plaintext localhost:9000 list 查看所有grpc服务
grpcurl -plaintext localhost:9000 describe hello.HelloService.SayHello 查看某一个grpc服务接口
grpcurl -plaintext localhost:9000 describe .hello.HelloRequest 查看类型信息

这依托于gRPC服务反射协议：注册了一个服务（列出服务器上注册的grpc服务和方法）。btw既然网关做grpc反向代理，以上可换成网关服务地址。

listener, err := net.Listen("tcp", *insecureAddr)if err != nil {log.Fatalf("failted to listen: %v", err)}// create gRPC servers := grpc.NewServer()grpcbinpb.RegisterGRPCBinServer(s, &grpcbinhandler.Handler{})hellopb.RegisterHelloServiceServer(s, &hellohandler.Handler{})addsvcpb.RegisterAddServer(s, &addsvchandler.Handler{})abepb.RegisterABitOfEverythingServiceServer(s, abehandler.NewHandler())// register reflection service on gRPC serverreflection.Register(s)// servelog.Printf("listening on %s (insecure gRPC)\n", *insecureAddr)if err := s.Serve(listener); err != nil {log.Fatalf("failed to serve: %v", err)}