RPC框架實踐之：Google gRPC

時間 2019-11-16

標籤 rpc 框架實踐 google grpc 欄目微服務简体版

原文原文鏈接

概述

gRPC是Google開源的通用高性能RPC框架，它支持的是使用Protocol Buffers來編寫Service定義，支持較多語言擴平臺而且擁有強大的二進制序列化工具集。與文章《RPC框架實踐之：Apache Thrift》一文中實踐的另外一種通用RPC框架 Thrift 能經過Generator自動生成對應語言的Service接口相似，gRPC也能 自動地生成 Server和Client的 Service存根（Stub），咱們只須要 一個命令 就能快速搭建起RPC運行環境。java

下面實踐一下gRPC框架，作的事情就是：Client端經過遠程RPC調用Server的獲取時間的接口，從而將服務器時間獲取到本地並顯示。git

相似於以前對於 RPC框架: Thrift 的實踐步驟，下面一一闡述。編程

注：本文首發於 My 公衆號 CodeSheep ，可長按或掃描下面的 當心心 來訂閱 ↓ ↓ ↓c#

開發gRPC-API

首先建立一個基於Maven的項目： GrpcAPIapi
pom中加入grpc相關的依賴bash

<dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-all</artifactId>
            <version>1.12.0</version>
        </dependency>
複製代碼

這個grpc-all包含了不少grpc相關的組件：grpc-netty 、 grpc-protobuf 、grpc-stub 等等服務器

pom中加入grpc相關的 build插件

這裏添加兩個Maven插件，目的是後面須要用這些插件來執行Protocol Buffers命令，從而自動生成相關的Stub代碼：框架

os-maven-plugin：生成平臺無關的屬性 protobuf-maven-plugin：執行Protocol Buffers命令並生成Stub代碼庫maven

<build>
        <extensions>
            <extension>
                <groupId>kr.motd.maven</groupId>
                <artifactId>os-maven-plugin</artifactId>
                <version>1.4.1.Final</version>
            </extension>
        </extensions>
        <plugins>
            <plugin>
                <groupId>org.xolstice.maven.plugins</groupId>
                <artifactId>protobuf-maven-plugin</artifactId>
                <version>0.5.0</version>
                <configuration>
                    <pluginId>grpc-java</pluginId>
                    <protocArtifact>com.google.protobuf:protoc:3.0.2:exe:${os.detected.classifier}</protocArtifact>
                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.2.0:exe:${os.detected.classifier}</pluginArtifact>
                </configuration>
                <executions>
                    <execution>
                        <goals>
                            <goal>compile</goal>
                            <goal>compile-custom</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
複製代碼

編寫.proto的服務定義文件

這裏.proto文件的做用和寫法就和個人前一篇文章《RPC框架實踐之：Apache Thrift》一文中Thrift所要求的.thrift文件編寫同樣，是有其本身的語法要求的！ide

syntax = "proto3」; // 語法版本 // stub選項 option java_package = "com.hansonwang99.grpc.api」;
option java_outer_classname = 「RPCDateServiceApi」;
option java_multiple_files = true;

// 定義包名，相似於個人文章《RPC框架實踐之：Apache Thrift》中的Thrift的namespace
package com.hansonwang99.grpc.api;

// 服務接口定義，服務端和客戶端都要遵照該接口進行通訊
service RPCDateService {
  rpc getDate (RPCDateRequest) returns (RPCDateResponse) {}
}

// 定義消息（請求）
message RPCDateRequest {
  string userName = 1;
}

// 定義消息（響應）
message RPCDateResponse {
  string serverDate = 1;
}
複製代碼

執行mvn compile命令來自動生成代碼Stub

mvn編譯完成之後，在target/generated-sources目錄下就能看到根據上面.proto文件自動轉化生成的Java代碼Stub

代碼生成結果以下所示

好了，既然gRPC-API已經有了，下面能夠分別編寫服務端和客戶端

開發gRPC服務端

建立基於Maven的項目：Server
pom中添加 GrpcAPI 依賴

<dependency>
            <groupId>com.hansonwang99</groupId>
            <artifactId>GrpcAPI</artifactId>
            <version>1.0-SNAPSHOT</version>
            <scope>compile</scope>
        </dependency>
複製代碼

接下來一步比較關鍵

實現gRPC服務接口

public class RPCDateServiceImpl extends RPCDateServiceGrpc.RPCDateServiceImplBase{
    @Override
    public void getDate(RPCDateRequest request, StreamObserver<RPCDateResponse> responseObserver) {
        RPCDateResponse rpcDateResponse = null;
        Date now=new Date();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("今天是"+"yyyy年MM月dd日 E kk點mm分」); String nowTime = simpleDateFormat.format( now ); try { rpcDateResponse = RPCDateResponse .newBuilder() .setServerDate( "Welcome " + request.getUserName() + ", " + nowTime ) .build(); } catch (Exception e) { responseObserver.onError(e); } finally { responseObserver.onNext( rpcDateResponse ); } responseObserver.onCompleted(); } } 複製代碼

我想此處重寫的getDate()方法並不陌生吧，這正是上文 .proto 文件中定義的Service接口。此處邏輯比較簡單：獲取當前時間，而且將其與請求RPCDateRequest中提取出的userName字段進行拼接，而後返回給調用端！造成一個閉環

建立gRPC服務端啓動類

public class GRPCServer {
    private static final int port = 9999;
    public static void main( String[] args ) throws Exception {
        Server server = ServerBuilder.
                forPort(port)
                .addService( new RPCDateServiceImpl() )
                .build().start();
        System.out.println( "grpc服務端啓動成功, 端口=" + port );
        server.awaitTermination();
    }
}
複製代碼

端口自定義的9999，也就是在該端口監聽。如今能夠當即運行GRPCServer，來啓動服務端

開發gRPC客戶端

建立基於Maven的項目：Client
pom中依然須要添加 GrpcAPI 依賴

<dependency>
            <groupId>com.hansonwang99</groupId>
            <artifactId>GrpcAPI</artifactId>
            <version>1.0-SNAPSHOT</version>
            <scope>compile</scope>
        </dependency>
複製代碼

建立gRPC客戶端啓動類

public class GRPCClient {
    private static final String host = 「localhost」;
    private static final int serverPort = 9999;

    public static void main( String[] args ) throws Exception {
        ManagedChannel managedChannel = ManagedChannelBuilder.forAddress( host, serverPort ).usePlaintext().build();
        try {
            RPCDateServiceGrpc.RPCDateServiceBlockingStub rpcDateService = RPCDateServiceGrpc.newBlockingStub( managedChannel );
            RPCDateRequest  rpcDateRequest = RPCDateRequest
                    .newBuilder()
                    .setUserName(「hansonwang99」)
                    .build();
            RPCDateResponse rpcDateResponse = rpcDateService.getDate( rpcDateRequest );
            System.out.println( rpcDateResponse.getServerDate() );
        } finally {
            managedChannel.shutdown();
        }
    }
}
複製代碼

如今當即啓動 GRPCClient！