golang下grpc框架的使用編寫示例

更新時(shí)間：2022年04月13日 13:24:31 作者：Jeff的技術(shù)棧

這篇文章主要為大家介紹了golang下grpc框架的使用編寫示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步早日升職加薪

1. 什么是grpc和protobuf

1.1 grpc

gRPC是一個(gè)高性能、開源和通用的RPC框架，面向移動(dòng)和HTTP/2設(shè)計(jì)。

目前提供C、Java和Go語(yǔ)言版本，分別是：

grpc,grpc-java,grpc-go.其中C版本支持C,

C++,Node.js,Python,Ruby,Objective-C,PHP和C#支持.

grpc遵循HTTP/2協(xié)議，是一個(gè)二進(jìn)制協(xié)議

grpc與http一樣，底層都是tcp連接，遵循socket套接字

RPC是指遠(yuǎn)程過(guò)程調(diào)用，兩臺(tái)服務(wù)器A,B。A(客戶端)調(diào)用B(服務(wù)端)上的方法，由于不在同一個(gè)內(nèi)存空間，不能直接調(diào)用，需要通過(guò)網(wǎng)絡(luò)調(diào)用。

1.2 protobuf

Protocol Buffer是一種協(xié)議。
Protocol Buffer 其實(shí) 是 Google出品的一種輕量 & 高效的結(jié)構(gòu)化數(shù)據(jù)存儲(chǔ)格式，性能比Json、XML真的強(qiáng)2-100倍！

protobuf經(jīng)歷了protobuf2和protobuf3，pb3比pb2簡(jiǎn)化了很多，目前主流的版本是pb3

protobuf優(yōu)點(diǎn)：

1.性能好：
壓縮性能；
序列化和發(fā)序列化快，比Json、XML強(qiáng)2-100倍；
傳輸速度快。

2.便捷性好：
使用簡(jiǎn)單，自動(dòng)生成序列化和反序列化代碼；
維護(hù)成本低，只維護(hù)proto文件
向后兼容，不必破壞舊格式
加密性好

3.跨語(yǔ)言，跨平臺(tái)，支持各種語(yǔ)言

protobuf缺點(diǎn)：

1.通用性差，json可以任何語(yǔ)言都支持，但是protobuf需要專門的解析庫(kù)

2.自解釋性差，只有通過(guò)proto文件才能了解數(shù)據(jù)結(jié)構(gòu)

2.go下grpc

2.1官網(wǎng)下載protobuf工具

官網(wǎng)：https://github.com/protocolbuffers/protobuf/releases

2.2 下載go的依賴包

go get github.com/golang/protobuf/protoc-gen-go

2.3 編寫proto文件

option go_package = "./;proto";

解釋：

./;:生成文件的路徑

proto:生成文件的包名

hello.proto

syntax = "proto3";
package services;
option go_package = "./;proto";
service Greeter {
    rpc SayHello (HelloRequest) returns (HelloReply);
}
message HelloRequest {
    string name = 1;
}
message HelloReply {
    string message = 1;
}

2.4 生成hello.pb.proto文件

cd到proto目錄下
命令：protoc -I . hello.proto   --go_out=plugins=grpc:.
命令解釋：
protoc -I .：在當(dāng)前路徑下尋找hello.proto文件
--go_out=plugins=grpc:.  ：生成go語(yǔ)言的proto文件放在當(dāng)前路徑下

2.5 編寫server端代碼

package main
import (
	"context"
	"file_test/grpc_go/proto"
	"net"

	"google.golang.org/grpc"
)
type Server struct {}
// 業(yè)務(wù)邏輯
func (s *Server) SayHello(ctx context.Context, request *proto.HelloRequest) (*proto.HelloReply, error) {
	res := &proto.HelloReply{
		Message: "hello " + request.Name,
	}
	return res, nil
}
// 啟動(dòng)rpc的server服務(wù)
func start() {
	// 1.實(shí)例化server
	g := grpc.NewServer()
	// 2.注冊(cè)邏輯到server中
	proto.RegisterGreeterServer(g,&Server{})
	// 3.啟動(dòng)server
	lis,err:=net.Listen("tcp","127.0.0.1:8081")
	if err !=nil{
		panic("監(jiān)聽錯(cuò)誤:"+err.Error())
	}

	err = g.Serve(lis)
	if err !=nil{
		panic("啟動(dòng)錯(cuò)誤:"+err.Error())
	}
}
func main() {
	start()
}

2.6 編寫client端代碼

package main
import (
	"context"
	"file_test/grpc_go/proto"
	"fmt"

	"google.golang.org/grpc"
)
// rpc調(diào)用
func clientRpc(body map[string]string) (res *proto.HelloReply, err error) {
	name := body["name"]
	conn, err := grpc.Dial("127.0.0.1:8081", grpc.WithInsecure())
	if err != nil {
		return nil,err
	}
	defer conn.Close()
	rpc := proto.NewGreeterClient(conn)
	response, err := rpc.SayHello(context.Background(), &proto.HelloRequest{Name: name})
	if err != nil {
		return nil,err
	}
	return response,nil
}
// 業(yè)務(wù)代碼
func start() {
	body := make(map[string]string)
	body["name"] = "jeff"
	response,err := clientRpc(body)
	if err!=nil{
		fmt.Println("rpc調(diào)用失敗:",err)
		return
	}
	fmt.Println(response.Message)
}
func main() {
	start()
}
//結(jié)果：
hello jeff