gRPC是一种与语言无关的高性能远程过程调用 (RPC) 框架。gRPC 的主要好处是：
- 现代、高性能、轻量级的 RPC 框架。
- 契约优先的 API 开发，默认使用协议缓冲区，与语言无关的实现。
- 可用于多种语言的工具来生成强类型服务器和客户端。
- 支持客户端、服务器和双向流调用。
- 通过 Protobuf 二进制序列化减少网络使用。
这些优势使 gRPC 非常适合：
- 效率至关重要的轻量级微服务。
- 需要多种语言进行开发的多语言系统。
- 需要处理流请求或响应的点对点实时服务。
什么是grpc-json转码器
grpc-json转码器是Envoy中的一个过滤器，它允许 RESTful JSON API 客户端通过 HTTP 向 Envoy 发送请求并代理到 gRPC 服务。
大家可以参考envoy官方文档：https://www.envoyproxy.io/docs/envoy/latest/configuration/http/http_filters/grpc_json_transcoder_filter
下面我们来通过Envoy的grpc-json转码器实现grpc服务的代理。
创建grpc服务
.NET中的grpc可以参考官方文档来实现。我们通过vs创建两个默认的grpc server：GrpcService1与GrpcService2，来实现grpc的负载。
我们需要基于默认Grpc模板项目做出以下修改
- 固定Grpc的端口，修改GrpcService1的默认端口为6001
- 固定Grpc的端口，修改GrpcService2的默认端口为6002
- 为了判断是否实现负载，我们修改GrpcService1的SayHello方法返回体，让其返回字符串Hello 1
- 为了判断是否实现负载，我们修改GrpcService2的SayHello方法返回体，让其返回字符串Hello 2
public static IHostBuilder CreateHostBuilder(string[] args) =>
Host.CreateDefaultBuilder(args)
.ConfigureWebHostDefaults(webBuilder =>
{
webBuilder.UseUrls("http://*:6001").UseStartup<Startup>();
});
public static IHostBuilder CreateHostBuilder(string[] args) =>
Host.CreateDefaultBuilder(args)
.ConfigureWebHostDefaults(webBuilder =>
{
webBuilder.UseUrls("http://*:6002").UseStartup<Startup>();
});
public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
{
return Task.FromResult(new HelloReply
{
Message = "Hello 1 " request.Name
});
}
public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
{
return Task.FromResult(new HelloReply
{
Message = "Hello 2 " request.Name
});
}修改完之后我们启动两个Grpc Server
Grpc服务描述符
Envoy必须知道GRPC服务的proto描述符才能REST API转码，我们可以通过以下链接下载proto工具 https://github.com/protocolbuffers/protobuf/releases
下载完成之后，通过以下命令生成描述符，生成的描述符需要和配置文件一起挂载进容器
代码语言：javascript复制protoc.exe --descriptor_set_out=C:greet.pb --include_imports C:greet.proto --proto_path=C://配置Envoy
Grpc相关的配置可以参考官方文档，其中需要注意的是以下几点
- 我们需要将dns_type改为static，因为我们grpc用的是ip而不是域名
- 并且需要指定auto_mapping: true，这样就可以在我们没有设置http method的情况下路由到我们的grpc服务中的方法
- 指定grpc描述符，让Envoy知道grpc定义
具体配置如下
代码语言：javascript复制admin:
address:
socket_address: {address: 0.0.0.0, port_value: 9901}
static_resources:
listeners:
- name: listener1
address:
socket_address: {address: 0.0.0.0, port_value: 10000}
filter_chains:
- filters:
- name: envoy.filters.network.http_connection_manager
typed_config:
"@type": type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager
stat_prefix: grpc_json
codec_type: AUTO
route_config:
name: local_route
virtual_hosts:
- name: local_service
domains: ["*"]
routes:
- match: {prefix: "/greet.Greeter"}
route: {cluster: grpc, timeout: 60s}
http_filters:
- name: envoy.filters.http.grpc_json_transcoder
typed_config:
"@type": type.googleapis.com/envoy.extensions.filters.http.grpc_json_transcoder.v3.GrpcJsonTranscoder
proto_descriptor: "/etc/envoy/greet.pb"
services: ["greet.Greeter"]
print_options:
add_whitespace: true
always_print_primitive_fields: true
always_print_enums_as_ints: false
preserve_proto_field_names: false
auto_mapping: true
- name: envoy.filters.http.router
clusters:
- name: grpc
type: static
lb_policy: ROUND_ROBIN
dns_lookup_family: V4_ONLY
typed_extension_protocol_options:
envoy.extensions.upstreams.http.v3.HttpProtocolOptions:
"@type": type.googleapis.com/envoy.extensions.upstreams.http.v3.HttpProtocolOptions
explicit_http_config:
http2_protocol_options: {}
load_assignment:
cluster_name: grpc
endpoints:
- lb_endpoints:
- endpoint:
address:
socket_address:
address: 192.168.43.94
port_value: 6001
- endpoint:
address:
socket_address:
address: 192.168.43.94
port_value: 6002启动Envoy
需要特别注意的是，我们需要将envoy.yaml和描述文件都映射到我们的容器内
代码语言：javascript复制docker run --rm -it -p 9902:9902 -p 10000:10000 -v D:/gateway/envoy/config/grpc/:/etc/envoy/ -v D:/gateway/envoy/logs:/logs envoyproxy/envoy-dev -c /etc/envoy/envoy.yaml测试
测试的时候需要注意的是
- 转码器过滤器处理的请求路径规则是/<package>.<service>/<method>
- 我们需要使用POST方法。
通过postman调用接口来看，我们成功利用GRPC-Json转码器实现了grpc的代理，并实现了grpc的负载！！
