建站
咨詢
售后
建站咨詢
新聞中心
早期的微服務(wù)實現(xiàn)利用了代表性狀態(tài)傳輸(REST)架構(gòu)作為事實上的通信技術(shù)。然而，充分利用REST的服務(wù)常常適用于面向外部的服務(wù)，這些服務(wù)直接暴露給消費者。由于它們基于傳統(tǒng)的基于文本的消息傳遞(JSON、XML和CVS over HTTP等)――針對人類進行了優(yōu)化，因此這些不是內(nèi)部服務(wù)間通信的理想選擇。
相反，使用一種基于文本的消息傳遞協(xié)議，我們可以利用針對服務(wù)間通信進行優(yōu)化的二進制協(xié)議。云原生計算基金會的gRPC(一種高性能的開源通用遠程過程調(diào)用框架)是服務(wù)間通信的理想選擇，因為它使用協(xié)議緩沖區(qū)(protocol buffer)作為服務(wù)間通信的二進制數(shù)據(jù)交換格式。
我們使用不同的技術(shù)和編程語言構(gòu)建多個微服務(wù)時，有一種標準的方法來定義服務(wù)接口和底層的消息交換格式很重要。gRPC提供了一種簡潔而強大的方法，可以使用協(xié)議緩沖區(qū)指定服務(wù)合約。因此，gRPC可能是最適合構(gòu)建內(nèi)部微服務(wù)間通信的解決方案。
我們在本文中將更深入地介紹為什么gRPC是構(gòu)建微服務(wù)間通信的一種出色選擇。
gRPC的基礎(chǔ)知識
有了gRPC，客戶可以對不同機器上的服務(wù)器應(yīng)用程序直接調(diào)用方法，好像該機器就是本地對象。gRPC立足于傳統(tǒng)的遠程過程調(diào)用(RPC)技術(shù)的基礎(chǔ)，但是實施在現(xiàn)代技術(shù)堆棧(比如HTTP2和協(xié)議緩沖區(qū)等)上，確保***的互操作性。
gRPC本身支持這種功能：使用gRPC接口定義語言(IDL)來定義服務(wù)合約。因此，作為服務(wù)定義的一部分，你可以指定可以遠程調(diào)用的方法以及參數(shù)和返回類型的數(shù)據(jù)結(jié)構(gòu)。
圖1表明了gRPC的使用，在線零售應(yīng)用程序作為庫存和產(chǎn)品搜索服務(wù)的一部分。 Inventory服務(wù)的合約使用gRPC IDL來定義，該IDL在inventory.proto文件中已有指定。因此，Inventory服務(wù)的開發(fā)人員應(yīng)先使用該服務(wù)來定義所有業(yè)務(wù)功能，然后利用proto文件生成服務(wù)端框架代碼。與之相仿，可以使用同樣的proto文件生成客戶端代碼(存根，stub)。
圖1
由于gRPC與編程語言無關(guān)，你可以使用異構(gòu)語言來構(gòu)建服務(wù)和客戶端。在這個例子中，我們使用Ballerina(ballerina.io)生成了Inventory服務(wù)代碼，使用Java生成了客戶端代碼。你可以使用GitHub上的這個源代碼來試試該示例。
庫存(inventory.proto)的服務(wù)合約如下所示：
- syntax = "proto3";
- package grpc_service;
- import "google/protobuf/wrappers.proto";
- service InventoryService {
- rpc getItemByName(google.protobuf.StringValue) returns (Items);
- rpc getItemByID(google.protobuf.StringValue) returns (Item);
- rpc addItem(Item) returns (google.protobuf.BoolValue);
- }
- message Items {
- string itemDesc = 1;
- repeated Item items = 2;
- }
- message Item {
- string id = 1;
- string name = 2;
- string description = 3;
- }
服務(wù)合約易于理解，可以在客戶端和服務(wù)之間共享。如果服務(wù)合約有任何變化，服務(wù)代碼和客戶端代碼都要重新生成。
比如說，以下代碼片段顯示了為Ballerina生成的gRPC服務(wù)的代碼。 對于我們在gRPC服務(wù)定義中的每個操作，都會生成相應(yīng)的Ballerina代碼。(Ballerina提供了開箱即用的功能，使用“ballerina grpc –input inventory.proto –output service-skeleton –mode service”或“ballerina grpc –input inventory.proto –output bal-client –mode client”，生成服務(wù)代碼或客戶端代碼)。
- import ballerina/grpc;
- import ballerina/io;
- endpoint grpc:Listener listener {
- host:"localhost",
- port:9000
- };
- @grpc:ServiceConfig
- service InventoryService bind listener {
- getItemByName(endpoint caller, string value) {
- // Implementation goes here.
- // You should return a Items
- }
- getItemByID(endpoint caller, string value) {
- // Creating a dummy inventory item
- Item requested_item;
- requested_item.id = value;
- requested_item.name = "Sample Item " + value ;
- requested_item.description = "Sample Item Desc for " + value;
- _ = caller->send(requested_item);
- _ = caller->complete();
- }
- addItem(endpoint caller, Item value) {
- // Implementation goes here.
- // You should return a boolean
- }
- }
至于客戶端，再次用Inventory服務(wù)的gRPC服務(wù)定義來生成產(chǎn)品搜索服務(wù)，這是一個Java(Spring Boot)服務(wù)。你可以使用maven插件為Spring Boot/Java服務(wù)生成客戶端存根(客戶端代碼嵌入在Spring Boot服務(wù)中)。調(diào)用生成的客戶端存根的客戶端代碼如下所示：
- package mfe.ch03.grpc;
- import com.google.protobuf.StringValue;
- import io.grpc.ManagedChannel;
- import io.grpc.ManagedChannelBuilder;
- public class InventoryClient {
- public static void main(String[] args) {
- ManagedChannel channel = ManagedChannelBuilder.forAddress("127.0.0.1", 9000)
- .usePlaintext()
- .build();
- InventoryServiceGrpc.InventoryServiceBlockingStub stub
- = InventoryServiceGrpc.newBlockingStub(channel);
- Inventory.Item item = stub.getItemByID(
- StringValue.newBuilder().setValue("123").build());
- System.out.println("Response : " + item.getDescription());
- }
- }
底層的通信
客戶端調(diào)用服務(wù)時，客戶端gRPC庫使用協(xié)議緩沖區(qū)，并編組(marshal)遠程過程調(diào)用，該調(diào)用隨后通過HTTP2來發(fā)送。在服務(wù)器端，請求解組(un-marshalled)，使用協(xié)議緩沖區(qū)執(zhí)行相應(yīng)的過程調(diào)用。響應(yīng)遵循從服務(wù)器到客戶端的類似的執(zhí)行流程。
使用gRPC開發(fā)服務(wù)和客戶端的主要優(yōu)點是，你的服務(wù)代碼或客戶端代碼不需要為解析JSON或類似的基于文本的消息格式(在代碼內(nèi)或隱含在Jackson等底層庫中，對服務(wù)代碼而言隱藏起來)操心。二進制格式解組、轉(zhuǎn)換成對象。此外，我們要處理多個微服務(wù)并確保和維護互操作性時，對通過IDL定義服務(wù)接口給予***支持是強大的功能。
用gRPC構(gòu)建微服務(wù)的實例
基于微服務(wù)的應(yīng)用程序由多個服務(wù)組成，并使用眾多編程語言構(gòu)建?；跇I(yè)務(wù)使用場景，你可以選擇最合適的技術(shù)來構(gòu)建服務(wù)。gRPC在這種多語言架構(gòu)中起到非常重要的作用。如圖2所示，產(chǎn)品搜索服務(wù)與另外多個服務(wù)進行通信，這些服務(wù)是使用gRPC作為通信協(xié)議構(gòu)建的。因此，我們可以為每個服務(wù)定義服務(wù)合約：庫存、電子品類和服裝品類等?，F(xiàn)在，如果你想要打造一種多語言架構(gòu)，可以使用不同的實現(xiàn)技術(shù)來生成服務(wù)框架。
圖2顯示了用Ballerina lang編寫的庫存服務(wù)、用Golang編寫的電子服務(wù)和用Vert.x(Java)編寫的服裝服務(wù)?？蛻舳诉€可以為這每個服務(wù)合約生成存根。
圖2
仔細研究圖2中的微服務(wù)通信風(fēng)格，可以看出gRPC用于所有內(nèi)部通信，而面向外部的通信可以基于REST或GraphQL。我們將REST用于面向外部的通信時，大多數(shù)外部客戶端可以將服務(wù)用作API(利用Open API等API定義技術(shù))，因為大多數(shù)外部客戶端知道如何與充分利用REST的HTTP服務(wù)進行通信。此外，我們可以使用GraphQL之類的技術(shù)，讓消費者可以根據(jù)特定的客戶需求來查詢服務(wù)，這是無法用gRPC提供便利的。
因此作為一般實踐，我們可以將gRPC用于內(nèi)部微服務(wù)之間的所有同步通信。其他同步消息傳遞技術(shù)(比如充分利用REST的服務(wù)和GraphQL)更適合面向外部的服務(wù)。
作者簡介：WSO2架構(gòu)團隊負責(zé)該公司集成平臺的開發(fā)工作，Kasun Indrasiri是該團隊的重要成員。之前，他作為產(chǎn)品主管參與開發(fā)了WSO2企業(yè)服務(wù)總線(ESB)。他撰有《WSO2 ESB入門》一書，并與人合著了《企業(yè)級微服務(wù)》。他是Apache軟件基金會的當選成員，還是Apache Synapse開源ESB項目的項目管理委員會成員和提交者。
新聞名稱：使用gRPC構(gòu)建實際的微服務(wù)
網(wǎng)頁地址：http://www.5511xx.com/article/cdjsosc.html
