欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Go?gRPC教程實現(xiàn)Simple?RPC

 更新時間:2022年06月15日 17:26:25   作者:煙花易冷人憔悴  
這篇文章主要為大家介紹了Go?gRPC教程實現(xiàn)Simple?RPC示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

前言

gRPC主要有4種請求和響應(yīng)模式,分別是簡單模式(Simple RPC)、服務(wù)端流式(Server-side streaming RPC)、客戶端流式(Client-side streaming RPC)、和雙向流式(Bidirectional streaming RPC)。

  • 簡單模式(Simple RPC):客戶端發(fā)起請求并等待服務(wù)端響應(yīng)。
  • 服務(wù)端流式(Server-side streaming RPC):客戶端發(fā)送請求到服務(wù)器,拿到一個流去讀取返回的消息序列。 客戶端讀取返回的流,直到里面沒有任何消息。
  • 客戶端流式(Client-side streaming RPC):與服務(wù)端數(shù)據(jù)流模式相反,這次是客戶端源源不斷的向服務(wù)端發(fā)送數(shù)據(jù)流,而在發(fā)送結(jié)束后,由服務(wù)端返回一個響應(yīng)。
  • 雙向流式(Bidirectional streaming RPC):雙方使用讀寫流去發(fā)送一個消息序列,兩個流獨立操作,雙方可以同時發(fā)送和同時接收。

本篇文章先介紹簡單模式。

新建proto文件

主要是定義我們服務(wù)的方法以及數(shù)據(jù)格式,我們使用上一篇的simple.proto文件。

1.定義發(fā)送消息的信息

message SimpleRequest{
    // 定義發(fā)送的參數(shù),采用駝峰命名方式,小寫加下劃線,如:student_name
    string data = 1;//發(fā)送數(shù)據(jù)
}

2.定義響應(yīng)信息

message SimpleResponse{
    // 定義接收的參數(shù)
    // 參數(shù)類型 參數(shù)名 標識號(不可重復(fù))
    int32 code = 1;  //狀態(tài)碼
    string value = 2;//接收值
}

3.定義服務(wù)方法Route

// 定義我們的服務(wù)(可定義多個服務(wù),每個服務(wù)可定義多個接口)
service Simple{
    rpc Route (SimpleRequest) returns (SimpleResponse){};
}

4.編譯proto文件

我這里使用上一篇介紹的VSCode-proto3插件,保存后自動編譯。

指令編譯方法,進入simple.proto文件所在目錄,運行:

protoc --go_out=plugins=grpc:./ ./simple.proto

創(chuàng)建Server端

1.定義我們的服務(wù),并實現(xiàn)Route方法

import (
	"context"
	"log"
	"net"
	"google.golang.org/grpc"
	pb "go-grpc-example/proto"
)
// SimpleService 定義我們的服務(wù)
type SimpleService struct{}
// Route 實現(xiàn)Route方法
func (s *SimpleService) Route(ctx context.Context, req *pb.SimpleRequest) (*pb.SimpleResponse, error) {
	res := pb.SimpleResponse{
		Code:  200,
		Value: "hello " + req.Data,
	}
	return &res, nil
}

該方法需要傳入RPC的上下文context.Context,它的作用結(jié)束超時或取消的請求。更具體的說請參考該文章

2.啟動gRPC服務(wù)器

const (
	// Address 監(jiān)聽地址
	Address string = ":8000"
	// Network 網(wǎng)絡(luò)通信協(xié)議
	Network string = "tcp"
)
func main() {
	// 監(jiān)聽本地端口
	listener, err := net.Listen(Network, Address)
	if err != nil {
		log.Fatalf("net.Listen err: %v", err)
	}
	log.Println(Address + " net.Listing...")
	// 新建gRPC服務(wù)器實例
	grpcServer := grpc.NewServer()
	// 在gRPC服務(wù)器注冊我們的服務(wù)
	pb.RegisterSimpleServer(grpcServer, &SimpleService{})
	//用服務(wù)器 Serve() 方法以及我們的端口信息區(qū)實現(xiàn)阻塞等待,直到進程被殺死或者 Stop() 被調(diào)用
	err = grpcServer.Serve(listener)
	if err != nil {
		log.Fatalf("grpcServer.Serve err: %v", err)
	}
}

里面每個方法的作用都有注釋,這里就不解析了。
運行服務(wù)端

go run server.go
:8000 net.Listing...

創(chuàng)建Client端

import (
	"context"
	"log"
	"google.golang.org/grpc"
	pb "go-grpc-example/proto"
)
const (
	// Address 連接地址
	Address string = ":8000"
)
func main() {
	// 連接服務(wù)器
	conn, err := grpc.Dial(Address, grpc.WithInsecure())
	if err != nil {
		log.Fatalf("net.Connect err: %v", err)
	}
	defer conn.Close()
	// 建立gRPC連接
	grpcClient := pb.NewSimpleClient(conn)
	// 創(chuàng)建發(fā)送結(jié)構(gòu)體
	req := pb.SimpleRequest{
		Data: "grpc",
	}
	// 調(diào)用我們的服務(wù)(Route方法)
	// 同時傳入了一個 context.Context ,在有需要時可以讓我們改變RPC的行為,比如超時/取消一個正在運行的RPC
	res, err := grpcClient.Route(context.Background(), &req)
	if err != nil {
		log.Fatalf("Call Route err: %v", err)
	}
	// 打印返回值
	log.Println(res)
}

運行客戶端

go run client.go
code:200 value:"hello grpc"

成功調(diào)用Server端的Route方法并獲取返回的數(shù)據(jù)。

總結(jié)

本篇介紹了簡單RPC模式,客戶端發(fā)起請求并等待服務(wù)端響應(yīng)。

教程源碼地址:https://github.com/Bingjian-Zhu/go-grpc-example

參考:gRPC官方文檔中文版

更多關(guān)于Go gRPC教程Simple RPC的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • Go?gRPC進階教程gRPC轉(zhuǎn)換HTTP

    Go?gRPC進階教程gRPC轉(zhuǎn)換HTTP

    這篇文章主要為大家介紹了Go?gRPC進階教程gRPC轉(zhuǎn)換HTTP教程示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-06-06
  • 詳解Golang中errors包如何返回自定義error類型

    詳解Golang中errors包如何返回自定義error類型

    這篇文章主要為大家詳細介紹了Golang中errors包如何返回自定義error類型,文中的示例代碼簡潔易懂,有需要的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2023-09-09
  • Golang連接PostgreSQL基本操作的實現(xiàn)

    Golang連接PostgreSQL基本操作的實現(xiàn)

    PostgreSQL是常見的免費的大型關(guān)系型數(shù)據(jù)庫,本文主要介紹了Golang連接PostgreSQL基本操作的實現(xiàn),具有一定的參考價值,感興趣的可以了解一下
    2024-02-02
  • Go處理PDF的實現(xiàn)代碼

    Go處理PDF的實現(xiàn)代碼

    這篇文章主要介紹了Go處理PDF的實現(xiàn)代碼,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-01-01
  • Go語言的Channel遍歷方法詳解

    Go語言的Channel遍歷方法詳解

    這篇文章主要介紹了Go語言的Channel遍歷方法詳解,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-04-04
  • Go的gin參數(shù)校驗中的validator庫詳解

    Go的gin參數(shù)校驗中的validator庫詳解

    這篇文章主要介紹了Go的gin參數(shù)校驗之validator庫,使用 validator 以后,只需要在定義結(jié)構(gòu)體時使用 binding 或 validate tag標識相關(guān)校驗規(guī)則,就可以進行參數(shù)校驗了,而不用自己單獨去寫常見的校驗規(guī)則,需要的朋友可以參考下
    2023-08-08
  • 詳解Go語言中init的使用與常見應(yīng)用場景

    詳解Go語言中init的使用與常見應(yīng)用場景

    Go?中有一個特別的?init()?函數(shù),它主要用于包的初始化,這篇文章將以此為主題介紹?Go?中?init()?函數(shù)的使用和常見使用場景,希望對大家有所幫助
    2024-02-02
  • Go語言計算指定年月天數(shù)的方法

    Go語言計算指定年月天數(shù)的方法

    這篇文章主要介紹了Go語言計算指定年月天數(shù)的方法,實例分析了Go語言操作時間的技巧,具有一定參考借鑒價值,需要的朋友可以參考下
    2015-02-02
  • Go語言實現(xiàn)牛頓法求平方根函數(shù)的案例

    Go語言實現(xiàn)牛頓法求平方根函數(shù)的案例

    這篇文章主要介紹了Go語言實現(xiàn)牛頓法求平方根函數(shù)的案例,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-12-12
  • GO語言的控制語句詳解包括GO語言的指針語法

    GO語言的控制語句詳解包括GO語言的指針語法

    這篇文章主要介紹了GO語言的控制語句詳解包括GO語言的指針語法,GO語言switch結(jié)構(gòu),GO語言for的4種結(jié)構(gòu)需要的朋友可以參考下
    2022-12-12

最新評論