gRPC (Google Remote Procedure Call) 是一種高效能、跨語言的遠端過程呼叫框架,它透過 Protocol Buffers(ProtoBuf)定義服務接口,並支援眾多程式語言。 gRPC 在分散式系統的開發中廣泛應用,其高效的序列化和反序列化機制、基於 HTTP/2 的流控制和分塊傳輸等一系列特性使其在網路傳輸方面有著明顯的優勢。
本文主要介紹在 Golang 中如何安裝 gRPC,並撰寫一個簡單的客戶端和服務端範例程式碼。
在安裝 gRPC 之前,需要先安裝 Protocol Buffers 3。 Protocol Buffers 是 gRPC 自動產生程式碼所需的工具,同時也是一個序列化資料的工具。
首先,下載Protocol Buffers 3 的安裝包,以Mac OS 為例:
$ curl -OL https://github.com/google/protobuf/releases/download/v3.9.1/protobuf-all-3.9.1.zip $ unzip protobuf-all-3.9.1.zip $ cd protobuf-3.9.1
執行configure、make、make install 即可安裝Protocol Buffers:
$ ./configure $ make $ sudo make install
安裝完Protocol Buffers 後,使用以下指令安裝Go 的gRPC 和相關工具:
$ go get -u google.golang.org/grpc $ go get -u github.com/golang/protobuf/protoc-gen-go
ProtoBuf 檔案用於定義服務介面和資料結構,並透過gRPC 工具自動產生對應的程式碼(包括客戶端和服務端程式碼)。
我們在此編寫一個簡單的範例,定義一個計算器服務接口,支援加法運算:
syntax = "proto3"; package calculator; service Calculator { rpc Add(AddRequest) returns (AddResponse) {} } message AddRequest { int32 left = 1; int32 right = 2; } message AddResponse { int32 sum = 1; }
在此範例中,定義一個名為Calculator 的服務接口,包含一個Add方法,該方法接收一個AddRequest 參數並傳回一個AddResponse 參數。
AddRequest 和 AddResponse 都是訊息結構,分別包含兩個 int32 類型的字段,表示加法的兩個運算元和結果。
在編寫ProtoBuf 檔案後,使用下列指令產生用戶端和服務端程式碼:
$ protoc --go_out=plugins=grpc:. calculator.proto
此指令產生一個名為calculator.pb. go 的Go 文件,其中定義了計算器服務的用戶端和服務端程式碼。
在產生客戶端和服務端程式碼後,就可以開始編寫實際的客戶端和服務端了。
首先是服務端程式碼,我們建立一個名為server.go 的文件,實作Calculator 介面:
package main import ( "context" "log" "net" pb "calculator/calculator" "google.golang.org/grpc" ) type server struct{} func (s *server) Add(ctx context.Context, in *pb.AddRequest) (*pb.AddResponse, error) { sum := in.Left + in.Right return &pb.AddResponse{Sum: sum}, nil } const ( port = ":50051" ) func main() { lis, err := net.Listen("tcp", port) if err != nil { log.Fatalf("failed to listen: %v", err) } s := grpc.NewServer() pb.RegisterCalculatorServer(s, &server{}) if err := s.Serve(lis); err != nil { log.Fatalf("failed to serve: %v", err) } }
在此範例中,我們定義了一個名為server 的結構體,實作了Calculator 介面中的Add 方法。 Add 方法接收一個 AddRequest 參數,並計算兩個運算元總和,傳回一個 AddResponse 參數。
最後,透過 gRPC 框架提供的 RegisterCalculatorServer 方法將服務註冊到 gRPC 伺服器中,並啟動 gRPC 伺服器。
接下來編寫客戶端程式碼,我們建立一個名為client.go 的文件,實作一個簡單的透過計算器服務進行加法運算的範例:
package main import ( "context" "log" "os" "strconv" pb "calculator/calculator" "google.golang.org/grpc" ) const ( address = "localhost:50051" defaultName = "world" ) func main() { // Set up a connection to the server. conn, err := grpc.Dial(address, grpc.WithInsecure()) if err != nil { log.Fatalf("did not connect: %v", err) } defer conn.Close() c := pb.NewCalculatorClient(conn) // Contact the server and print out its response. left, err := strconv.Atoi(os.Args[1]) if err != nil { log.Fatalf("could not parse left operand: %v", err) } right, err := strconv.Atoi(os.Args[2]) if err != nil { log.Fatalf("could not parse right operand: %v", err) } r, err := c.Add(context.Background(), &pb.AddRequest{Left: int32(left), Right: int32(right)}) if err != nil { log.Fatalf("could not add: %v", err) } log.Printf("Sum: %d", r.Sum) }
在此範例中,我們建立了一個名為client 的客戶端對象,並透過grpc.Dial 方法連接到伺服器。然後,我們從命令列參數中解析出加法的兩個操作數,並呼叫 Add 方法發送請求,得到伺服器傳回的結果並輸出。
在兩個檔案都寫完畢後,使用下列指令編譯並執行兩個程式:
$ go build server.go $ go build client.go $ ./server
然後在另一個終端機中執行以下指令執行客戶端程式:
$ ./client 1 2
執行結果會輸出計算結果3。
以上就是 gRPC 在 Golang 中的安裝和使用,透過 gRPC 編寫高效的分散式系統將變得十分簡單。
以上是grpc golang安裝的詳細內容。更多資訊請關注PHP中文網其他相關文章!