在线乱码卡一卡二卡新HD,最近韩国免费观看视频,国产色无码精品视频国产,亚洲男人的天堂久久香蕉

?大家好，我是指北君。又是一周工作日的最后一天，但也不要忘記努力。

(相關資料圖)

吃得苦中苦，你長大開路虎，少壯不努力，你長大開夏利。

接下來開始進入正題~

?前言

相信大家對RPC協(xié)議都有一定的了解，并且或多或少都會在項目中涉及，但可能都和小編類似，都是直接使用平臺封裝的插件，對于其中的原理不是很了解，今天借此機會和大家分享下最近接觸的RPC框架-grpc，一同聊聊那些知其然卻不知其所以然的內(nèi)容。

?概述

RPC(Remote Procedure Call)遠程過程調(diào)用協(xié)議，是一種本地可以通過網(wǎng)絡請求遠程計算機，完成計算機間的數(shù)據(jù)內(nèi)容的交互的協(xié)議，不需要了解網(wǎng)絡底層技術就可以快速上手，使得開發(fā)更加容易，同時提升了交互體驗效率。

為了方便開發(fā)，有很多基于RPC協(xié)議實現(xiàn)的RPC框架，比如Thrift、Dubbo，和本文即將要介紹的gRPC。

?什么是gRPCgRPC是由google開發(fā)的一種支跨平臺（語言）、高性能、開源通用的RPC框架。它是基于HTTP2.0協(xié)議的，可以保持客戶端與服務端長連接，基于二進制流（字節(jié)流）傳輸數(shù)據(jù)。客戶端與服務端交互過程

客戶端（gRPC Sub）調(diào)用A方法，發(fā)起RPC請求

請求內(nèi)容使用Protobf進行對象序列化壓縮

服務端（gRPC Server）接收請求，解析請求內(nèi)容，業(yè)務處理后返回

響應結果通過Protobuf進行對象序列化壓縮

客戶端接收響應，解析響應內(nèi)容，最終完成交互

?實踐案例

小編以java版進行案例展示，其它語言類似，可自行測試

POM依賴

gRPC官方提供完成的依賴配置，按照說明直接引用即可（依賴包含插件），版本僅供參考，也可選擇其它版本。

io.grpc grpc-netty-shaded 1.29.0 io.grpc grpc-protobuf 1.29.0 io.grpc grpc-services 1.29.0 io.grpc grpc-stub 1.29.0 org.xolstice.maven.plugins protobuf-maven-plugin 0.6.1 com.google.protobuf:protoc:3.11.0:exe:${os.detected.classifier} grpc-java io.grpc:protoc-gen-grpc-java:1.29.0:exe:${os.detected.classifier} compile compile-custom

編寫protobuf文件

小編使用的是proto3版本，需要注意固定的目錄結構（src/proto/*.proto）,否則會編譯失敗。proto文件有固定的編寫格式，可以自行上網(wǎng)搜索即可?

syntax = "proto3";//包所在路徑option java_package = "com.greatom.dockerdemo.rule";option java_multiple_files = true;package rule;//聲明服務和方法service RuleService { //查詢并更新規(guī)則 rpc getArchivesDic (RuleRequest) returns (RuleResponse); //獲取當前規(guī)則字典 rpc getRule (Request) returns (Response);}//定義請求對象message RuleRequest { // message RuleRPCDTO { // int32 ruleCode = 1; // string administrativeCost = 2; // } Response ruleRPCDTO = 1; int32 basicId = 2;}//定義響應對象message RuleResponse { int32 id = 1;}message Request {}//定義響應消息message Response { int32 ruleCode = 1; string administrativeCost = 2;}使用maven插件編譯，雙擊執(zhí)行（生成Bean，maven->Plugins->protobuf->protobuf:compile；生成具體接口，maven->Plugins->protobuf->protobuf:compile-custom）。小編只執(zhí)行protobuf:compile命令，然后在target目錄（\target\generated-sources\protobuf）下就找到了生成的java文件，復制出來粘貼到項目執(zhí)行目錄下即可。

編寫接口實現(xiàn)類

編譯完后會生成RuleServiceGrpc接口，接下來就是按照自己的業(yè)務需求編寫邏輯即可。小編定義的兩個接口分別是 getArchivesDic（更新規(guī)則）、getRule（查詢規(guī)則）。具體實現(xiàn)如下

// 繼承生成的RuleServiceGrpc.RuleServiceImplBase// 實現(xiàn)接口具體邏輯@Componentpublic class RuleGRPCServer extends RuleServiceGrpc.RuleServiceImplBase { // 更新規(guī)則字典 @Override public void getArchivesDic(RuleRequest request, StreamObserver responseObserver) { Response ruleRPCDTO = request.getRuleRPCDTO(); RuleDTO ruleDTO = new RuleDTO(); BeanUtils.copyProperties(ruleRPCDTO, ruleDTO); RuleResponse ruleResponse = RuleResponse.newBuilder().setId(1).build(); responseObserver.onNext(ruleResponse); responseObserver.onCompleted(); } // 查詢規(guī)則字典 @Override public void getRule(Request request, StreamObserver responseObserver) { Response response = Response.newBuilder().setRuleCode(1) .setAdministrativeCost("2222").build(); responseObserver.onNext(response); responseObserver.onCompleted(); }}

服務端與客戶端

服務端啟動類

public static void main(String[] args) throws Exception { // 設置service接口. Server server = ServerBuilder.forPort(9999).addService(new RuleGRPCServiceImpl()).build().start(); System.out.println(String.format("GRpc服務端啟動成功, 端口號: %d.", port)); server.awaitTermination(); } 日志 --- GRpc服務端啟動成功, 端口號: 9999.客戶端啟動類

public static void main(String[] args) throws Exception { // 1. 拿到一個通信的channel ManagedChannel managedChannel = ManagedChannelBuilder.forAddress("localhost", 9999).usePlaintext().build(); try { // 2.拿到道理對象 RuleServiceGrpc.RuleServiceBlockingStub rpcDateService = RuleServiceGrpc.newBlockingStub(managedChannel); Request rpcDateRequest = Request .newBuilder() .build(); // 3. 請求 Response rpcDateResponse = rpcDateService.getRule(rpcDateRequest); // 4. 輸出結果 System.out.println(rpcDateResponse.getRuleCode()); } finally { // 5.關閉channel, 釋放資源. managedChannel.shutdown(); } } 日志： - 16:05:44.628 [grpc-nio-worker-ELG-1-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyClientHandler - [id: 0x8447cc92, L:/127.0.0.1:60973 - R:localhost/127.0.0.1:9999] INBOUND DATA: streamId=3 padding=0 endStream=false length=12 bytes=0000000007086f1203323232 - 16:05:44.648 [grpc-nio-worker-ELG-1-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyClientHandler - [id: 0x8447cc92, L:/127.0.0.1:60973 - R:localhost/127.0.0.1:9999] INBOUND HEADERS: streamId=3 headers=GrpcHttp2ResponseHeaders[grpc-status: 0] padding=0 endStream=true - 輸出結果-----111 - 16:05:44.664 [grpc-nio-worker-ELG-1-2] DEBUG io.grpc.netty.shaded.io.grpc.netty.NettyClientHandler - [id: 0x8447cc92, L:/127.0.0.1:60973 - R:localhost/127.0.0.1:9999] OUTBOUND GO_AWAY: lastStreamId=0 errorCode=0 length=0 bytes=

客戶端日志輸出結果即表示客戶端通過gRPC調(diào)用服務端成功，并返回結果。

?總結

gRPC本質(zhì)上就是傳統(tǒng)的C|S模型，這樣看角色分的清楚，也很容易理解。

還有就是它很聰明的點是基于HTTP2.0協(xié)議的，而不是自己制定，這就對未來的網(wǎng)絡開發(fā)很友好，降低了門檻。

比較難上手的點在于proto文件的編寫和使用，這部分需要插件等依賴，過程相對復雜，但也可能會出現(xiàn)工具或腳本，可以簡化下這部分。但生成代碼確實是真香~ 減少了一部分工作量。?

關鍵詞： 啟動成功 請求內(nèi)容 你不知道的 使用的是 傳輸數(shù)據(jù)