微服务开发手册之GRPC

时间：2020-05-20 11:59:55 阅读：79 评论：0 收藏：0 [点我收藏+]

标签：透传中文中文版 header attr 查看框架 params simple

> GRPC是一个高性能、通用的开源RPC框架，基于HTTP/2协议标准和Protobuf序列化协议开发，支持众多的开发语言。

@[TOC]

1 简介

在GRPC框架中，客户端可以像调用本地对象一样直接调用位于不同机器的服务端方法，如此我们就可以非常方便的创建一些分布式的应用服务。

在服务端，我们实现了所定义的服务和可供远程调用的方法，运行一个gRPC server来处理客户端的请求；在客户端，gRPC实现了一个stub（可以简单理解为一个client），其提供跟服务端相同的方法。技术图片 gRPC使用protocol buffers作为接口描述语言（IDL）以及底层的信息交换格式，一般情况下推荐使用 proto3因为其能够支持更多的语言，并减少一些兼容性的问题。由于gRPC涉及到几个比较重要的技术点http2、protobuf，正是这几个技术点才使得gRPC得到广泛应用，这里也顺带讲一下这几个技术点

1.1 http2

HTTP/2是最新的HTTP协议，提高了资源访问效率。通过本篇科普小文，可以了解HTTP/2协议的概念以及优势。

HTTP/2也被称为HTTP 2.0，相对于HTTP 1.1新增多路复用、压缩HTTP头、划分请求优先级、服务端推送等特性，解决了在HTTP 1.1中一直存在的问题，优化了请求性能，同时兼容了HTTP 1.1的语义。

2015年，HTTP/2 发布。HTTP/2是现行HTTP协议（HTTP/1.1）的替代，但它不是重写，HTTP方法、状态码、语义都与HTTP/1.1一样。HTTP/2 相比于 HTTP/1.1，可以说是大幅度提高了网页的性能，只需要升级到该协议就可以减少很多之前需要做的性能优化工作。HTTP/2基于SPDY，专注于性能，最大的一个目标是在用户和网站间只用一个连接（connection）。

HTTP/2新特性

1.1.1二进制传输

HTTP/2传输数据量的大幅减少,主要有两个原因:以二进制方式传输和Header 压缩。先来介绍一下二进制传输,HTTP/2 采用二进制格式传输数据，而非HTTP/1.1 里纯文本形式的报文，二进制协议解析起来更高效。HTTP/2 将请求和响应数据分割为更小的帧，并且它们采用二进制编码。HTTP/2所有性能增强的核心在于新的二进制分帧层，它定义了如何封装http消息并在客户端与服务器之间传输。

1.1.2 Header压缩

HTTP/1.1的header带有大量信息，而且每次都要重复发送，HTTP/2并没有使用传统的压缩算法，而是开发了专门的“HPACK”算法，在客户端和服务器两端建立“字典”，用索引号表示重复的字符串，还采用哈夫曼编码来压缩整数和字符串，可以达到50%~90%的高压缩率。

1.1.3 多路复用

多路复用允许同时通过单一的HTTP/2连接发起多重的请求-响应信息，很好的解决了浏览器限制同一个域名下的请求数量的问题，同时也更容易实现全速传输。

1.1.4 服务器推送

HTTP2还在一定程度上改变了传统的“请求-应答”工作模式，服务器不再是完全被动地响应请求，也可以新建“流”主动向客户端发送消息。比如，在浏览器刚请求HTML的时候就提前把可能会用到的JS、CSS文件发给客户端，减少等待的延迟，这被称为”服务器推送”（ Server Push，也叫 Cache push）。

1.2 Protobuf

Protocol buffers 是一种语言中立，平台无关，可扩展的序列化数据的格式，可用于通信协议，数据存储等。

Protocol buffers 在序列化数据方面，它是灵活的，高效的。相比于 XML 来说，Protocol buffers 更加小巧，更加快速，更加简单。一旦定义了要处理的数据的数据结构之后，就可以利用 Protocol buffers 的代码生成工具生成相关的代码。甚至可以在无需重新部署程序的情况下更新数据结构。只需使用 Protobuf 对数据结构进行一次描述，即可利用各种不同语言或从各种不同数据流中对你的结构化数据轻松读写。

Protocol buffers 很适合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列化结构数据格式。

1.2.1 优点

1、性能好/效率高

时间开销： XML格式化（序列化）的开销还好；但是XML解析（反序列化）的开销就不敢恭维了。但是protobuf在这个方面就进行了优化。可以使序列化和反序列化的时间开销都减短。

空间开销：也减少了很多

2、有代码生成机制

比如你你写个一下类似结构体的内容


 message testA  
{  
    required int32 m_testA = 1;  
}

像写一个这样的结构，protobuf可以自动生成它的.h 文件和点.cpp文件。 protobuf将对结构体testA的操作封装成一个类。

3、支持向后兼容和向前兼容

当客户端和服务器同事使用一块协议的时候，当客户端在协议中增加一个字节，并不会影响客户端的使用

4、支持多种编程语言

在Google官方发布的源代码中包含了c++、java、Python三种语言

1.2.2 缺点

1、二进制格式导致可读性差

为了提高性能，protobuf采用了二进制格式进行编码。这直接导致了可读性差。这个直接影响开发测试时候的效率。当然，一般情况下，protobuf非常可靠，并不会出现太大的问题。

2、缺乏自描述

一般来说，XML是自描述的，而protobuf格式则不是。给你一段二进制格式的协议内容，不配合你写的结构体是看不出来什么作用的。

3、通用性差

protobuf虽然支持了大量语言的序列化和反序列化，但仍然并不是一个跨平台和语言的传输标准。在多平台消息传递中，对其他项目的兼容性并不是很好，需要做相应的适配改造工作。相比json 和 XML，通用性还是没那么好。

1.2.3 与其他序列化方式对比

protobuf处理整型特别快，如果需要了解原理可以查看高效的数据压缩编码方式 Protobuf

至于与其他序列化方式以及使用场景的对比可以参考下面的文章 Protobuf有没有比JSON快5倍？用代码来击破pb性能神话

全方位评测：Protobuf性能到底有没有比JSON快5倍？

2 grpc四种模式

1，简单模式：简单模式只是使用参数和返回值作为服务器与客户端传递数据的方式，最简单。

2，客户端流模式：即从客户端往服务器端发送数据使用的是流，即服务器端的参数为流类型，然而在服务器相应后返还数据给客户端，使用的也是流的send方法。一般在服务器端的代码，需要先recv再send，而客户端与此相反。但是在后面的双向模式中可以使用go的协程协作。

3，服务器端流模式：即服务器端返回结果的时候使用的是流模式，即传入的数据是通过参数形式传入的。但是在往客户端发送数据时使用send方法，与客户端返回数据的方式大同小异。

4，双向模式：客户端如果不适用协程，那么发送必须在接收之前。如果使用协程，发送与接收并没有先后顺序。为了保证协程的同步，可以使用互斥量进行约束。

如果想要了解详细demo，可以查看gRPC 官方文档中文版

3 集成springcloud

这里集成grpc建议有两种方案，

3.1 实现公共protobuf，通过java grpc来远程调用

这个方案就是不用编写protobuf了，可以直接类似dubbo一样提供java api就可以实现rpc调用，这里详情可以参考github上的demo ttps://github.com/ChinaSilence/spring-boot-starter-grpc

技术图片

facade：独立的 Maven 模块，依赖 spring-boot-www.yixingylzc.cn starter-grpc，需要远程调用的方法，都定义在此模块，形式可以为接口(interface) 或者抽象类(abstract www.lanboyulezc.cn class)
server：服务提供方，依赖 facade 模块，需实现 facade 模块定义的接口或者抽象类的抽象方法
client：服务调用方，依赖 facade 模块，使用时，直接调用即可

优缺点分析

优点：

不需要编写probuff文件，以java api形式来定义接口
不依赖于eureka，完美适用于k8s

缺点：

只支持java，如果要支持异构语言需要使用springcloudsidecar 或者手动注册到eureka
eureka支持有限，不支持负载均衡

3.2 每次使用protobuf定义接口（集成net.devh.grpc）

这里内容还比较多，详情可以参考我的博客 springcloud集成grpc（百事2:www.baihuayl7.cn）这种方式集成每次都需要编写proto接口文件并自动生成代码，客户端和服务端都需要另外组装参数。

不过优势是，有详细的接口规范（protobuf），并且可以支持异构语言调用。

后面会介绍只有java语言调用，但是不用每次都编写proto文件的集成方式。

4 服务发现与负载均衡

gRPC开源组件官方并未直接提供服务注册与发现的功能实现，但其设计文档已提供实现的思路，并在不同语言的gRPC代码API中已提供了命名解析和负载均衡接口供扩展。

其基本实现原理：

服务启动后gRPC客户端向命名服务器发出名称解析请求，名称将解析为一个或多个IP地址，每个IP地址标示它是服务器地址还是负载均衡器地址，以及标示要使用那个客户端负载均衡策略或服务配置。

客户端实例化负载均衡策略，如果解析返回的地址是负载均衡器地址，则客户端将使用grpclb策略，否则客户端使用服务配置请求的负载均衡策略。

负载均衡策略为每个服务器地址创建一个子通道（channel）。

当有rpc请求时，负载均衡策略决定那个子通道即grpc服务器将接收请求，当可用服务器为空时客户端的请求将被阻塞。根据gRPC官方提供的设计思路，基于进程内LB方案（即第2个案，阿里开源的服务框架 Dubbo 也是采用类似机制），结合分布式一致的组件（如Zookeeper、Consul、Etcd），可找到gRPC服务发现和负载均衡的可行解决方案。接下来以GO语言为例，简单介绍下基于Etcd3的关键代码实现：

4.1 dubbo

上面有描述，dubbo支持grpc，方案类似本文3.1提出的方案，不过是阿里提供了一整套微服务体系，包括注册中心nacas、dubbo、sentinel都支持grpc

4.2 springcloud

这个方案同样是类似3.2章，上面是集成了net.devh.www.shbkrcxzz.cn grpc，该插件最新版本，同样支持springcloud全家桶，详细可以参考github： https://github.com/yidongnan/grpc-spring-boot-starter。如果是异构语言则需要集成springcloud中的sidecar来实现服务发现，这里也仅仅是支持java调用其他异构语言，如果需要其他语言也支持相互调用，则需要对应语言按照开源组件官方说的方案二来实现相应组件

4.3 istio

Istio是什么：Istio是Google/IBM/Lyft联合开发的开源项目，2017年5月发布第一个release 0.1.0，官方定义为:

Istio：一个连接，管理和保护微服务的开放平台。

按照isito文档中给出的定义:

Istio提供一种简单的方式来建立已部署的服务的网络，具备负载均衡，服务到服务认证，监控等等功能，而不需要改动任何服务代码。

简单的说，有了Istio，你的服务就不再需要任何微服务开发框架（典型如Spring Cloud，Dubbo），也不再需要自己动手实现各种复杂的服务治理的功能（很多是Spring Cloud和Dubbo也不能提供的，需要自己动手）。只要服务的客户端和服务器可以进行简单的直接网络访问，就可以通过将网络层委托给Istio，从而获得一系列的完备功能。 Istio的关键功能:

HTTP/1.1，www.lanboylpt.cn HTTP/2，gRPC和TCP流量的自动区域感知负载平衡和故障切换。
通过丰富的路由规则，容错和故障注入，对流行为的细粒度控制。
支持访问控制，速率限制和配额的可插拔策略层和配置API。
集群内所有流量的自动量度，日志和跟踪，包括集群入口和出口。
安全的服务到服务身份验证，在集群中的服务之间具有强大的身份标识。

可以近似的理解为：Istio = 微服务框架 + 服务治理以下是 Istio 的官方拓扑图：技术图片这里的前提是使用了k8s，在k8s中可以无缝集成istio。具体操作步骤我这里不做详细描述，详情可以参考下面链接使用Istio和Envoy实践服务网格gRPC度量

5 grpc之拦截器

grpc自带认证，不过有时候也需要在调用前，或者调用后做一些操作，比如说记录监控信息、或者透传header等等，这时就需要用到grpc的拦截器，这里仅以java语言来说一下拦截器用法。

5.1 server拦截器

public class MyServerInsterceptor implements ServerInterceptor{


    @Override
    public <reqt, respt> ServerCall.Listener<reqt> interceptCall(ServerCall<reqt, respt> call,
                                                                 Metadata headers, ServerCallHandler<reqt, respt> next) {
      
        return next.startCall(call,headers);
    }
}

这里可以设置全局拦截器

@Configuration
public class GrpcOpenConfig {

    //grpc-spring-boot-starter provides @GrpcGlobalInterceptor to allow server-side interceptors to be registered with all
    //server stubs, we are just taking advantage of that to install the server-side gRPC tracer.
    @Bean
    ServerInterceptor grpcServerInterceptor() {
        return new MyServerInterceptor();
    }

    @Bean
    public GlobalServerInterceptorConfigurer globalInterceptorConfigurerAdapter(ServerInterceptor grpcServerInterceptor) {
        return registry -&gt; registry.addServerInterceptors(grpcServerInterceptor);
    }
}

同时如果集成了grpc-spring-boot-starter，也可以使用@GrpcGlobalInterceptor来增加全局拦截器，hi需要将该注解加到类名上

5.2 client拦截器

public class MyClientInterceptor implements ClientInterceptor {


    Metadata.Key<string> token = Metadata.Key.of("token", Metadata.ASCII_STRING_MARSHALLER);

    @Override
    public <reqt, respt> ClientCall<reqt, respt> interceptCall(MethodDescriptor<reqt, respt> method,
            CallOptions callOptions, Channel next) {
        return new SimpleForwardingClientCall<reqt, respt>(next.newCall(method, callOptions)) {

            @Override
            public void start(Listener<respt> responseListener, Metadata headers) {
                //此处为你登录后获得的token的值
                headers.put(token, "A2D05E5ED2414B1F8C6AEB19F40EF77C");
                super.start(new SimpleForwardingClientCallListener<respt>(responseListener) {
                    @Override
                    public void onHeaders(Metadata headers) www.dafengyulept.com{
                        super.onHeaders(恒煊2:www.hengxuangyul.com  headers);
                    }
                }, headers);
            }
        };
    }
}

这里可以设置全局拦截器

@Order(Ordered.LOWEST_PRECEDENCE)
@Configuration
@Slf4j
public class GrpcOpenTracingConfig {
    //We also create a client-side interceptor and put that in the context, this interceptor can then be injected into gRPC clients and
    //then applied to the managed channel.
    @Bean
    ClientInterceptor grpcClientInterceptor() {
        return new MyclientInterceptor(www.jintianxuesha.com);
    }

    @Bean
    public GlobalClientInterceptorConfigurer globalInterceptorConfigurerAdapter(ClientInterceptor grpcClientInterceptor) {
        return registry -&gt; registry.addClientInterceptors(grpcClientInterceptor);
    }

}