protobuf及grpc的client请求
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了protobuf及grpc的client请求相关的知识，希望对你有一定的参考价值。
参考技术A 背景：
需要对rpc服务进行压测，需要构造rpc请求。
protobuf 简介
Protocol Buffer (简称Protobuf) 是Google出品的性能优异、跨语言、跨平台的序列化库。
文档结构
protobuf 使用 .proto 文件来保存文档。
定义消息
protobuf使用message定义消息，例如：
AlgPluginObject消息定义了三个字段，分别为插件名称，U0ID及插件方法。
消息定义中的每个字段都有唯一的编号。 这些字段编号用于以消息二进制格式标识字段，并且在使用消息类型后不应更改
定义服务
定义RPC方法，需要使用service关键字定义服务，并在里面定义方法。
此处定义了一个AlgReportPush服务，包含两个rpc方法：
下面针对上面的proto文件，写一个grpc client 进行rpc请求。
教你使用ProtoBuf，通过gRPC服务在Android上进行网络请求
教你如何使用ProtoBuf，通过gRPC服务在android上进行网络请求。
https://github.com/xuexiangjys/Protobuf-gRPC-Android
简介
ProtoBuf
google公司发布的一套开源编码规则，基于二进制流的序列化传输，可以转换成多种编程语言，几乎涵盖了市面上所有的主流编程语言，是目前公认的非常高效的序列化技术。
ProtoBuf的Github主页：
https://github.com/protocolbuffers/protobuf
gRPC
gRPC是一个高性能、开源和通用的RPC框架，面向移动和HTTP/2设计。目前提供C、Java和Go语言版本，分别是grpc、grpc-java、grpc-go。gRPC基于HTTP/2标准设计，带来诸如双向流、流控、头部压缩、单TCP连接上的多复用请求等特性。这些特性使得其在移动设备上表现更好，更省电和节省空间占用。gRPC由google开发，是一款语言中立、平台中立、开源的远程过程调用系统。
gRPC(Java)的Github主页：
https://github.com/grpc/grpc-java
为什么要使用ProtoBuf和gRPC
简而言之，ProtoBuf就好比信息传输的媒介，类似我们常用的json，而grpc则是传输他们的通道，类似我们常用的socket。
ProtoBuf和json
如果用一句话来概括ProtoBuf和JSON的区别的话，那就是：对于较多信息存储的大文件而言，ProtoBuf的写入和解析效率明显高很多，而JSON格式的可读性明显要好。网上有一段数据用以对此ProtoBuf和JSON之间的性能差异：
JSON
总共写65535条Data记录到文件中，测试结果如下：
生成的文件尺寸是23,733k。
生成文件的时间是12.80秒。
从该文件中解析的时间是11.50秒。
ProtoBuf
总共写65535条Data记录到文件中，测试结果如下：
生成的文件尺寸是3760k。
生成文件的时间是0.08秒。
从该文件中解析的时间是0.07秒。
gRPC
作为google公司极力推荐的分布式网络架构，基于HTTP2.0标准设计，使用用ProtoBuf作为序列化工具，在移动设备上表现更好，更省电和节省空间占用。google出品，品质值得信赖。
如何使用
像这种国外的开源框架，还是建议大家先直接阅读官方文档，再看国内的文章，这样才不容易被误导。
官方教程:
https://grpc.io/docs/quickstart/android.html
官方示例:
https://github.com/grpc/grpc-java/tree/master/examples/android
环境配置
1.首先需要下载安装Protobuf Support插件，如下图：
2.在项目的根目录的 build.gradle 的 buildscript中加入 protobuf-gradle-plugin插件：
buildscript {
...
dependencies {
...
classpath "com.google.protobuf:protobuf-gradle-plugin:0.8.6"
}
}
3.然后在应用Module的 build.gradle 中进行如下配置
apply plugin: 'com.android.application'
apply plugin: 'com.google.protobuf' //引用protobuf-gradle-plugin插件
android {
...
lintOptions {
abortOnError false
disable 'GoogleAppIndexingWarning', 'HardcodedText', 'InvalidPackage'
textReport true
textOutput "stdout"
}
}
protobuf {
protoc { artifact = 'com.google.protobuf:protoc:3.6.1' }
plugins {
javalite { artifact = "com.google.protobuf:protoc-gen-javalite:3.0.0" }
grpc { artifact = 'io.grpc:protoc-gen-grpc-java:1.19.0' // CURRENT_GRPC_VERSION
}
}
generateProtoTasks {
all().each { task ->
task.plugins {
javalite {}
grpc { // Options added to --grpc_out
option 'lite' }
}
}
}
}
dependencies {
//protobuf
implementation 'io.grpc:grpc-okhttp:1.19.0'
implementation 'io.grpc:grpc-protobuf-lite:1.19.0'
implementation 'io.grpc:grpc-stub:1.19.0'
implementation 'javax.annotation:javax.annotation-api:1.2'
}
4.最后将你 .proto协议文件放至 src/main/proto/文件夹下，点击build进行编译，如果出现如下图，则证明环境配置成功！
普通请求
在测试demo中的请求前，请务必先运行服务端的代码。
1.构建Channel
/**
* 构建一条普通的Channel
*
* @param port 端口
* @return
*/
public static ManagedChannel newChannel(String host, int port) {
return ManagedChannelBuilder.forAddress(host, port)
.usePlaintext()
.build();
}
2.构建服务请求API代理
//构建通道
final ManagedChannel channel = gRPCChannelUtils.newChannel(host, port);
//构建服务api代理
mStub = GreeterGrpc.newStub(channel);
3.构建请求实体
//HelloRequest是自动生成的实体类
HelloRequest request = HelloRequest.newBuilder().setName(message).build();
4.执行请求
//进行请求
mStub.sayHello(request, new SimpleStreamObserver<HelloReply>() {
@Override
protected void onSuccess(HelloReply value) {
tvGrpcResponse.setText(value.getMessage());
btnSend.setEnabled(true);
}
@MainThread
@Override
public void onError(Throwable t) {
super.onError(t);
tvGrpcResponse.setText(Log.getStackTraceString(t));
btnSend.setEnabled(true);
}
@Override
public void onCompleted() {
super.onCompleted();
gRPCChannelUtils.shutdown(channel); //关闭通道
}
});
Https请求
与普通请求相比，就在第一步建立通道有所不同，需要设置CA证书，其他步骤都相同。
/**
* 构建一条SSLChannel
*
* @param port 端口
* @param authority 域名
* @param certificates 证书
* @return
*/
public static ManagedChannel newSSLChannel(String host, int port, String authority, InputStream... certificates) {
HttpsUtils.SSLParams sslParams = HttpsUtils.getSslSocketFactory(certificates);
return OkHttpChannelBuilder.forAddress(host, port)
//overrideAuthority非常重要，必须设置调用
.overrideAuthority(authority)
.sslSocketFactory(sslParams.sSLSocketFactory)
.build();
}
联系方式
微信公众号
以上是关于protobuf及grpc的client请求的主要内容，如果未能解决你的问题，请参考以下文章
go+protobuf+grpc+consul简单的服务发现模型
教你使用ProtoBuf，通过gRPC服务在Android上进行网络请求