grpc学习

grpc介绍

源于Google的内部RPC框架, 使用protobuf进行编码解码。

grpc的一些特点：

数据空间更小（protobuffer其数据格式紧密，没有多余的空格，括号，尖括号，key 等）

支持多种语言，通过 proto3 工具生成指定语言的数据结构、服务端接口以及客户端 Stub

支持相对复杂的数据格式

支持HTTP/2

性能相对更好，protobuffer + 二进制传输 + HTTP/2 。

grpc总共支持4种通信方式：

Simple RPC

简单rpc 这就是一般的rpc调用，一个请求对象对应一个返回对象 proto语法：

rpc simpleHello(Person) returns (Result) {}

Server-side streaming RPC

服务端流式rpc 一个请求对象，服务端可以传回多个结果对象

rpc serverStreamHello(Person) returns (stream Result) {}

Client-side streaming RPC

客户端流式rpc 客户端传入多个请求对象，服务端返回一个响应结果

rpc clientStreamHello(stream Person) returns (Result) {}

Bidirectional streaming RPC

双向流式rpc 结合客户端流式rpc和服务端流式rpc，可以传入多个对象，返回多个响应对象

rpc biStreamHello(stream Person) returns (stream Result) {}

grpc实现

Protobuf安装

Mac用户可以使用brew进行安装:

brew install protobuf

定义.proto 文件,  hello.proto 如下：

syntax="proto3";

packageproto;

​

// The request message containing the user's name.

messageHelloRequest{

stringname=1;

}

​

// The response message containing the greetings

messageHelloReply{

stringmessage=1;

}

​

// The greeting service definition.

serviceGreeter{

// Sends a greeting

rpcSayHello(HelloRequest)returns(HelloReply) {}

// Sends another greeting

rpcSayHelloAgain(HelloRequest)returns(HelloReply) {}

}

proto定义完之后，用protocol生成器生成一份go的代码，用来给server端和client端调用, 

protoc--go_out=plugins=grpc:.hello.proto

生成的文件为hello.pb.go，包含几个部分：

方法出入参结构体以及序列化和反序列方法

注册出入参结构体的 init 方法

客户端存根结构体和接口以及实现

服务端结构体和接口以及一个空实现

stream 的 send 和 recv 结构体和接口以及实现

服务的一些描述

编写服务端代码：

服务端主要是定义一个结构体，实现pb.go接口

packageserver

​

import(

  "context"

  pb"github.com/goCode/rpc/grpc/proto"

)

​

typeHelloServerstruct{

}

​

func(s*HelloServer)SayHello(ctxcontext.Context,in*pb.HelloRequest) (*pb.HelloReply,error) {

  return&pb.HelloReply{Message:"Hello "+in.GetName()},nil

}

​

func(s*HelloServer)SayHelloAgain(ctxcontext.Context,in*pb.HelloRequest) (*pb.HelloReply,error) {

  return&pb.HelloReply{Message:"Hello again "+in.GetName()},nil

}

启动服务端

funcStartServer() {

  lis,err:=net.Listen("tcp","127.0.0.1:8091")

  iferr!=nil{

    log.Fatalf("failed to listen: %v",err)

  }

  //创建一个grpc服务器对象

  gRpcServer:=grpc.NewServer()

​

//注册grpc服务

  pb.RegisterGreeterServer(gRpcServer,&HelloServer{})

  gRpcServer.Serve(lis)

}

​

实现客户端

funcStartClient() {

  conn,err:=grpc.Dial("127.0.0.1:8091",grpc.WithInsecure())

  iferr!=nil{

    return

  }

  deferconn.Close()

  c:=pb.NewGreeterClient(conn)

  res,err:=c.SayHello(context.Background(),new(pb.HelloRequest),grpc.EmptyCallOption{})

  fmt.Println(res,err)

}