Envoy实现.NET架构的网关(三)代理GRPC

.NET网关与Gateway实战-Envoy与kong课程

b47860e81e9fc32bb51a33a5a03fffcb.png

  • Envoy实现.NET架构的网关(一)静态配置与文件动态配置

  • Envoy实现.NET架构的网关(二)基于控制平面的动态配置

什么是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的负载。

41381947e3dcee25e3e5a3c20986aa6e.png

我们需要基于默认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

4c882749fa06d3de7bd07a3525b11fea.png

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: listener1address:socket_address: {address: 0.0.0.0, port_value: 10000}filter_chains:- filters:- name: envoy.filters.network.http_connection_managertyped_config:"@type": type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManagerstat_prefix: grpc_jsoncodec_type: AUTOroute_config:name: local_routevirtual_hosts:- name: local_servicedomains: ["*"]routes:- match: {prefix: "/greet.Greeter"}route: {cluster: grpc, timeout: 60s}http_filters:- name: envoy.filters.http.grpc_json_transcodertyped_config:"@type": type.googleapis.com/envoy.extensions.filters.http.grpc_json_transcoder.v3.GrpcJsonTranscoderproto_descriptor: "/etc/envoy/greet.pb"services: ["greet.Greeter"]print_options:add_whitespace: truealways_print_primitive_fields: truealways_print_enums_as_ints: falsepreserve_proto_field_names: falseauto_mapping: true- name: envoy.filters.http.routerclusters:- name: grpctype: staticlb_policy: ROUND_ROBINdns_lookup_family: V4_ONLYtyped_extension_protocol_options:envoy.extensions.upstreams.http.v3.HttpProtocolOptions:"@type": type.googleapis.com/envoy.extensions.upstreams.http.v3.HttpProtocolOptionsexplicit_http_config:http2_protocol_options: {}load_assignment:cluster_name: grpcendpoints:- lb_endpoints:- endpoint:address:socket_address:address: 192.168.43.94port_value: 6001- endpoint:address:socket_address:address: 192.168.43.94port_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方法。

5df9d26c18848ebfa8bb9c11b9775ff6.png

 22335967332966b8769bedb2fb8e73a4.png

 通过postman调用接口来看,我们成功利用GRPC-Json转码器实现了grpc的代理,并实现了grpc的负载!!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/296260.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Linux 下用来查询安装包信息的RPM选项

Linux 下用来查询安装包信息的RPM选项RPM是RedHat的包管理器&#xff0c;用来安装、卸载、升级和查询基于RedHat Linux的安装包。RHEL和基于它的系统使用rpm命令来完成这些功能。AD&#xff1a;RPM是RedHat的包管理器&#xff0c;用来安装、卸载、升级和查询基于RedHat Linux的…

如何用Java讲一句话重复五遍_Java 0515 第二次课作业

import java.util.*;public class Work_01 {public static void main(String[] args) {Scanner scan new Scanner(System.in);System.out.println("上午是否合格?");String judge scan.next();//输入是否while(!"是".equals(judge)){//用equals方法判断…

一张图看懂华为计算全联接2020

全世界只有3.14 % 的人关注了爆炸吧知识END◆ 推荐阅读 ◆点击下方图片即可阅读华为邓泰华&#xff1a;让每一位开发者的智慧汇聚成全生态创新&#xff0c;共同点亮多样性计算新时代左右滑动查看更多☟

独立开发一个云(PaaS)的核心要素, Go, Go, Go!!!

最近一年的工作&#xff0c;有很大的比重在做云平台的事情&#xff0c;简单来说&#xff0c;就是为公司内用户提供一个PaaS&#xff0c;用户可以在我们的云平台上方便的将单机服务程序扩展为多实例程序&#xff0c;以平台服务化的方式对外提供。在这里简单分享一下。 首先简单说…

C# 使用Timer控件设置时间间隔

Timer 控件可以定期引发事件&#xff0c;该控件是为 Windows 窗体环境设计的。时间间隔的长度由 Interval 属性定义&#xff0c;其值以毫秒为单位。若启用了该组件&#xff0c;则每个时间间隔引发一个 Tick 事件&#xff0c;在该事件中添加要执行的代码。如图1 所示为 Timer 控…

吐血整理!近二十年全国数学联赛赛题大全,烧脑全集来啦!

1981年&#xff0c;中国数学会开始举办"全国数学联赛"&#xff0c;经过1981、1982、1983三年的实践&#xff0c;这一群众性的数学竞赛活动得到了广大中学师生欢迎&#xff0c;也得到教育行政部门、各级科学技术协会、以及社会各阶层人士的肯定和支持。"试题所涉…

组装电脑教程(转载)

组装电脑已经越来越受欢迎&#xff0c;性价比在那摆着&#xff0c;而之前品牌机引以为傲的售后服务也已经被组装机赶上&#xff0c;可以说已经没有不选组装机的理由&#xff0c;就连王思聪也是买组装电脑&#xff08;几万元土豪组装机&#xff09;。但是组装电脑对于新手却不是…

java基本类型与引用数据类型_java基本数据类型与引用数据类型总结

昨天京东笔试的一道选择题&#xff0c;被坑了。最近一直在做笔试题&#xff0c;发现自己学了两年多的java&#xff0c;三大框架什么都会&#xff0c;却连基本的拆箱装箱都忘了。昨天考的引用数据类型&#xff0c;基本数据类型都不知道。看来得好好把基础复习几遍了。总结&#…

男朋友的内裤旧了不要扔,关键时刻有大用......

1 女生没有运动内衣不用愁翻翻衣柜总有办法▼2 孩子&#xff0c;你这家庭咋这么散装呢&#xff1f;▼3 这个原地打滑的本领也是一门技术▼4 三轮车夫&#xff1a;我顶不住了......▼5 有空不仅可以一起洗澡还可以一起拉屎▼6 哟&#xff01;哥们儿&#xff0c;我来陪你啦…

基于事件驱动架构构建微服务第9部分:处理更新

原文链接&#xff1a;https://logcorner.com/building-microservices-through-event-driven-architecture-part10-handling-updates-and-deletes/在本文中&#xff0c;我将讨论如何处理事件溯源系统上的更新。在前面的步骤中&#xff0c;我将系统的所有业务变化存储为事件&…

理解离散傅立叶变换(一. 傅立叶变换的由来)

转自&#xff1a;http://blog.csdn.net/dznlong/article/details/2261150理解离散傅立叶变换&#xff08;一&#xff09;------傅立叶变换的由来关于傅立叶变换&#xff0c;无论是书本还是在网上可以很容易找到关于傅立叶变换的描述&#xff0c;但是大都是些故弄玄虚的文章&…

浅谈入行

2019独角兽企业重金招聘Python工程师标准>>> 2006年开始参加工作&#xff0c;从编码&#xff0c;到带人&#xff0c;再到设计&#xff0c;自己不知不觉也走过了许多个年头。在公司从外包&#xff0c;到国内前后也参加了十多个不同的项目&#xff0c;每年都会有一些新…

数学界再出变态神人!竟用一个比基尼方程,暴力吊打美国数学家!看完我惊了......

全世界只有3.14 % 的人关注了爆炸吧知识没时间了快上车&#xff01;最近&#xff0c;有粉丝给超模君发了一些图片。早跟你们要说&#xff0c;要好好学数学。现在好了&#xff0c;连沙发问题都不懂&#xff01;没办法&#xff0c;作为数学界屈指可数的老司机&#xff0c;是时候挺…

Envoy实现.NET架构的网关(四)集成IdentityServer4实现OAuth2认证

.NET网关与Gateway实战-Envoy与kong课程什么是OAuth2认证简单说&#xff0c;OAuth 就是一种授权机制。数据的所有者告诉系统&#xff0c;同意授权第三方应用进入系统&#xff0c;获取这些数据。系统从而产生一个短期的进入令牌&#xff08;token&#xff09;&#xff0c;用来代…

java中transferto_被朋友问到什么是零拷贝,我一脸懵逼…

前言我们的Web应用多多少少都会处理一些静态内容&#xff0c;需要先从磁盘中读取到数据&#xff0c;在不经过修改后将此数据写入到套接字&#xff0c;伪代码如下&#xff1a;read(file, tmp_buf, len);write(socket, tmp_buf, len);虽然看似简单&#xff0c;但是它的效率却不高…

20个天才般的走心设计,真是太牛了!

全世界只有3.14 % 的人关注了爆炸吧知识科技发展一日千里&#xff0c;每天都有很多实用的小物被发明出来。下面就是20个超聪明的日常小发明&#xff0c;看过后你一定也想拥有&#xff01;“页面”椅子&#xff0c;可以帮助用户调整座椅高度&#xff0c;灵感来自于书籍装上这个以…

Android拨号盘,支持T9搜索和号码搜索

之前做通讯录软件&#xff0c;其中在做拨号盘的时候一直为怎么实现T9输入烦恼&#xff0c;上网找了很多帖子&#xff0c;都没有满意的答案。不过最后终于是实现了&#xff0c;看社区内好像也有不少朋友需要&#xff0c;在此分享一下。这个是在我项目中提取出来的拨号盘案例&…

浅谈.Net异步编程的前世今生----异步函数篇(完结)

前言上一篇我们着重讲解了TPL任务并行库&#xff0c;可以看出TPL已经很符合现代API的特性&#xff1a;简洁易用。但它的不足之处在于&#xff0c;使用者难以理解程序的实际执行顺序。为了解决这些问题&#xff0c;在C# 5.0中&#xff0c;引入了新的语言特性&#xff0c;被称为异…

NSInteger,NSUInteger,NSNumber

2019独角兽企业重金招聘Python工程师标准>>> Objective-C入门教程10:数字类型&#xff08;NSInteger,NSUInteger,NSNumber&#xff09; 柳志超博客 Program Objective-C Objective-C入门教程10:数字类型&#xff08;NSInteger,NSUInteger,NSNumber&#xff09; p…

听说麦当劳,买一个雪糕就送一个男友!

1 麦当劳买雪糕免费送男友&#xff01;▼2 当90后成了家长......▼3 不要跟有鼻子的人握手可能刚刚扣过鼻屎▼4 鸟&#xff1a;别瞎玩&#xff01;快开车&#xff01;▼5 凭实力当上群主&#xff01;▼6 要是有喜欢的女生千万不要问她闺蜜的意见▼7 终于&#xff0c;我们…