本篇內(nèi)容主要講解“GO版gRPC開(kāi)發(fā)方法是什么”,感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷,實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“GO版gRPC開(kāi)發(fā)方法是什么”吧!
讓客戶滿意是我們工作的目標(biāo),不斷超越客戶的期望值來(lái)自于我們對(duì)這個(gè)行業(yè)的熱愛(ài)。我們立志把好的技術(shù)通過(guò)有效、簡(jiǎn)單的方式提供給客戶,將通過(guò)不懈努力成為客戶在信息化領(lǐng)域值得信任、有價(jià)值的長(zhǎng)期合作伙伴,公司提供的服務(wù)項(xiàng)目有:國(guó)際域名空間、網(wǎng)頁(yè)空間、營(yíng)銷軟件、網(wǎng)站建設(shè)、冀州網(wǎng)站維護(hù)、網(wǎng)站推廣。
接下來(lái)的開(kāi)發(fā)都是在$GOPATH目錄下進(jìn)行的,我這里的真實(shí)目錄是/home/golang/gopath;
在/home/golang/gopath/src目錄下新建helloworld目錄,作為接下來(lái)的實(shí)戰(zhàn)用到的目錄;
在完成本篇的所有開(kāi)發(fā)后,最終$GOPATH/src/helloworld目錄下的內(nèi)容如下:
[golang@centos7 src]$ tree helloworld/ helloworld/ ├── client │ └── client.go ├── helloworld.pb.go ├── helloworld.proto └── server └── server.go 2 directories, 4 files
proto文件用來(lái)描述遠(yuǎn)程服務(wù)相關(guān)的信息,如方法簽名、數(shù)據(jù)結(jié)構(gòu)等,本篇的proto文件名為helloworld.proto,位置是$GOPATH/src/helloworld,內(nèi)容如下:
// 協(xié)議類型syntax = "proto3";// 包名package helloworld;// 定義的服務(wù)名service Greeter { // 具體的遠(yuǎn)程服務(wù)方法 rpc SayHello (HelloRequest) returns (HelloReply) { }}// SayHello方法的入?yún)?,只有一個(gè)字符串字段message HelloRequest { string name = 1;}// SayHello方法的返回值,只有一個(gè)字符串字段message HelloReply { string message = 1;}
在helloworld.proto所在的目錄,執(zhí)行以下命令:
protoc --go_out=plugins=grpc:. helloworld.proto
如果helloworld.proto沒(méi)有語(yǔ)法錯(cuò)誤,會(huì)在當(dāng)前目錄生成文件helloworld.pb.go,這里面是工具protoc-gen-go自動(dòng)生成的代碼,里面生成的代碼在開(kāi)發(fā)服務(wù)端和客戶端時(shí)都會(huì)用到;
下面是helloworld.pb.go的代碼片段,作用是服務(wù)注冊(cè),入?yún)⑹荊reeterServer是個(gè)接口,由此可以推測(cè):在服務(wù)端,由具體的業(yè)務(wù)代碼來(lái)實(shí)現(xiàn)GreeterServer接口,并且調(diào)用RegisterGreeterServer方法注冊(cè),這樣客戶端遠(yuǎn)程調(diào)用的服務(wù)就可以實(shí)現(xiàn)業(yè)務(wù)功能了:
func RegisterGreeterServer(s *grpc.Server, srv GreeterServer) { s.RegisterService(&_Greeter_serviceDesc, srv)}type GreeterServer interface { // 具體的遠(yuǎn)程服務(wù)方法SayHello(context.Context, *HelloRequest) (*HelloReply, error)}
借助GoLand的Structure面板,可以進(jìn)一步觀察helloworld.pb.go:
在$GOPATH/src/helloworld目錄下新建文件夾server,在此文件夾下新建server.go,內(nèi)容如下,已經(jīng)添加詳細(xì)注釋:
package mainimport ("context""log""net""google.golang.org/grpc" pb "helloworld")const ( port = ":50051")// 定義結(jié)構(gòu)體,在調(diào)用注冊(cè)api的時(shí)候作為入?yún)ⅲ? // 該結(jié)構(gòu)體會(huì)帶上SayHello方法,里面是業(yè)務(wù)代碼 // 這樣遠(yuǎn)程調(diào)用時(shí)就執(zhí)行了業(yè)務(wù)代碼了type server struct { // pb.go中自動(dòng)生成的,是個(gè)空結(jié)構(gòu)體 pb.UnimplementedGreeterServer}// 業(yè)務(wù)代碼在此寫(xiě),客戶端遠(yuǎn)程調(diào)用SayHello時(shí), // 會(huì)執(zhí)行這里的代碼 func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) { // 打印請(qǐng)求參數(shù) log.Printf("Received: %v", in.GetName()) // 實(shí)例化結(jié)構(gòu)體HelloReply,作為返回值 return &pb.HelloReply{ Message: "Hello " + in.GetName()}, nil}func main() { // 要監(jiān)聽(tīng)的協(xié)議和端口 lis, err := net.Listen("tcp", port)if err != nil { log.Fatalf("failed to listen: %v", err)} // 實(shí)例化gRPC server結(jié)構(gòu)體 s := grpc.NewServer() // 服務(wù)注冊(cè) pb.RegisterGreeterServer(s, &server{ }) log.Println("開(kāi)始監(jiān)聽(tīng),等待遠(yuǎn)程調(diào)用...")if err := s.Serve(lis); err != nil { log.Fatalf("failed to serve: %v", err)}}
在server.go所在目錄執(zhí)行g(shù)o run server.go,控制臺(tái)提示如下:
[golang@centos7 server]$ go run server.go 2020/12/13 08:20:32 開(kāi)始監(jiān)聽(tīng),等待遠(yuǎn)程調(diào)用...
此時(shí)gRPC的服務(wù)端已經(jīng)啟動(dòng),可以響應(yīng)遠(yuǎn)程調(diào)用,接下來(lái)開(kāi)發(fā)客戶端代碼;
再打開(kāi)一個(gè)控制臺(tái);
在$GOPATH/src/helloworld目錄下新建文件夾client,在此文件夾下新建client.go,內(nèi)容如下,已經(jīng)添加詳細(xì)注釋:
package mainimport ("context""log""os""time""google.golang.org/grpc" pb "helloworld")const ( address = "localhost:50051" defaultName = "world")func main() { // 遠(yuǎn)程連接服務(wù)端 conn, err := grpc.Dial(address, grpc.WithInsecure(), grpc.WithBlock())if err != nil { log.Fatalf("did not connect: %v", err)}// main方法執(zhí)行完畢后關(guān)閉遠(yuǎn)程連接defer conn.Close()// 實(shí)例化數(shù)據(jù)結(jié)構(gòu) c := pb.NewGreeterClient(conn)// 遠(yuǎn)程調(diào)用的請(qǐng)求參數(shù),如果沒(méi)有從命令行傳入,就用默認(rèn)值 name := defaultName if len(os.Args) > 1 { name = os.Args[1]}// 超時(shí)設(shè)置 ctx, cancel := context.WithTimeout(context.Background(), time.Second)defer cancel()// 遠(yuǎn)程調(diào)用 r, err := c.SayHello(ctx, &pb.HelloRequest{ Name: name})if err != nil { log.Fatalf("could not greet: %v", err)}// 將服務(wù)端的返回信息打印出來(lái) log.Printf("Greeting: %s", r.GetMessage())}
在client.go所在目錄執(zhí)行g(shù)o run client.go,會(huì)立即向服務(wù)端發(fā)起遠(yuǎn)程調(diào)用,控制臺(tái)提示如下,可見(jiàn)得到了服務(wù)端的返回信息Hello world:
[golang@centos7 client]$ go run client.go 2020/12/13 08:38:05 Greeting: Hello world
再去服務(wù)端的控制臺(tái)看一下,通過(guò)日志發(fā)現(xiàn)業(yè)務(wù)代碼被執(zhí)行,收到了遠(yuǎn)程請(qǐng)求的參數(shù):
[golang@centos7 server]$ go run server.go 2020/12/13 08:20:32 開(kāi)始監(jiān)聽(tīng),等待遠(yuǎn)程調(diào)用... 2020/12/13 08:38:05 Received: world
回到客戶端控制臺(tái),在命令行帶參數(shù)試試,輸入go run client.go abc,收到服務(wù)端響應(yīng)如下:
[golang@centos7 client]$ go run client.go abc 2020/12/13 08:56:36 Greeting: Hello abc
再去服務(wù)端的控制臺(tái)看一下,成功收到了abc:
[golang@centos7 server]$ go run server.go 2020/12/13 08:20:32 開(kāi)始監(jiān)聽(tīng),等待遠(yuǎn)程調(diào)用... 2020/12/13 08:38:05 Received: world 2020/12/13 08:56:36 Received: abc
到此,相信大家對(duì)“GO版gRPC開(kāi)發(fā)方法是什么”有了更深的了解,不妨來(lái)實(shí)際操作一番吧!這里是創(chuàng)新互聯(lián)網(wǎng)站,更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢,關(guān)注我們,繼續(xù)學(xué)習(xí)!
分享題目:GO版gRPC開(kāi)發(fā)方法是什么
文章轉(zhuǎn)載:http://bm7419.com/article28/pciscp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供響應(yīng)式網(wǎng)站、網(wǎng)站收錄、標(biāo)簽優(yōu)化、小程序開(kāi)發(fā)、電子商務(wù)、網(wǎng)站內(nèi)鏈
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)