grpc-源码-网络模型

golang 的grpc库是

在杨浦等地区，都构建了全面的区域性战略布局，加强发展的系统性、市场前瞻性、产品创新能力，以专注、极致的服务理念，为客户提供成都网站设计、成都做网站 网站设计制作按需设计网站,公司网站建设,企业网站建设,成都品牌网站建设,营销型网站,外贸网站建设,杨浦网站建设费用合理。

grpc server端和服务端网络协议是在tcp基础上的 http2协议，http2协议负责grpc基础的数据传输、连接管理、流控等， 具体的业务层service 定义是基于 protobuf的

整个的网络过程和关键点如下图

说明：

TCP KeepAlive则是为了探测/保鲜（心跳检测，连接错误检测）：用于探测对端的状态及网络情况(有可能客户端崩溃、强制关闭了应用、主机不可达等等)，也有保鲜功能。比如如防止nat超时。TCP keepalive则是通过发送发送侦测包实现。在Linux中通过net.ipv4.tcp_keepalive_intvl，net.ipv4.tcp_keepalive_probes，net.ipv4.tcp_keepalive_time配置。比如gnet 网络框架中的实现

gRPC服务开发和接口测试初探「Go」

之前写过了Grpc服务开发和接口测试初探【Java】，中间耽搁了一些时间，Go版本的gRPC测试开发实践才有时间学习使用。其中也是由于自己Go语言不够熟悉导致的。之前有段时间想暂时放弃Go语言的学习，导致了Go的生疏，原因是从Groovy到Java性能。

回归正题，Go语言版本的gRPC实践相对Java来说是比较简单的，但是总体的工具链是比较复杂的，可能是因为Go生态目前相比Java还是比较匮乏吧。下面我先简述一下大致的步骤：

以上步骤亲自操作可能会遇到一些小问题，我本人搜到的教程什么的也是乱七八糟，踩了一些坑。我没有整理出一个亲自实践之后的可行的教程，原因有二：

Go语言的gRPC的 proto 编写跟Java大致一致，只有一个报名的参数不太一样。下面是我的 Hello.proto 内容：

这里主要 go_package 网上搜到的配置方式有些不一样，我没有全都尝试，大家在搜索的资料时候，尽量先看看 syntax 这个参数的值，以及文章教程写作的时间，如果距离现在太久了，我建议直接关掉。搜索引擎有过滤功能，可以过滤掉过时的教程。

这里Go语言gRPC的一点优势，就是在一个项目中即可实现，Java需要先弄一个SDK这样。Go语言的gRPC的代码可以通过生成代码命令中的参数实现指定路径。我是放在了和 proto 文件的同级目录。

服务端代码也是比较格式化的内容，如下：

其中 pb.RegisterHelloServiceServer(s, Ser{}) 如果报错，请检查自己安装的工具 protoc-gen-go 或者 protoc-gen-gofast 版本，一般提取报错 message 搜索也能得到解决办法。

下面是客户端的代码，由于学艺不精，其中大部分参数的含义目前我也不是很清楚，特别是基于 stream 的请求响应的方式使用。后面我先把Java的学完，再回过头来看Go的，按照这个顺序学习和分享。

服务端输出：

忘记打日志了。没有输出

客户端输出：

Go语言的gRPC测试开发实践已经完事儿，大概率上我不会在工作中使用Go作为主力gRPC测试语言，后面测试实践内容还是会以Java为主。

golang channel 超时如何处理

个人理解的channel超时处理思路分享，若有错误或者不足，请联系我:qq 869329877

主程序通过go timeout(）挂起一个协程，在timeout方法里面利用select来监控逻辑处理的变化，如果请求时间过长或者连接到其他服务比如grpc、mysql等服务中断导致的请求时间过长，则直接超时，超时要返回定义的管道数据结果，否则程序会报错。

GRPC负载均衡

负载均衡是高可用网络基础架构的关键组件，通常用于将工作负载分布到多个服务器来提高应用的性能和可靠性。

关于GRPC的负载均衡，我们选择NGINX来进行反向代理。NGINX在1.13.9版本已经开始支持GRPC代理。有了对 GRPC 的支持，NGINX 就可以代理 GRPC TCP 连接，还可以终止、检查和跟踪 GRPC 的方法调用。

在nginx的配置文件中配置GRPC代理即可。

通过grpc 调用代理端口

观察NGINX的access.log，可以看到相应的代理记录

首先GRPC是建立在HTTP2.0的基础上进行数据传输，HTTP2.0的优势就不用多说了。因此NGINX负载均衡同样也是建立在HTTP2.0的基础之上。并且NGINX新增了GRPC模块。用于负载GRPC请求。

需要注意以下几个NGINX的参数配置：

nginx_http2模块

http2_max_requests：在一个tcp连接上默认通过的最大数据包数，默认1000个

http2_max_concurrent_streams：在一个tcp连接上默认最大并发流，默认128个

nginx_grpc模块

grpc_send_timeout：将请求传输到gRPC服务器的超时时间，如果超过这个时间，NGINX会断开连接。

grpc_read_timeout：接收gRPC服务器数据的超时时间，如果超过这个时间，NGINX会断开连接。

grpc_socket_keepalive：NGINX与gRPC服务器长连接配置设置。