我的Go gRPC之旅、01 初識gRPC，感受gRPC的強大魅力

来源:https://www.cnblogs.com/linxiaoxu/archive/2022/09/18/16705386.html
-Advertisement-
Play Games

我的gRPC之旅。本節介紹微服務架構、強弱類型介面、Rest、gRPC定義，proto編譯方式，並用golang編寫一個簡單的gRPC托管服務和客戶端。在調試中進步，感受gRPC的魅力。 ...


微服務架構

微服務是一種開發軟體的架構和組織方法，其中軟體由通過明確定義的API 進行通信的小型獨立服務組成。 這些服務由各個小型獨立團隊負責。 微服務架構使應用程式更易於擴展和更快地開發，從而加速創新並縮短新功能的上市時間。

將軟體應用程式構建為一組獨立、自治（獨立開發、部署和擴展）、松耦合、面向業務能力（強調能力，而不是完成任務）的服務。

為什麼微服務軟體系統需要藉助進程間（服務間，應用程式間）通信技術？

傳統軟體系統被進一步拆分為一組細粒度，自治和麵向業務能力的實體，也就是微服務。

強、弱類型介面

服務API介面有強、弱類型之分。
強類型介面
 傳統的RPC服務（定製二進位協議 ，對消息進行編碼和解碼），採用TCP傳輸消息。RPC服務通常有嚴格的契約，開發服務前需要使用IDL（Interface description language）定義契約，最終通過契約自動生成強類型的伺服器端、客戶端的介面。服務調用直接使用強類型的客戶端。（GRPC、Thrift）

  • 優點：不需要手動的編碼和解碼、介面規範、自動代碼生成、編譯器自動類型檢查。
  • 缺點：服務端和客戶端強耦合、任何一方升級改動可能會造成另一方break。自動代碼生成需要工具支持，開發這些工具的成本比較高。強類型介面開發測試不友好、瀏覽器、Postman這些工具無法直接訪問這些強類型介面。

弱類型介面
 Restful服務通常採用JSON作為傳輸消息，使用HTTP作為傳輸協議，沒有嚴格契約的概念，使用普通的HTTP Client即可調用。調用方需要對JSON消息進行手動的編碼和解碼工作。（Springboot）

  • 優點：服務端和客戶端非強耦合、開發測試友好。
  • 缺點：調用方手動編碼解碼，沒有自動代碼生成、沒有編譯期介面類型檢查、相對不規範、容易出現運行期錯誤。

Rest

描述性狀態轉移架構，是面向資源架構的基礎。將分散式應用程式建模為資源集合，訪問這些資源的客戶端可以變更這些資源的狀態。有三大局限性。

  • 基於文本的低效消息協議

  • 應用程式之間缺乏強類型介面

  • 架構風格難以強制實施

gRPC

gRPC 是一項進程間通信技術，用來連接、調用、操作和調試分散式異構應用程式。

定義服務介面

開發gRPC應用需要先定義服務介面，使用的語言叫做 介面定義語言

  • 確定消費者消費服務的方式
  • 消費者遠程調用的方法和傳入的參數和消息格式

優勢

  • 提供高效的進程間通信。不使用json、xml，基於在HTTP/2之上的protocol buffers的二進位協議
  • 簡單且定義良好的服務介面和模式
  • 屬於強類型介面。構建跨團隊、技術類型的雲原生應用程式，對於其所產生的的大多數運行時錯誤和互操作錯誤們可以通過靜態類型來剋服
  • 支持多語言
  • 支持雙工流。同時構建傳統請求-響應風格的消息以及客戶端流和服務端流
  • 商業化特性內置支持
  • 與雲原生生態系統進行了集成

劣勢

  • 不太適合面向外部服務
  • 巨大的服務定義變更是複雜的開發流程
  • 生態系統相對較小

編寫gRPC服務

創建 client、service 目錄，分別用指令生成 go.mod 文件

go mod init productinfo/client
go mod init productinfo/service

目錄結構

PS C:\Users\小能喵喵喵\Desktop\Go\gRPC\chapter2\productinfo> tree /f
├─client
│  │  client.go
│  │  go.mod
│  │  go.sum
│  │
│  ├─bin
│  │      client.exe
│  │
│  └─ecommerce
│          product_info.pb.go
│          product_info.proto
│          product_info_grpc.pb.go
│
└─service
    │  go.mod
    │  go.sum
    │  server.go
    │  service.go
    │
    ├─bin
    │      server.exe
    │
    └─ecommerce
            product_info.pb.go
            product_info.proto
            product_info_grpc.pb.go

product_info.proto 介面定義

syntax = "proto3";

package ecommerce;
option go_package = ".";

service ProductInfo {
  rpc addProduct (Product) returns (ProductID);
  rpc getProduct (ProductID) returns (Product);
}

message Product{
  string id = 1;
  string name = 2;
  string description = 3;
  float price = 4;
}

message ProductID {
  string value = 1;
}

編譯工具

安裝：Release Protocol Buffers v21.6 · protocolbuffers/protobuf (github.com)

教程：Go Generated Code | Protocol Buffers | Google Developers

註： $GOPATH/bin要添加到系統環境變數里

protoc-gen-go-grpc: program not found or is not executable 解決方案

go get -u google.golang.org/protobuf/cmd/protoc-gen-go
go install google.golang.org/protobuf/cmd/protoc-gen-go
go get -u google.golang.org/grpc/cmd/protoc-gen-go-grpc
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc

Please specify either:
  • a "go_package" option in the .proto source file, or
  • a "M" argument on the command line.

解決方案 在syntax=”proto3″;下一行增加option go_package配置項。

編譯方法

protoc [opt...] file.proto
/* 例如 */ 
protoc --proto_path=src --go_out=out --go_opt=paths=source_relative foo.proto
  • 當前版本編譯時，之前的方法protoc --go_out=plugins=grpc:. *.proto不再使用，轉而用protoc --go_out=. --go-grpc_out=. ./hello.proto代替。
  • go_out=. 指定生成的pb.go文件所在目錄(如果沒有該目錄，需要手動提前創建)，.代表當前protoc執行目錄，結合.proto文件中的option go_package，其最終的生成文件目錄為go_out指定目錄/go_package指定目錄，go-grpc_out針對_grpc.pb.go文件，同理。
  • --go_opt=paths=source_relative，其含義代表生成的.pb.go文件路徑不依賴於.proto文件中的option go_package配置項，直接在go_out指定的目錄下生成.pb.go文件（.pb.go文件的package名還是由option go_package決定）。--go-grpc_opt=paths=source_relative，針對_grpc.pb.go文件，同理。
PS C:\Users\小能喵喵喵\Desktop\Go\gRPC\chapter2\productinfo\service\ecommerce>
protoc --go_out=. --go-grpc_out=. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative ./product_info.proto

image-20220918162836068

Product和ProductID結構體定義在product_info.pb.go文件中，通過product_info.proto自動生成。

service.go 業務邏輯代碼

package main

import (
	"context"
	pb "productinfo/service/ecommerce" // ^ 導入 protobuf編譯器生成代碼的包

	"github.com/google/uuid"
	"google.golang.org/grpc/codes"
	"google.golang.org/grpc/status"
)

// ^ 實現 service/ecommerce 服務
type service struct {
	pb.UnimplementedProductInfoServer
	productMap map[string]*pb.Product
}

// ^ 實現方法邏輯、添加商品
// ^ ctx 對象包含一些元數據，比如終端用戶授權令牌標識和請求的截止時間
func (s *service) AddProduct(ctx context.Context, in *pb.Product) (*pb.ProductID, error) {
	out, err := uuid.NewUUID() // ^ 通用唯一標示符
	if err != nil {
		return nil, status.Errorf(codes.Internal, "生成產品編碼時出錯", err)
	}
	in.Id = out.String()
	if s.productMap == nil {
		s.productMap = make(map[string]*pb.Product)
	}
	s.productMap[in.Id] = in
	return &pb.ProductID{Value: in.Id}, status.New(codes.OK, "").Err()
}

func (s *service) GetProduct(ctx context.Context, in *pb.ProductID) (*pb.Product, error) {
	value, exists := s.productMap[in.Value]
	if exists {
		return value, status.New(codes.OK, "").Err()
	}
	return nil, status.Errorf(codes.NotFound, "商品條目不存在", in.Value)
}

server.go 托管服務的gRPC伺服器

前向相容

前向相容一般指向上相容。 向上相容（Upward Compatible）又稱向前相容（Forward Compatible），在某一平臺的較低版本環境中編寫的程式可以在較高版本的環境中運行。

無法傳遞給RegisterXXXService方法

新版protoc-gen-go不支持grpc服務生成，需要通過protoc-gen-go-grpc生成grpc服務介面，但是生成的Server端介面中會出現一個mustEmbedUnimplemented***方法，為瞭解決前向相容問題（現在的相容未來的），如果不解決，就無法傳遞給RegisterXXXService方法。

  • 在grpc server實現結構體中匿名嵌入Unimplemented***Server結構體
  • 使用protoc生成server代碼時命令行加上關閉選項，protoc --go-grpc_out=require_unimplemented_servers=false
package main

import (
	"fmt"
	"log"
	"net"
	pb "productinfo/service/ecommerce"

	"google.golang.org/grpc"
)

const (
	ip   = "127.0.0.1"
	port = "23333"
)

func main() {
	lis, err := net.Listen("tcp", fmt.Sprintf("%v:%v", ip, port))
	if err != nil {
		log.Fatalf("無法監聽埠 %v %v", port, err)
	}
	s := grpc.NewServer()
	pb.RegisterProductInfoServer(s, &service{})
	log.Println("gRPC伺服器開始監聽", port)
	if err := s.Serve(lis); err != nil {
		log.Fatalf("提供服務失敗: %v", err)
	}
}

2022/09/18 17:17:30 gRPC伺服器開始監聽 23333

client.go 客戶端代碼

重新編譯proto

創建一個client目錄，並重新之前mod init、編譯proto的操作。

PS C:\Users\小能喵喵喵\Desktop\Go\gRPC\chapter2\productinfo\client\ecommerce> 
protoc --go_out=. --go-grpc_out=. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative ./product_info.proto

grpc.WithInsecure已棄用

grpc.WithInsecure is Deprecated: use WithTransportCredentials and insecure.NewCredentials() instead. Will be supported throughout 1.x.

The function insecure.NewCredentials returns an implementation of credentials.TransportCredentials.

grpc.Dial(":9950", grpc.WithTransportCredentials(insecure.NewCredentials()))

代碼

package main

import (
	"context"
	"log"
	"time"

	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials/insecure"

	pb "productinfo/client/ecommerce"
)

const (
	address = "localhost:23333"
)

func main() {
	conn, err := grpc.Dial(address, grpc.WithTransportCredentials(insecure.NewCredentials())) // ^ 不安全地創建端到端連接
	if err != nil {
		log.Fatalf("did not connect: %v", err)
	}
	c := pb.NewProductInfoClient(conn) // ^ 傳遞連接並創建存根實例,包含所有遠程調用方法
	name := "小米 10 Pro"
	description := "雷軍說:Are you ok?"
	price := float32(2000.0)
	ctx, cancel := context.WithTimeout(context.Background(), time.Second) // ^ 用於傳遞元數據:用戶標識,授權令牌,請求截止時間
	defer cancel()
	r, err := c.AddProduct(ctx, &pb.Product{
		Name: name, Price: price, Description: description,
	})
	if err != nil {
		log.Fatalf("無法添加商品 %v", err)
	}
	log.Printf("添加商品成功 %v", r.Value)
	/* -------------------------------------------------------------------------- */
	product, err := c.GetProduct(ctx, &pb.ProductID{Value: r.Value})
	if err != nil {
		log.Fatalf("獲取不到商品 %v", err)
	}
	log.Println("Product: ", product.String())
}

構建運行

分別進入service，client文件夾執行如下命令。構建二進位文件並運行（可以交叉編譯運行在其他操作系統上）。

PS C:\Users\小能喵喵喵\Desktop\Go\gRPC\chapter2\productinfo\service> 
go build -o bin/server.exe   
PS C:\Users\小能喵喵喵\Desktop\Go\gRPC\chapter2\productinfo\client> 
go build -o bin/client.exe

image-20220918175935419

image-20220918180006848

參考資料


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 我的Go併發之旅、02 基本併發原語
    **註：**本文所有函數名為中文名，並不符合代碼規範，僅供讀者理解參考。 Goroutine Go程不是OS線程，也不是綠色線程（語言運行時管理的線程），而是更高級別的抽象，一種特殊的協程。是一種非搶占式的簡單併發子goroutine（函數、閉包、方法）。不能被中斷，但有多個point可以暫停或重新 ...
  • C++ 左值引用與 const 關鍵字
    左值引用是已定義的變數的別名，其主要用途是用作函數的形參，將 const 關鍵字用於左值引用時，其在初始化時可接受的賦值形式變得更加廣泛了，這裡來總結一下。 ...
  • day40-網路編程02
    Java網路編程02 4.TCP網路通信編程 基本介紹 基於客戶端--服務端的網路通信 底層使用的是TCP/IP協議 應用場景舉例：客戶端發送數據，服務端接收並顯示控制台 基於Scoket的TCP編程 4.1應用案例1:(使用位元組流) 編寫一個伺服器端，和一個客戶端 伺服器端在9999埠監聽 客戶 ...
  • 類裝飾器
    2022-09-18 類裝飾器的定義： 使用一個類作為一個裝飾器，在類裡面對已有函數添加其他功能。 類裝飾器使用的一個實例： 1 class MyDecorator(object): 2 def __init__(self,func): 3 self.__func = func 4 5 def __ ...
  • 帶有參數的裝飾器
    2022-09-18 帶有參數的裝飾器的實質： 因為裝飾器是不能在帶有參數，所以要定義帶有參數的裝飾器應該換一種思路。在裝飾器的外面套一個函數，使用該函數返回這個裝飾器。 帶有參數的裝飾器的實例： 1 # 裝飾器 2 def return_decorator(flag): 3 def decorat ...
  • 使用多個裝飾器
    2022-09-18 多個裝飾器使用的實例： 1 # 定義一個裝飾器 2 def make_p(func): 3 print("執行裝飾器make_p") 4 5 def inner(): 6 # 對已有函數增加新的功能 7 result = "<p>" + func() + "</p>" 8 # ...
  • 深入理解C++的new和delete
    一、C++中的動態記憶體管理方式 C語言中的動態管理方式是用malloc、free函數，它們在C++仍然可以繼續使用，但是由於在部分地方略顯無能為力，且使用起來比較麻煩，所以C++提出了自己的記憶體管理方式：採用new、delete關鍵字去進行動態記憶體管理。 註意：C語言開闢空間所用的malloc、ca ...
  • 從華為離職了
    作者：Bai Bing 原文：https://zhuanlan.zhihu.com/p/485029198 遺憾的是，我轉正後看到了大家的能力和努力，也意識到在預期的時間內難以達到我想要的高度，最終經過各方面的考慮，決定放棄這個職位，重新回到外企找回適合我的節奏。 依依不捨的離職後，回想起來，覺得我 ...
一周排行
    -Advertisement-
    Play Games
  • .net 6 C#中System.IO.Path類的用法
    1. 說明 /* Performs operations on System.String instances that contain file or directory path information. These operations are performed in a cross-pla ...
  • 使用WebApi+Vue3從0到1搭建《許可權管理系統》:二、搭建JWT系統鑒權
    視頻地址：【WebApi+Vue3從0到1搭建《許可權管理系統》系列視頻：搭建JWT系統鑒權-嗶哩嗶哩】 https://b23.tv/R6cOcDO qq群:801913255 一、在appsettings.json中設置鑒權屬性 /*jwt鑒權*/ "JwtSetting": { "Issuer" ...
  • 實戰指南：使用 xUnit 和 ASP.NET Core 進行集成測試【完整教程】
    引言 集成測試可在包含應用支持基礎結構（如資料庫、文件系統和網路）的級別上確保應用組件功能正常。 ASP.NET Core 通過將單元測試框架與測試 Web 主機和記憶體中測試伺服器結合使用來支持集成測試。 簡介 集成測試與單元測試相比，能夠在更廣泛的級別上評估應用的組件，確認多個組件一起工作以生成預 ...
  • .NET Emit 入門教程：第六部分：IL 指令：9：詳解 ILGenerator 指令方法：運算操作指令（指令篇結束）
    在.NET Emit編程中，我們探討了運算操作指令的重要性和應用。這些指令包括各種數學運算、位操作和比較操作，能夠在動態生成的代碼中實現對數據的處理和操作。通過這些指令，開發人員可以靈活地進行算術運算、邏輯運算和比較操作，從而實現各種複雜的演算法和邏輯......本篇之後，將進入第七部分：實戰項目 ...
  • WPF多表頭表格實現
    前言 多表頭表格是一個常見的業務需求，然而WPF中卻沒有預設實現這個功能，得益於WPF強大的控制項模板設計，我們可以通過修改控制項模板的方式自己實現它。 一、需求分析 下圖為一個典型的統計表格，統計1-12月的數據。 此時我們有一個需求，需要將月份按季度劃分，以便能夠直觀地看到季度統計數據，以下為該需求 ...
  • gRPC入門學習之旅（七）
    如何將 ASP.NET Core MVC 項目的視圖分離到另一個項目 在當下這個年代 SPA 已是主流，人們早已忘記了 MVC 以及 Razor 的故事。但是在某些場景下 SSR 還是有意想不到效果。比如某些靜態頁面，比如追求首屏載入速度的時候。最近在項目中回歸傳統效果還是不錯。 有的時候我們希望將 ...
  • System.AggregateException: 發生一個或多個錯誤.....
    System.AggregateException: 發生一個或多個錯誤。 > Microsoft.WebTools.Shared.Exceptions.WebToolsException: 生成失敗。檢查輸出視窗瞭解更多詳細信息。 內部異常堆棧跟蹤的結尾 > (內部異常 #0) Microsoft ...
  • 精通中間件測試：Asp.Net Core實戰指南，提升應用穩定性和可靠性
    引言 在上一章節我們實戰了在Asp.Net Core中的項目實戰，這一章節講解一下如何測試Asp.Net Core的中間件。 TestServer 還記得我們在集成測試中提供的TestServer嗎？ TestServer 是由 Microsoft.AspNetCore.TestHost 包提供的。 ...
  • Case表達式
    在發現結果為真的WHEN子句時,CASE表達式的真假值判斷會終止,剩餘的WHEN子句會被忽略: CASE WHEN col_1 IN ('a', 'b') THEN '第一' WHEN col_1 IN ('a') THEN '第二' ELSE '其他' END 註意: 統一各分支返回的數據類型. ...
  • 揭秘：C#語法中“_ =” 是什麼？
    在C#編程世界中，語法的精妙之處往往體現在那些看似微小卻極具影響力的符號與結構之中。其中，“_ =” 這一組合突然出現還真不知道什麼意思。本文將深入剖析“_ =” 的含義、工作原理及其在實際編程中的廣泛應用，揭示其作為C#語法奇兵的重要角色。 一、下劃線 _：神秘的棄元符號 下劃線 _ 在C#中並非 ...
所有分類