當(dāng)前位置：首頁(yè) > 编程资源 > 编程问答 >内容正文

编程问答

Go语言初探gRPC服务

發(fā)布時(shí)間：2024/4/11 编程问答 27 豆豆

生活随笔收集整理的這篇文章主要介紹了 Go语言初探gRPC服务小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

原文鏈接：https://www.jianshu.com/p/20ed82218163

環(huán)境：2018-05-12 protoc 3.5.1 go1.10.1 windows
gRPC: Google主導(dǎo)開(kāi)發(fā)的RPC框架，這里不再贅述。

準(zhǔn)備工作

先安裝Protobuf 編譯器 protoc，下載地址：https://github.com/google/protobuf/releases
我的是windows，將壓縮包bin目錄下的exe放到環(huán)境PATH目錄中即可。

然后獲取插件支持庫(kù)

// gRPC運(yùn)行時(shí)接口編解碼支持庫(kù)go get -u github.com/golang/protobuf/proto// 從 Proto文件(gRPC接口描述文件) 生成 go文件的編譯器插件go get -u github.com/golang/protobuf/protoc-gen-go

獲取go的gRPC包(網(wǎng)絡(luò)問(wèn)題可參閱https://www.jianshu.com/p/6392cb9dc38f)

go get google.golang.org/grpc

接口文件 /src/

新建test.proto示例：

syntax = "proto3";// 定義包名package test;// 可以定義多個(gè)服務(wù)，每個(gè)服務(wù)內(nèi)可以定義多個(gè)接口service Waiter {// 定義接口 (結(jié)構(gòu)體可以復(fù)用)// 方法 (請(qǐng)求消息結(jié)構(gòu)體) returns (返回消息結(jié)構(gòu)體) {}rpc DoMD5 (Req) returns (Res) {}}// 定義 Req 消息結(jié)構(gòu)message Req {// 類型字段 = 標(biāo)識(shí)號(hào)string jsonStr = 1;}// 定義 Res 消息結(jié)構(gòu)message Res {string backJson = 1;} // PS：jsonStr和backJson只是隨手寫(xiě)的名字，并沒(méi)有用json

proto文件語(yǔ)法詳解參閱：https://blog.csdn.net/u014308482/article/details/52958148

然后將proto文件編譯為go文件

// protoc --go_out=plugins=grpc:{輸出目錄} {proto文件}protoc --go_out=plugins=grpc:./test/ ./test.proto

注意：原則上不要修改編譯出來(lái)的*.bp.go文件的代碼，因?yàn)殡p方接口基于同一個(gè)proto文件編譯成自己的語(yǔ)言源碼，此文件只作為接口數(shù)據(jù)處理，業(yè)務(wù)具體實(shí)現(xiàn)不在*.bp.go中。

服務(wù)端 /src/server/

本人也是剛接觸Go，基于https://github.com/freewebsys/grpc-go-demo的Demo在修改中理解gRPC
其中中文注釋均為個(gè)人理解筆記，若有不嚴(yán)謹(jǐn)?shù)牡胤?#xff0c;還望指正。

package mainimport ("log""net""golang.org/x/net/context""google.golang.org/grpc""test""google.golang.org/grpc/reflection""fmt""crypto/md5")// 業(yè)務(wù)實(shí)現(xiàn)方法的容器type server struct{}// 為server定義 DoMD5 方法內(nèi)部處理請(qǐng)求并返回結(jié)果// 參數(shù) (context.Context[固定], *test.Req[相應(yīng)接口定義的請(qǐng)求參數(shù)])// 返回 (*test.Res[相應(yīng)接口定義的返回參數(shù)，必須用指針], error)func (s *server) DoMD5(ctx context.Context, in *test.Req) (*test.Res, error) {fmt.Println("MD5方法請(qǐng)求JSON:"+in.JsonStr)return &test.Res{BackJson: "MD5 :" + fmt.Sprintf("%x", md5.Sum([]byte(in.JsonStr)))}, nil}func main() {lis, err := net.Listen("tcp", ":8028") //監(jiān)聽(tīng)所有網(wǎng)卡8028端口的TCP連接if err != nil {log.Fatalf("監(jiān)聽(tīng)失敗: %v", err)}s := grpc.NewServer() //創(chuàng)建gRPC服務(wù)/**注冊(cè)接口服務(wù)* 以定義proto時(shí)的service為單位注冊(cè)，服務(wù)中可以有多個(gè)方法* (proto編譯時(shí)會(huì)為每個(gè)service生成Register***Server方法)* 包.注冊(cè)服務(wù)方法(gRpc服務(wù)實(shí)例，包含接口方法的結(jié)構(gòu)體[指針])*/test.RegisterWaiterServer(s, &server{})/**如果有可以注冊(cè)多個(gè)接口服務(wù),結(jié)構(gòu)體要實(shí)現(xiàn)對(duì)應(yīng)的接口方法* user.RegisterLoginServer(s, &server{})* minMovie.RegisterFbiServer(s, &server{})*/// 在gRPC服務(wù)器上注冊(cè)反射服務(wù)reflection.Register(s)// 將監(jiān)聽(tīng)交給gRPC服務(wù)處理err = s.Serve(lis)if err != nil {log.Fatalf("failed to serve: %v", err)}}

客戶端 /src/client/

package mainimport ("log""os""golang.org/x/net/context""google.golang.org/grpc""test")func main() {// 建立連接到gRPC服務(wù)conn, err := grpc.Dial("127.0.0.1:8028", grpc.WithInsecure())if err != nil {log.Fatalf("did not connect: %v", err)}// 函數(shù)結(jié)束時(shí)關(guān)閉連接defer conn.Close()// 創(chuàng)建Waiter服務(wù)的客戶端t := test.NewWaiterClient(conn)// 模擬請(qǐng)求數(shù)據(jù)res := "test123"// os.Args[1] 為用戶執(zhí)行輸入的參數(shù) 如：go run ***.go 123if len(os.Args) > 1 {res = os.Args[1]}// 調(diào)用gRPC接口tr, err := t.DoMD5(context.Background(), &test.Req{JsonStr: res})if err != nil {log.Fatalf("could not greet: %v", err)}log.Printf("服務(wù)端響應(yīng): %s", tr.BackJson)}

啟動(dòng)服務(wù)端監(jiān)聽(tīng)，運(yùn)行客戶端即可達(dá)成遠(yuǎn)程調(diào)用

總結(jié)

以上是生活随笔為你收集整理的Go语言初探gRPC服务的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。

语言
Grpc