什么是GRPC
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
下載完成之后，通過以下命令生成描述符，生成的描述符需要和組態檔一起掛載進容器
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定義
具體配置如下，需要注意的地方已標紅
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和描述檔案都映射到我們的容器內
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的負載！！
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/342970.html
標籤：.NET Core