文章目錄

• • • 簡介
    • • 誕生
      • 主要用途
    • 基礎
    • • 數據結構
      • gRPC如何調用
    • gRPC與微服務
    • • 與SpringCloud整合
      • • 預配置
        • 編碼
        • 實現&&配置
        • 調用RPC，執行客戶端代碼，即可調用
        • 新增字段
        • 資源消耗
      • 報錯
      • • 服務提供者不在線

文件名稱版本號作者qq版本

問道gRPC	v1.0.0	學生宮布	8416837	net-devh-grpc.version 2.7.0.RELEASE grpc.version 1.29.0 protobuf.version 3.4.0

簡介

誕生

Google的孩子

主要用途

進程通信

基礎

• 檢測是否安裝protobuf

go version protoc --version

• 下載 protoc-3.10.1-win64.zip
• 將安裝目錄/bin配置到Win環境變量
  

數據結構

數據格式Protobuf
查看我寫的protobuf教程
一個簡單的proto文件

syntax = 'proto3';package proto;message Human {int32 age = 1;string name = 2;int32 sex = 3; }

安裝編譯插件

go get -u github.com/golang/protobuf/protoc-gen-go

進入該文件目錄使用gitbash編譯該文件
protoc --go_out=. --python_out=. fruit.proto
編譯完畢，說明插件安裝成功：

gRPC如何調用

grpc提供的原生接口服務無法被http模式訪問

• 在golang代碼里調用 查看教程
• 查看GitHub代碼

gRPC與微服務

• 服務消費模式，與FeignClient、Dubbo RPC模式接近
• 路由表 來自注冊中心
• 負載均衡 軟負載 根據路由表輪詢、一致性hash、活躍度等

與SpringCloud整合

• 基礎→ Protocol Buffers教程
• 進入安裝Nacos教程,gRPC服務注冊到Nacos

預配置

• pom.xml 核心配置節選

<plugin><groupId>org.xolstice.maven.plugins</groupId><artifactId>protobuf-maven-plugin</artifactId><version>0.5.0</version><configuration><protocArtifact>com.google.protobuf:protoc:3.1.0:exe:${os.detected.classifier}</protocArtifact><pluginId>grpc-java</pluginId> <!-- gRPC等相關 - start--><pluginArtifact>io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier}</pluginArtifact><!--默認值--><protoSourceRoot>${project.basedir}/src/main/proto</protoSourceRoot><!--默認值--><!--<outputDirectory>${project.build.directory}/generated-sources/protobuf/java</outputDirectory>--><outputDirectory>${project.basedir}/src/main/java</outputDirectory><!--設置是否在生成java文件之前清空outputDirectory的文件，默認值為true，設置為false時也會覆蓋同名文件--><clearOutputDirectory>false</clearOutputDirectory> <!-- gRPC等相關 - end--></configuration><executions><execution><goals><goal>compile</goal><goal>compile-custom</goal></goals></execution></executions></plugin>

• 引入插件，可能報紅↓
  
  引入變量就不會報紅了↓

<properties><grpc.version>1.29.0</grpc.version><os.detected.classifier>windows-x86_64</os.detected.classifier><net-devh-grpc.version>2.7.0.RELEASE</net-devh-grpc.version></properties>

編碼

• 新建目錄src\main\proto
  

• 編輯Human.proto文件

syntax = "proto3"; // 版本號。與proto2差別不大 option java_package = "test.pro.domain"; option java_outer_classname = "HumanDomain";// 簡單定義一個rpc服務和一個接口 定義了接口的輸入輸出 而輸入輸出都在下述結構體 service TheFirstRpc {rpc SayHello ( HelloParams) returns ( Human ) {} }message HelloParams { // 類結構體string name = 1; } message Human { // 類結構體int32 id = 1; // 結構體屬性int32 sex = 2; // 數字作為key，省空間。不一定要連續string age = 3; }

實現&&配置

• 引入protobuf依賴↓
  父項目

<properties><protobuf.version>3.4.0</protobuf.version> ... ... <dependencyManagement><dependencies><dependency><groupId>com.google.protobuf</groupId><artifactId>protobuf-java</artifactId><version>${protobuf.version}</version></dependency><dependency><groupId>io.grpc</groupId><artifactId>grpc-all</artifactId><version>${grpc.version}</version></dependency>

子項目

<dependency><groupId>com.google.protobuf</groupId><artifactId>protobuf-java</artifactId></dependency><dependency><groupId>io.grpc</groupId><artifactId>grpc-all</artifactId></dependency>

• 編譯 找到Maven插件
  
  執行插件compile && compile-custom命令，或自己打命令（不推薦）
  若報錯：
  說明缺少依賴

編譯成功


這樣proto就變成了Java類，以備后續使用

• 服務端實現RPC
  服務提供者配置

grpc:server:port: 9080 # 不配置默認9090

服務端引入依賴包

<net-devh-grpc.version>2.7.0.RELEASE</net-devh-grpc.version><dependency><groupId>net.devh</groupId><artifactId>grpc-client-spring-boot-starter</artifactId><version>${net-devh-grpc.version}</version></dependency><dependency><groupId>net.devh</groupId><artifactId>grpc-server-spring-boot-starter</artifactId><version>${net-devh-grpc.version}</version></dependency>

前提是服務端和客戶端都引入RPC相關Java類
上一步只是編譯了RPC結構，并未實現它。因此，可以在服務端（提供者）編寫實現代碼，以備客戶端（消費者）調用。
注意：有些類的名字改成你自己的。這些類主要與proto關聯。

package test.rpc;/*** 功能：rpc實現** @author: cc* @qq: 8416837* @date: 2020/5/17 15:48*/import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; import net.devh.boot.grpc.server.service.GrpcService; import test.pro.domain.HumanDomain; import test.pro.domain.TheFirstRpcGrpc;@Slf4j @GrpcService public class HelloService extends TheFirstRpcGrpc.TheFirstRpcImplBase {@Overridepublic void sayHello(HumanDomain.HelloParams request, StreamObserver<HumanDomain.Human> responseObserver) {String name = request.getName();log.debug("{} === {}", "[請求參數]", request);final HumanDomain.Human.Builder replyBuilder = HumanDomain.Human.newBuilder().setSex(1).setAge(18).setName(name);responseObserver.onNext(replyBuilder.build());responseObserver.onCompleted();} }

• 客戶端配置文件

# grpc grpc:client:TheFirstRpc: # 服務名稱address: static://localhost:9080negotiationType: plaintext# 服務# GLOBAL:# address: static://localhost:9080 // 服務端的端口號# negotiation-type: plaintext

• 客戶端代碼，節選，注意區分：

@GrpcClient("TheFirstRpc")private TheFirstRpcGrpc.TheFirstRpcBlockingStub theFirstRpcBlockingStub;@GetMapping("/grpc/{name}")public Object sayHello(@PathVariable("name") String name) throws InterruptedException {// 服務端默認ip是微服務ip，端口是9090HumanDomain.Human response = theFirstRpcBlockingStub.sayHello(HumanDomain.HelloParams.newBuilder().setName(name).build());String resStr = response.toString();return resStr;}

調用RPC，執行客戶端代碼，即可調用

使用REST API觸發客戶端調用服務端RPC，即可完成調用，原理見上述代碼
把RPC調用結果toString后再返回，避免REST Json返回響應時報錯。按上述代碼，實操調用成功。

• 調用成功
  

新增字段

在proto新增字段之后，執行命令↓

資源消耗

• 開啟grpc Nacos通訊后，Nacos消耗運存情況：
  
  運存占用不多，持續增長中，但是吃cpu，nacos 是1.2.1， 可能是bug， 多方運行核實一下，例如普通的不帶grpc的微服務會不會出現這種大量吃cpu的情況

報錯

服務提供者不在線

報錯：

io.grpc.StatusRuntimeException: UNAVAILABLE: io exceptionat io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:244) ~[grpc-stub-1.29.0.jar:1.29.0]Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s):|_ checkpoint ? org.springframework.security.web.server.authorization.AuthorizationWebFilter [DefaultWebFilterChain]

解決辦法：開啟服務

總結

以上是生活随笔為你收集整理的问道gRPC_v1.0.0的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。