golang-grpc
- 2022 年 4 月 11 日
- 筆記
目錄
1. 什麼是grpc和protobuf
1.1 grpc
gRPC是一個高性能、開源和通用的RPC框架，面向移動和HTTP/2設計。目前提供C、Java和Go語言版本，分別是：grpc,grpc-java,grpc-go.其中C版本支援C,C++,Node.js,Python,Ruby,Objective-C,PHP和C#支援.
grpc遵循HTTP/2協議，是一個二進位協議
grpc與http一樣，底層都是tcp連接，遵循socket套接字
RPC是指遠程過程調用，兩台伺服器A,B。A(客戶端)調用B(服務端)上的方法，由於不在同一個記憶體空間，不能直接調用，需要通過網路調用。
1.2 protobuf
Protocol Buffer是一種協議。
Protocol Buffer 其實 是 Google出品的一種輕量 & 高效的結構化數據存儲格式，性能比Json、XML真的強2-100倍！
protobuf經歷了protobuf2和protobuf3，pb3比pb2簡化了很多，目前主流的版本是pb3
protobuf優點：
1.性能好：
壓縮性能；
序列化和發序列化快，比Json、XML強2-100倍；
傳輸速度快。
2.便捷性好：
使用簡單，自動生成序列化和反序列化程式碼；
維護成本低，只維護proto文件
向後兼容，不必破壞舊格式
加密性好
3.跨語言，跨平台，支援各種語言
protobuf缺點：
1.通用性差，json可以任何語言都支援，但是protobuf需要專門的解析庫
2.自解釋性差，只有通過proto文件才能了解數據結構
2.go下grpc
2.1官網下載protobuf工具
官網：//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 .：在當前路徑下尋找hello.proto文件
--go_out=plugins=grpc:. ：生成go語言的proto文件放在當前路徑下
2.5 編寫server端程式碼
package main
import (
"context"
"file_test/grpc_go/proto"
"net"
"google.golang.org/grpc"
)
type Server struct {}
// 業務邏輯
func (s *Server) SayHello(ctx context.Context, request *proto.HelloRequest) (*proto.HelloReply, error) {
res := &proto.HelloReply{
Message: "hello " + request.Name,
}
return res, nil
}
// 啟動rpc的server服務
func start() {
// 1.實例化server
g := grpc.NewServer()
// 2.註冊邏輯到server中
proto.RegisterGreeterServer(g,&Server{})
// 3.啟動server
lis,err:=net.Listen("tcp","127.0.0.1:8081")
if err !=nil{
panic("監聽錯誤:"+err.Error())
}
err = g.Serve(lis)
if err !=nil{
panic("啟動錯誤:"+err.Error())
}
}
func main() {
start()
}
2.6 編寫client端程式碼
package main
import (
"context"
"file_test/grpc_go/proto"
"fmt"
"google.golang.org/grpc"
)
// rpc調用
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
}
// 業務程式碼
func start() {
body := make(map[string]string)
body["name"] = "jeff"
response,err := clientRpc(body)
if err!=nil{
fmt.Println("rpc調用失敗:",err)
return
}
fmt.Println(response.Message)
}
func main() {
start()
}
//結果：
hello jeff
2.7 python和go相互調用實踐(跨語言調用)
proto文件共用。
1.開啟python的server端，go的client端測試。
2.開啟go的server端，python的clinet端測試。
