最近2018中文字幕在日韩欧美国产成人片_国产日韩精品一区二区在线_在线观看成年美女黄网色视频_国产精品一区三区五区_国产精彩刺激乱对白_看黄色黄大色黄片免费_人人超碰自拍cao_国产高清av在线_亚洲精品电影av_日韩美女尤物视频网站

RELATEED CONSULTING
相關咨詢
選擇下列產品馬上在線溝通
服務時間:8:30-17:00
你可能遇到了下面的問題
關閉右側工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
GO版gRPC開發(fā)方法是什么

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

讓客戶滿意是我們工作的目標,不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術通過有效、簡單的方式提供給客戶,將通過不懈努力成為客戶在信息化領域值得信任、有價值的長期合作伙伴,公司提供的服務項目有:國際域名空間、網(wǎng)頁空間、營銷軟件、網(wǎng)站建設、冀州網(wǎng)站維護、網(wǎng)站推廣。

環(huán)境相關

  • 接下來的開發(fā)都是在$GOPATH目錄下進行的,我這里的真實目錄是/home/golang/gopath;

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

  • 在完成本篇的所有開發(fā)后,最終$GOPATH/src/helloworld目錄下的內容如下:

[golang@centos7 src]$ tree helloworld/
helloworld/
├── client
│   └── client.go
├── helloworld.pb.go
├── helloworld.proto
└── server
    └── server.go

2 directories, 4 files

編寫proto文件

  • proto文件用來描述遠程服務相關的信息,如方法簽名、數(shù)據(jù)結構等,本篇的proto文件名為helloworld.proto,位置是$GOPATH/src/helloworld,內容如下:

// 協(xié)議類型syntax = "proto3";// 包名package helloworld;// 定義的服務名service Greeter {
   
   
   
  // 具體的遠程服務方法
  rpc SayHello (HelloRequest) returns (HelloReply) {
   
   
   }}// SayHello方法的入?yún)?,只有一個字符串字段message HelloRequest {
   
   
   
  string name = 1;}// SayHello方法的返回值,只有一個字符串字段message HelloReply {
   
   
   
  string message = 1;}

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

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

protoc --go_out=plugins=grpc:. helloworld.proto
  1. 如果helloworld.proto沒有語法錯誤,會在當前目錄生成文件helloworld.pb.go,這里面是工具protoc-gen-go自動生成的代碼,里面生成的代碼在開發(fā)服務端和客戶端時都會用到;

  2. 下面是helloworld.pb.go的代碼片段,作用是服務注冊,入?yún)⑹荊reeterServer是個接口,由此可以推測:在服務端,由具體的業(yè)務代碼來實現(xiàn)GreeterServer接口,并且調用RegisterGreeterServer方法注冊,這樣客戶端遠程調用的服務就可以實現(xiàn)業(yè)務功能了:

func RegisterGreeterServer(s *grpc.Server, srv GreeterServer) {
   
   
   
	s.RegisterService(&_Greeter_serviceDesc, srv)}type GreeterServer interface {
   
   
   // 具體的遠程服務方法SayHello(context.Context, *HelloRequest) (*HelloReply, error)}
  1. 借助GoLand的Structure面板,可以進一步觀察helloworld.pb.go:
    GO版gRPC開發(fā)方法是什么

編寫服務端代碼server.go并啟動

  1. 在$GOPATH/src/helloworld目錄下新建文件夾server,在此文件夾下新建server.go,內容如下,已經(jīng)添加詳細注釋:

package mainimport ("context""log""net""google.golang.org/grpc"
	pb "helloworld")const (
	port = ":50051")// 定義結構體,在調用注冊api的時候作為入?yún)ⅲ?
// 該結構體會帶上SayHello方法,里面是業(yè)務代碼
// 這樣遠程調用時就執(zhí)行了業(yè)務代碼了type server struct {
   
   
   
	// pb.go中自動生成的,是個空結構體
	pb.UnimplementedGreeterServer}// 業(yè)務代碼在此寫,客戶端遠程調用SayHello時,
// 會執(zhí)行這里的代碼
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
   
   
   
	// 打印請求參數(shù)
	log.Printf("Received: %v", in.GetName())
	// 實例化結構體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)}

	// 實例化gRPC server結構體
	s := grpc.NewServer()

	// 服務注冊
	pb.RegisterGreeterServer(s, &server{
   
   
   })

	log.Println("開始監(jiān)聽,等待遠程調用...")if err := s.Serve(lis); err != nil {
   
   
   
		log.Fatalf("failed to serve: %v", err)}}
  1. 在server.go所在目錄執(zhí)行go run server.go,控制臺提示如下:

[golang@centos7 server]$ go run server.go 
2020/12/13 08:20:32 開始監(jiān)聽,等待遠程調用...
  1. 此時gRPC的服務端已經(jīng)啟動,可以響應遠程調用,接下來開發(fā)客戶端代碼;

編寫客戶端代碼client.go并啟動

  1. 再打開一個控制臺;

  2. 在$GOPATH/src/helloworld目錄下新建文件夾client,在此文件夾下新建client.go,內容如下,已經(jīng)添加詳細注釋:

package mainimport ("context""log""os""time""google.golang.org/grpc"
	pb "helloworld")const (
	address     = "localhost:50051"
	defaultName = "world")func main() {
   
   
   // 遠程連接服務端
	conn, err := grpc.Dial(address, grpc.WithInsecure(), grpc.WithBlock())if err != nil {
   
   
   
		log.Fatalf("did not connect: %v", err)}// main方法執(zhí)行完畢后關閉遠程連接defer conn.Close()// 實例化數(shù)據(jù)結構
	c := pb.NewGreeterClient(conn)// 遠程調用的請求參數(shù),如果沒有從命令行傳入,就用默認值
	name := defaultName	if len(os.Args) > 1 {
   
   
   
		name = os.Args[1]}// 超時設置
	ctx, cancel := context.WithTimeout(context.Background(), time.Second)defer cancel()// 遠程調用
	r, err := c.SayHello(ctx, &pb.HelloRequest{
   
   
   Name: name})if err != nil {
   
   
   
		log.Fatalf("could not greet: %v", err)}// 將服務端的返回信息打印出來
	log.Printf("Greeting: %s", r.GetMessage())}
  1. 在client.go所在目錄執(zhí)行go run client.go,會立即向服務端發(fā)起遠程調用,控制臺提示如下,可見得到了服務端的返回信息Hello world:

[golang@centos7 client]$ go run client.go
2020/12/13 08:38:05 Greeting: Hello world
  1. 再去服務端的控制臺看一下,通過日志發(fā)現(xiàn)業(yè)務代碼被執(zhí)行,收到了遠程請求的參數(shù):

[golang@centos7 server]$ go run server.go 
2020/12/13 08:20:32 開始監(jiān)聽,等待遠程調用...
2020/12/13 08:38:05 Received: world
  1. 回到客戶端控制臺,在命令行帶參數(shù)試試,輸入go run client.go abc,收到服務端響應如下:

[golang@centos7 client]$ go run client.go abc
2020/12/13 08:56:36 Greeting: Hello abc
  1. 再去服務端的控制臺看一下,成功收到了abc:

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

到此,相信大家對“GO版gRPC開發(fā)方法是什么”有了更深的了解,不妨來實際操作一番吧!這里是創(chuàng)新互聯(lián)網(wǎng)站,更多相關內容可以進入相關頻道進行查詢,關注我們,繼續(xù)學習!


名稱欄目:GO版gRPC開發(fā)方法是什么
轉載源于:http://fisionsoft.com.cn/article/pciscp.html