A high-performance, open-source universal RPC framework

所谓RPC(remote procedure call 远程过程调用)框架实际是提供了一套机制，使得应用程序之间可以进行通信，而且也遵从server/client模型。使用的时候客户端调用server端提供的接口就像是调用本地的函数一样。如下图所示就是一个典型的RPC结构图。

RPC通信

gRPC有什么好处以及在什么场景下需要用gRPC
既然是server/client模型，那么我们直接用restful api不是也可以满足吗，为什么还需要RPC呢？下面我们就来看看RPC到底有哪些优势

gRPC vs. Restful API

gRPC和restful API都提供了一套通信机制，用于server/client模型通信，而且它们都使用http作为底层的传输协议(严格地说, gRPC使用的http2.0，而restful api则不一定)。不过gRPC还是有些特有的优势，如下：

gRPC可以通过protobuf来定义接口，从而可以有更加严格的接口约束条件。

另外，通过protobuf可以将数据序列化为二进制编码，这会大幅减少需要传输的数据量，从而大幅提高性能。
gRPC可以方便地支持流式通信(理论上通过http2.0就可以使用streaming模式, 但是通常web服务的restful api似乎很少这么用，通常的流式数据应用如视频流，一般都会使用专门的协议如HLS，RTMP等，这些就不是我们通常web服务了，而是有专门的服务器应用。）

Protobuf是什么

官方文档: https://developers.google.com/protocol-buffers

Protobuf实际是一套类似Json或者XML的数据传输格式和规范，用于不同应用或进程之间进行通信时使用。通信时所传递的信息是通过Protobuf定义的message数据结构进行打包，然后编译成二进制的码流再进行传输或者存储。

Protobuf的优点

相比较而言，Protobuf有如下优点：

安装Protobuf

根据自己的系统版本下载指定的稳定版本文件

我这边是 MAC 就下载 protoc-3.11.4-osx-x86_64.zip 文件

添加可执行文件到环境变量

为了基础 protobuf 文件，使用 protoc 工具编译出 go 相关文件，需要安装一个插件

$ go get github.com/golang/protobuf/protoc-gen-go
GRPC示例
安装grpc
$ go get -u google.golang.org/grpc
GRPC服务端
├── main.go // 入口文件
├── pbfile  // protobuf 中间文件
│   └── Prob.proto
├── pbservices  // 根据中间文件生成的go文件
│   └── Prob.pb.go
└── services    // 根据生成的go文件的实现
    └── Prob.go
protobuf 中间文件
// proto 文件版本
syntax = "proto3";
// 生成文件的包名
package services;
// 请求结构体
message ProbRequest {
    int32 Pid = 1;
// 响应结构体
message ProbResponse {
    float Price = 1;
// 定义rpc接口
service ProbService {
    rpc GetProductPrice (ProbRequest) returns (ProbResponse)
使用中间文件生成go文件
$ cd pbfile/
$ protoc --go_out=plugins=grpc:../pbservices Prob.proto
实现生成的go文件的接口
// services/Prob.go
package services
import (
	"context"
	"pbservices"
type ProbService struct {
func (this *ProbService) GetProductPrice(context.Context, request *pbservices.ProbRequest) (*pbservices.ProbResponse, error) {
	return &pbservices.ProbResponse{Price: 10}, nil
创建rpc服务文件
package main
import (
	"pbservices"
	"services"
	"google.golang.org/grpc"
	"log"
	"net"
func main() {
	// 服务端启用安全证书
	//cred, err := credentials.NewServerTLSFromFile("./keys/server.crt", "./keys/server.key")
	//if err != nil {
	//	log.Fatal(err)
	// 创建服务
	//rpcserver := grpc.NewServer(grpc.Creds(cred))
	rpcserver := grpc.NewServer()
	// 注册
	pbservices.RegisterProbServicesServer(rpcserver, &services.ProbService{})
	// 启动监听
	lis, err := net.Listen("tcp", ":8081")
	if err != nil {
		log.Fatal(err)
	err = rpcserver.Serve(lis)
	if err != nil {
		log.Fatal(err)
GRPC客户端
├── main.go     // 入口文件
└── pbservices  // 根据中间文件生成的go文件
    └── Prob.pb.go
客户端实现
package main
import (
	"context"
	"fmt"
	"pbservices"
	"google.golang.org/grpc"
	"log"
func main() {
	// 启用安全证书
	//cred, err := credentials.NewClientTLSFromFile("./keys/server.crt", "mazhichao.com")
	//if err != nil {
	//	log.Fatal(err)
	//conn, err := grpc.Dial(":8081", grpc.WithTransportCredentials(cred))
	// grpc.WithInsecure() 忽略安全
	conn, err := grpc.Dial(":8081", grpc.WithInsecure())
	if err != nil {
		log.Fatal(err)
	defer conn.Close()
	client := pbservices.NewProbServicesClient(conn)
	req := &pbservices.ProbRequest{Pid: 1}
	response, err := client.GetProductPrice(context.Background(), req)
	if err != nil {
		log.Fatal(err)
	fmt.Println(response.Price)