惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

Y
Y Combinator Blog
The GitHub Blog
The GitHub Blog
Vercel News
Vercel News
D
DataBreaches.Net
MongoDB | Blog
MongoDB | Blog
H
Help Net Security
小众软件
小众软件
美团技术团队
T
The Blog of Author Tim Ferriss
爱范儿
爱范儿
D
Docker
Martin Fowler
Martin Fowler
大猫的无限游戏
大猫的无限游戏
博客园 - 聂微东
Blog — PlanetScale
Blog — PlanetScale
H
Hackread – Cybersecurity News, Data Breaches, AI and More
罗磊的独立博客
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
V
V2EX
S
SegmentFault 最新的问题
云风的 BLOG
云风的 BLOG
B
Blog
雷峰网
雷峰网
The Cloudflare Blog

Razeen`s Blog

Let's Encrypt 推出 Gen Y 根证书架构:揭示 Web PKI 的五大未来趋势 通过 Wi-Fi 自动备份你的 iPhone 到 Nas 管理培训感悟:从技术视角看管理之路 UPS 一拖多:保护你的 NAS 和 Linux 服务器 从影音中心到 AI 助手:我的50款 Homelab 服务清单 从SSL证书有效期将缩短到47天聊开去 部署一个自己的 Running Page 谈谈特斯拉 Model Y 用车一年的感受和费用分析 弃用 Disqus 评论,使用自建 Waline 使用 Prometheus 和 Grafana 搭建你的证书监控面板 服务器迁移记:一次磁盘换板引发的Linux分区与挂载的学习 改善信息来源, 利用 RSS 高效获取资讯 (RSShub + Reeder5 + WeWe RSS) 多种 Docker 镜像拉取解决方案与实践 App分享 | AppCleaner - Mac上的卸载神器 Azure OpenAI API 申请和使用 如何开通 OneKey 虚拟信用卡,并充值消费 如何拥有一个可长期在国内使用的国外手机号码 分享开通 ChatGPT Plus 过程 如何开通 Depay 虚拟信用卡,并充值消费 如何开通欧易Web3钱包, 交易入账 如何5分钟内1块钱注册 ChatGPT 如何注册美区的 Apple ID (2023年/无需科学上网) NAS折腾记(11): NASTool3.0体验和降级 NAS折腾记(10): Docker版本的NASTool配置 NAS折腾记(9): NASTool与微信交互,微信发送消息远程下载电影【多图】 NAS折腾记(8):群晖安装 NASTool 实现影音半自动化【多图】 内网穿透(2):Tailscale 组网实现内网穿透,操作简单,无成本 内网穿透(1):总结了11中内网穿透的方式,总有一种适合你 NAS折腾记(7):从零开始设置(黑)群晖系统 NAS折腾记(6):黑群晖系统安装好后怎么洗白?
gRPC在Go中的使用(一)Protocol Buffers语法与相关使用
2018-07-16 · via Razeen`s Blog

在gRPC官网用了一句话来介绍:“一个高性能、开源的通用RPC框架”,同时介绍了其四大特点:

  • 定义简单
  • 支持多种编程语言多种平台
  • 快速启动和缩放
  • 双向流媒体和集成身份验证

gRPC在go中使用系列中,关于其简介与性能我就不多介绍,相信在社区也有很多关于这些的讨论。这里我主要从三个层次来总结我以往在Go中使用gRPC的一些经验,主要分为:

  1. Protocol Buffers语法与相关使用
  2. gRPC实现简单通讯
  3. gRPC服务认证与双向流通讯

*注:下面Protocol Buffers简写protobuf.

这篇我们先介绍protobuf的相关语法、怎么书写.proto文件以及go代码生成。

简介

要熟练的使用GRPC,protobuf的熟练使用必不可少。

gRPC使用protobuf来定义服务。protobuf是由Google开发的一种数据序列化协议,可以把它想象成是XML或JSON格式,但更小,更快更简洁。而且一次定义,可生成多种语言的代码。

定义

首先我们需要编写一些.proto文件,定义我们在程序中需要处理的结构化数据。我们直接从一个实例开始讲起,下面是一个proto文件:

syntax = "proto3";

option go_package = "github.com/razeencheng/demo-go/grpc/demo1/helloworld";

package helloworld;

import "github.com/golang/protobuf/ptypes/any/any.proto";

message HelloWorldRequest {
  string greeting = 1;
  map<string, string> infos  = 2;
}

message HelloWorldResponse {
  string reply = 1;
  repeated google.protobuf.Any details = 2;
}

service HelloWorldService {
  rpc SayHelloWorld(HelloWorldRequest) returns (HelloWorldResponse){}
}

版本

文件的开头syntax="proto3"也就指明版本,主要有proto2proto3,他们在语法上有一定的差异,我这里主要使用的是后者。

包名

第二行,指定生成go文件的包名,可选项,默认使用第三行包名。

第三行,包名。

导包

第四行,类似你写go一样,protobuf也可以导入其他的包。

消息定义

后面message开头的两个结构就是我们需要传递的消息类型。所有的消息类型都是以message开始,然后定义类型名称。结构内字段的定义为字段规则 字段类型 字段名=字段编号

  • 字段规则主要有 singularrepeated。如其中greetingreply的字段规则为singular,允许该消息中出现0个或1个该字段(但不能超过一个),而像details字段允许重复任意次数。其实对应到go里面也就是基本类型和切片类型。
  • 字段类型,下表是proto内类型与go类型的对应表。
.proto TypeNotesGo Type
doublefloat64
floatfloat32
int32使用可变长度编码。 无效编码负数 - 如果您的字段可能具有负值, 请改用sint32。int32
int64使用可变长度编码。 无效编码负数 - 如果您的字段可能具有负值,请改用sint64。int64
uint32使用可变长度编码。uint32
uint64使用可变长度编码。uint64
sint32使用可变长度编码。 带符号的int值。 这些比常规的int32更有效地编码负数。int32
sint64使用可变长度编码。 带符号的int值。 这些比常规的int64更有效地编码负数。int64
fixed32总是四个字节。 如果值通常大于228,则比uint32效率更高。uint32
fixed64总是八个字节。 如果值通常大于256,则会比uint64更高效。uint64
sfixed32总是四个字节。int32
sfixed64总是八个字节。int64
boolbool
string字符串必须始终包含UTF-8编码或7位ASCII文本。string
bytes可能包含任何字节序列。[]byte

看到这里你也许会疑惑,go里面的切片,map,接口等类型我怎么定义呢?别急,下面一一替你解答。

1.map类型,HelloWorldRequestinfos就是一个map类型,它的结构为map<key_type, value_type> map_field = N 但是在使用的时候你需要注意map类型不能repetead

2.切片类型,我们直接定义其规则为repeated就可以了。就像HelloWorldResponse中的details字段一样,它就是一个切片类型。那么你会问了它是什么类型的切片?这就看下面了~

3.接口类型在proto中没有直接实现,但在google/protobuf/any.proto中定义了一个google.protobuf.Any类型,然后结合protobuf/go也算是曲线救国了~

  • 字段编号

    最后的1,2代表的是每个字段在该消息中的唯一标签,在与消息二进制格式中标识这些字段,而且当你的消息在使用的时候该值不能改变。1到15都是用一个字节编码的,通常用于标签那些频繁发生修改的字段。16到2047用两个字节编码,最大的是2^29-1(536,870,911),其中19000-19999为预留的,你也不可使用。

服务定义

如果你要使用RPC(远程过程调用)系统的消息类型,那就需要定义RPC服务接口,protobuf编译器将会根据所选择的不同语言生成服务接口代码及存根。就如:

service HelloWorldService {
  rpc SayHelloWorld(HelloWorldRequest) returns (HelloWorldResponse){}
}

protobuf编译器将产生一个抽象接口HelloWorldService以及一个相应的存根实现。存根将所有的调用指向RpcChannel(SayHelloWorld),它是一个抽象接口,必须在RPC系统中对该接口进行实现。具体如何使用,将在下一篇博客中详细介绍。

生成Go代码

安装protoc

首先要安装protoc,可直接到这里下载二进制安装到 $PATH里面,也可以直接下载源码编译。除此之外,你还需要安装go的proto插件protoc-gen-go

// mac terminal
go get -u github.com/golang/protobuf/{proto,protoc-gen-go}
// win powershell
go get -u github.com/golang/protobuf/proto
go get -u github.com/golang/protobuf/protoc-gen-go

生成go代码

接下来,使用protoc命令即可生成。

### mac terminal
protoc -I ${GOPATH}/src --go_out=plugins=grpc:${GOPATH}/src ${GOPATH}/src/github.com/razeencheng/demo-go/grpc/demo1/helloworld/hello_world.proto
### win powershell
protoc -I $env:GOPATH\src --go_out=plugins=grpc:$env:GOPATH\src $env:GOPATH\src\github.com\razeencheng\demo-go\grpc\demo1\helloworld\hello_world.proto

如上所示 -I指定搜索proto文件的目录,--go_out=plugins=grpc:指定生成go代码的文件夹,后面就是需要生成的proto文件路径。

注意: 如果你使用到了其他包的结构,-I需要将该资源包括在内。

例如我导入了github.com/golang/protobuf/ptypes/any/any.proto 我首先需要

go get -u github.com/golang/protobuf获取该包,然后在使用时资源路径(-I)直接为GOPATH\src

最后生成的hello-world.pb.go文件。内容大概如下图所示,点这里可查看全部。

图中我们可以看到两个message对应生成了两个结构体,同时会生成一些序列化的方法等。

而定义的service则是生成了对应的clientserver接口,那么这到底有什么用?怎么去用呢?下一篇博客将为你详细讲解~

看到这,我们简单的了解一下protobuf语法,如果你想了解更多,点这里看官方文档。