RPC 代指远程过程调用(Remote Procedure Call),它的调用包含了传输协议和编码(对象序列号)协议等等。允许运行于一台计算机的程序调用另一台计算机的 子程序 ,而开发人员无需额外地为这个交互作用编程。

RPC具有简单、通用、安全、效率的特点,可以基于 HTTP 协议进行调用。

GRPC相关安装

安装G rpc

1、go get方式

 $ go get -u google. golang .org/grpc  

2、通过 github

进入$GOTPATH目录,新建google.golang.org目录,拉取golang在github上的镜像库:

 $ cd /usr/local/go/path/src   
$  mkdir  google.golang.org
$ cd google.golang.org/
$ git clone 
$ mv grpc-go/ grpc/  

Protoc Plugin编译器插件安装

 $ go get -u github.com/golang/ Protobuf /protoc-gen-go  

将Protoc Plugin的 可执行文件 从 $GOPATH 中移动到 $GOBIN 下

 $ which protoc-gen-go
/usr/local/bin/protoc-gen-go  

Protocol Buffers v3安装

 $ wget 
$ unzip protobuf-all-3.5.1.zip
$ cd protobuf-3.5.1/
$ ./configure
$ make
$ make install
$ protoc --version
libprotoc 3.5.1  
介绍

简单介绍:protobuf是协议,protoc是 IDL 生成器。

Protocol Buffers 是一种与语言、平台无关,可扩展的序列化结构化数据的方法,常用于通信协议,数据存储等等。

语法:

 syntax = "proto3";

package proto;

service SearchService {
    rpc Search(Search Request ) returns (SearchResponse) {}
}

option go_package ="./proto"; // 指定RPC文件生成路径地址

message SearchRequest {
    string request = 1;
}

message SearchResponse {
    string response = 1;
}  
  1. 第一行声明使用 proto3 语法。如果不声明,将默认使用 proto2 语法。
  2. 定义 SearchService RPC 服务,其包含 RPC 方法 Search,入参为 SearchRequest 消息,出参为 SearchResponse 消息
  3. 定义 SearchRequest、SearchResponse 消息,示例定义了一个字段,包含三个属性:类型、字段名称、字段编号
  4. Protobuf 编译器会根据选择的语言不同,生成相应语言的 Service Interface Code 和 Stubs

V2,V3区别

  • 删除原始值字段的字段存在逻辑
  • 删除 required 字段
  • 删除 optional 字段,默认就是
  • 删除 default 字段
  • 删除扩展特性,新增 Any 类型来替代它
  • 删除 unknown 字段的支持
  • 新增 JSON Mapping
  • 新增 Map 类型的支持
  • 修复 enum 的 unknown 类型
  • repeated 默认使用 packed 编码
  • 引入了新的语言实现(C#,JavaScript, Ruby ,Objective-C)
protoc使用

常用参数-IPATH, –proto_path=PATH:指定import搜索的目录,可指定多个,如果不指定则默认当前工作目录;–go_out:生成golang源文件

示例:

 $ protoc --go_out=plugins=grpc:. *.proto   

将plugins=grpc参数传递给–go_out,protoc-gen-go可以生成与grpc相兼容的代码

GRPC

简单来讲 gRPC 是一个 基于 HTTP/2 协议设计的 RPC 框架,它采用了 Protobuf 作为 IDL,具有以下特性:

  1. 强大的IDL,使用Protocol Buffers作为数据交换的格式,支持v2、v3(推荐v3)
  2. 跨语言、跨平台,也就是Grpc支持多种平台和语言
  3. 支持HTTP2,双向传输、 多路复用 、认证等

gRPC vs. Restful API

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

  • gRPC可以通过protobuf来定义接口,从而可以有更加严格的接口约束条件
  • 通过protobuf可以将数据序列化为二进制编码,这会大幅减少需要传输的数据量,从而大幅提高性能
  • gRPC可以方便地支持流式通信

GRPC流程图

1.图中服务端使用的是C++语言开发的系统,客户端分别使用的是Android-Java开发的平台和 Ruby语言 开发的平台.gRPC可以在不同的语言开发的平台上使用.

2.主要实现的流程为,在服务端实现自身定义的服务内的接口,并运行一个 gRPC 服务器来处理客户端的请求调用并将处理结果返回到客户端。在客户端拥有一个存根能够像服务端一样的方法。

GRPC示例

目录结构

 $ tree
.
├── client.go
├── proto
│   ├── search.pb. go 
│   └── search.proto
└── server.go

1 directory, 4 files  

IDL

编写search.proto:

 syntax = "proto3";

package proto;

service SearchService {
    rpc Search(SearchRequest) returns (SearchResponse) {}
}

option go_package ="./proto"; // 指定RPC文件生成路径地址

message SearchRequest {
    string request = 1;
}

message SearchResponse {
    string response = 1;
}  

在 proto 文件夹下执行如下命令生成go文件:

 $ protoc --go_out=plugins=grpc:. *.proto  

执行完之后会生成search.pb.go。

server

 package main

import (
"context"
"log"
"net"

"google.golang.org/grpc"

pb "../t2/proto"
)

type SearchService  struct {}

func (s *SearchService) Search(ctx context.Context, r *pb.SearchRequest) (*pb.SearchResponse, error) {
return &pb.SearchResponse{Response: r.GetRequest() + " welcome to study grpc!"},  nil 
}

const PORT = "9001"

func main() {
server := grpc.NewServer()
pb.RegisterSearchServiceServer(server, &SearchService{})

lis, err := net.Listen("tcp", ":"+PORT)
if err != nil {
log.Fatalf("net.Listen err: %v", err)
}

server.Serve(lis)
}  
  1. 创建 gRPC Server 对象
  2. 将 SearchService(其包含需要被调用的服务端接口)注册到 gRPC Server 的内部注册中心。这样可以在接受到请求时,通过内部的服务发现,发现该服务端接口并转接进行逻辑处理
  3. 创建 Listen,监听 TCP 端口
  4. gRPC Server 开始 lis.Accept,直到 Stop 或 GracefulStop

client

 package main

import (
"context"
"log"

"google.golang.org/grpc"

pb "../t2/proto"
)

const PORT = "9001"

func main() {
conn, err := grpc.Dial(":"+PORT, grpc.WithInsecure())
if err != nil {
log.Fatalf("grpc.Dial err: %v", err)
}
defer conn.Close()

client := pb.NewSearchServiceClient(conn)
resp, err := client.Search(context.Background(), &pb.SearchRequest{
Request: "ares",
})
if err != nil {
log.Fatalf("client.Search err: %v", err)
}

log. Printf ("resp: %s", resp.GetResponse())
}  
  1. 创建与服务端的连接交互
  2. 创建 SearchService 的客户端对象
  3. 发送 RPC 请求,等待同步响应,得到回调后返回响应结果
  4. 输出响应结果

运行server及client

至此,一个简单的GRPC示例已经跑起来了。