Go?gRPC教程實(shí)現(xiàn)Simple?RPC
前言
gRPC主要有4種請(qǐng)求和響應(yīng)模式,分別是簡(jiǎn)單模式(Simple RPC)、服務(wù)端流式(Server-side streaming RPC)、客戶端流式(Client-side streaming RPC)、和雙向流式(Bidirectional streaming RPC)。
- 簡(jiǎn)單模式(Simple RPC):客戶端發(fā)起請(qǐng)求并等待服務(wù)端響應(yīng)。
- 服務(wù)端流式(Server-side streaming RPC):客戶端發(fā)送請(qǐng)求到服務(wù)器,拿到一個(gè)流去讀取返回的消息序列。 客戶端讀取返回的流,直到里面沒有任何消息。
- 客戶端流式(Client-side streaming RPC):與服務(wù)端數(shù)據(jù)流模式相反,這次是客戶端源源不斷的向服務(wù)端發(fā)送數(shù)據(jù)流,而在發(fā)送結(jié)束后,由服務(wù)端返回一個(gè)響應(yīng)。
- 雙向流式(Bidirectional streaming RPC):雙方使用讀寫流去發(fā)送一個(gè)消息序列,兩個(gè)流獨(dú)立操作,雙方可以同時(shí)發(fā)送和同時(shí)接收。
本篇文章先介紹簡(jiǎn)單模式。
新建proto文件
主要是定義我們服務(wù)的方法以及數(shù)據(jù)格式,我們使用上一篇的simple.proto文件。
1.定義發(fā)送消息的信息
message SimpleRequest{ // 定義發(fā)送的參數(shù),采用駝峰命名方式,小寫加下劃線,如:student_name string data = 1;//發(fā)送數(shù)據(jù) }
2.定義響應(yīng)信息
message SimpleResponse{ // 定義接收的參數(shù) // 參數(shù)類型 參數(shù)名 標(biāo)識(shí)號(hào)(不可重復(fù)) int32 code = 1; //狀態(tài)碼 string value = 2;//接收值 }
3.定義服務(wù)方法Route
// 定義我們的服務(wù)(可定義多個(gè)服務(wù),每個(gè)服務(wù)可定義多個(gè)接口) service Simple{ rpc Route (SimpleRequest) returns (SimpleResponse){}; }
4.編譯proto文件
我這里使用上一篇介紹的VSCode-proto3插件,保存后自動(dòng)編譯。
指令編譯方法,進(jìn)入simple.proto文件所在目錄,運(yùn)行:
protoc --go_out=plugins=grpc:./ ./simple.proto
創(chuàng)建Server端
1.定義我們的服務(wù),并實(shí)現(xiàn)Route方法
import ( "context" "log" "net" "google.golang.org/grpc" pb "go-grpc-example/proto" ) // SimpleService 定義我們的服務(wù) type SimpleService struct{} // Route 實(shí)現(xiàn)Route方法 func (s *SimpleService) Route(ctx context.Context, req *pb.SimpleRequest) (*pb.SimpleResponse, error) { res := pb.SimpleResponse{ Code: 200, Value: "hello " + req.Data, } return &res, nil }
該方法需要傳入RPC的上下文context.Context,它的作用結(jié)束超時(shí)或取消的請(qǐng)求。更具體的說請(qǐng)參考該文章
2.啟動(dòng)gRPC服務(wù)器
const ( // Address 監(jiān)聽地址 Address string = ":8000" // Network 網(wǎng)絡(luò)通信協(xié)議 Network string = "tcp" ) func main() { // 監(jiān)聽本地端口 listener, err := net.Listen(Network, Address) if err != nil { log.Fatalf("net.Listen err: %v", err) } log.Println(Address + " net.Listing...") // 新建gRPC服務(wù)器實(shí)例 grpcServer := grpc.NewServer() // 在gRPC服務(wù)器注冊(cè)我們的服務(wù) pb.RegisterSimpleServer(grpcServer, &SimpleService{}) //用服務(wù)器 Serve() 方法以及我們的端口信息區(qū)實(shí)現(xiàn)阻塞等待,直到進(jìn)程被殺死或者 Stop() 被調(diào)用 err = grpcServer.Serve(listener) if err != nil { log.Fatalf("grpcServer.Serve err: %v", err) } }
里面每個(gè)方法的作用都有注釋,這里就不解析了。
運(yùn)行服務(wù)端
go run server.go :8000 net.Listing...
創(chuàng)建Client端
import ( "context" "log" "google.golang.org/grpc" pb "go-grpc-example/proto" ) const ( // Address 連接地址 Address string = ":8000" ) func main() { // 連接服務(wù)器 conn, err := grpc.Dial(Address, grpc.WithInsecure()) if err != nil { log.Fatalf("net.Connect err: %v", err) } defer conn.Close() // 建立gRPC連接 grpcClient := pb.NewSimpleClient(conn) // 創(chuàng)建發(fā)送結(jié)構(gòu)體 req := pb.SimpleRequest{ Data: "grpc", } // 調(diào)用我們的服務(wù)(Route方法) // 同時(shí)傳入了一個(gè) context.Context ,在有需要時(shí)可以讓我們改變RPC的行為,比如超時(shí)/取消一個(gè)正在運(yùn)行的RPC res, err := grpcClient.Route(context.Background(), &req) if err != nil { log.Fatalf("Call Route err: %v", err) } // 打印返回值 log.Println(res) }
運(yùn)行客戶端
go run client.go code:200 value:"hello grpc"
成功調(diào)用Server端的Route方法并獲取返回的數(shù)據(jù)。
總結(jié)
本篇介紹了簡(jiǎn)單RPC模式,客戶端發(fā)起請(qǐng)求并等待服務(wù)端響應(yīng)。
教程源碼地址:https://github.com/Bingjian-Zhu/go-grpc-example
參考:gRPC官方文檔中文版
更多關(guān)于Go gRPC教程Simple RPC的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Go?gRPC進(jìn)階教程gRPC轉(zhuǎn)換HTTP
這篇文章主要為大家介紹了Go?gRPC進(jìn)階教程gRPC轉(zhuǎn)換HTTP教程示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-06-06詳解Golang中errors包如何返回自定義error類型
這篇文章主要為大家詳細(xì)介紹了Golang中errors包如何返回自定義error類型,文中的示例代碼簡(jiǎn)潔易懂,有需要的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-09-09Golang連接PostgreSQL基本操作的實(shí)現(xiàn)
PostgreSQL是常見的免費(fèi)的大型關(guān)系型數(shù)據(jù)庫,本文主要介紹了Golang連接PostgreSQL基本操作的實(shí)現(xiàn),具有一定的參考價(jià)值,感興趣的可以了解一下2024-02-02Go的gin參數(shù)校驗(yàn)中的validator庫詳解
這篇文章主要介紹了Go的gin參數(shù)校驗(yàn)之validator庫,使用 validator 以后,只需要在定義結(jié)構(gòu)體時(shí)使用 binding 或 validate tag標(biāo)識(shí)相關(guān)校驗(yàn)規(guī)則,就可以進(jìn)行參數(shù)校驗(yàn)了,而不用自己?jiǎn)为?dú)去寫常見的校驗(yàn)規(guī)則,需要的朋友可以參考下2023-08-08詳解Go語言中init的使用與常見應(yīng)用場(chǎng)景
Go?中有一個(gè)特別的?init()?函數(shù),它主要用于包的初始化,這篇文章將以此為主題介紹?Go?中?init()?函數(shù)的使用和常見使用場(chǎng)景,希望對(duì)大家有所幫助2024-02-02Go語言實(shí)現(xiàn)牛頓法求平方根函數(shù)的案例
這篇文章主要介紹了Go語言實(shí)現(xiàn)牛頓法求平方根函數(shù)的案例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-12-12