GO版gRPC開發(fā)方法是什么

本篇內(nèi)容主要講解“GO版gRPC開發(fā)方法是什么”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“GO版gRPC開發(fā)方法是什么”吧!

環(huán)境相關(guān)

• 接下來的開發(fā)都是在$GOPATH目錄下進(jìn)行的，我這里的真實(shí)目錄是/home/golang/gopath；

• 在/home/golang/gopath/src目錄下新建helloworld目錄，作為接下來的實(shí)戰(zhàn)用到的目錄；

• 在完成本篇的所有開發(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文件

• proto文件用來描述遠(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;}

根據(jù)proto生成go源碼

1. 在helloworld.proto所在的目錄，執(zhí)行以下命令：

protoc --go_out=plugins=grpc:. helloworld.proto

2. 如果helloworld.proto沒有語法錯(cuò)誤，會(huì)在當(dāng)前目錄生成文件helloworld.pb.go，這里面是工具protoc-gen-go自動(dòng)生成的代碼，里面生成的代碼在開發(fā)服務(wù)端和客戶端時(shí)都會(huì)用到；

3. 下面是helloworld.pb.go的代碼片段，作用是服務(wù)注冊(cè)，入?yún)⑹荊reeterServer是個(gè)接口，由此可以推測：在服務(wù)端，由具體的業(yè)務(wù)代碼來實(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)}

4. 借助GoLand的Structure面板，可以進(jìn)一步觀察helloworld.pb.go：
   

編寫服務(wù)端代碼server.go并啟動(dòng)

1. 在$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ù)代碼在此寫，客戶端遠(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)聽的協(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("開始監(jiān)聽，等待遠(yuǎn)程調(diào)用...")if err := s.Serve(lis); err != nil {
   
   
   
		log.Fatalf("failed to serve: %v", err)}}

2. 在server.go所在目錄執(zhí)行go run server.go，控制臺(tái)提示如下：

[golang@centos7 server]$ go run server.go 
2020/12/13 08:20:32 開始監(jiān)聽，等待遠(yuǎn)程調(diào)用...

3. 此時(shí)gRPC的服務(wù)端已經(jīng)啟動(dòng)，可以響應(yīng)遠(yuǎn)程調(diào)用，接下來開發(fā)客戶端代碼；

編寫客戶端代碼client.go并啟動(dòng)

1. 再打開一個(gè)控制臺(tái)；

2. 在$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ù)，如果沒有從命令行傳入，就用默認(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ù)端的返回信息打印出來
	log.Printf("Greeting: %s", r.GetMessage())}

3. 在client.go所在目錄執(zhí)行go run client.go，會(huì)立即向服務(wù)端發(fā)起遠(yuǎn)程調(diào)用，控制臺(tái)提示如下，可見得到了服務(wù)端的返回信息Hello world：

[golang@centos7 client]$ go run client.go
2020/12/13 08:38:05 Greeting: Hello world

4. 再去服務(wù)端的控制臺(tái)看一下，通過日志發(fā)現(xiàn)業(yè)務(wù)代碼被執(zhí)行，收到了遠(yuǎn)程請(qǐng)求的參數(shù)：

[golang@centos7 server]$ go run server.go 
2020/12/13 08:20:32 開始監(jiān)聽，等待遠(yuǎn)程調(diào)用...
2020/12/13 08:38:05 Received: world

5. 回到客戶端控制臺(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

6. 再去服務(wù)端的控制臺(tái)看一下，成功收到了abc：

[golang@centos7 server]$ go run server.go 
2020/12/13 08:20:32 開始監(jiān)聽，等待遠(yuǎn)程調(diào)用...
2020/12/13 08:38:05 Received: world
2020/12/13 08:56:36 Received: abc

到此，相信大家對(duì)“GO版gRPC開發(fā)方法是什么”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！