摘要：插畫牛肉框架小怪獸的電報員一旦系統怪物被拆分成了多個服務小怪獸，小怪獸們如何溝通協作就成了我們最關心的問題。插畫牛肉實現客戶端小怪獸發送今晚的月色真美，服務端小怪獸收到電報內容，并回復。

作者：亞瑟、文遠

一個小巧的單體應用會隨著公司業務的擴張而慢慢成長，逐漸演化成一個龐大且復雜的系統怪物，系統任何一處的問題都將影響整個怪物的表現，很少有多帶帶的開發者能理清系統怪物所有的肌理脈絡，導致bug的定位和新功能的擴展都變得越來越困難，對系統的任一改動都要求整個怪物一起回歸測試并重新部署，效率必然不高。所以公司發展到了一定階段，總會需要從架構上尋找解決系統怪物之道，而微服務就是目前最流行的架構方案之一，它將系統怪物拆分成多個獨立自治的服務小怪獸，讓我們有能力分而治之。

插畫：牛肉

一旦系統怪物被拆分成了多個服務小怪獸，小怪獸們如何溝通協作就成了我們最關心的問題。服務小怪獸間的通信就好像發電報一樣，涉及到數據序列化、反序列化、連接管理、收發線程、超時處理等多個問題，RPC框架的出現解決了這些問題，就好像通過電報員發電報一樣，使用RPC框架讓小怪獸們不必關心通信的底層細節。

插畫：牛肉

服務消費方（小怪獸A）以本地調用方式調用服務

client stub（小怪獸A的電報員）接受到調用后負責將方法、參數等編碼成能夠進行網絡傳輸的消息體（電報）

client stub（小怪獸A的電報員）找到服務地址，并將消息發送到服務端

server stub（小怪獸B的電報員）收到消息（電報）后進行解碼

server stub（小怪獸B的電報員）根據解碼結果調用本地的服務（小怪獸B）

本地服務(小怪獸B)執行并將結果返回給server stub（小怪獸B的電報員）

server stub（小怪獸B的電報員）將結果編碼成消息（電報）并發送至客戶端

client stub（小怪獸A的電報員）接受到消息（電報）并進行解碼

服務消費方（小怪獸A）得到最終的結果

如果通信的小怪獸們語言不通，那么我們需要對電報員（亦即RPC框架）的人選提出更高的要求，無論小怪獸們用的是什么語言，協助通信的兩位電報員都必須把它們的話翻譯成電報員彼此能理解的同一種語言，亦即IDL(Interface Description Language)，是的，電報員在這種情況下還必須承擔翻譯的角色，而gRPC就是一位如此優秀的電報員。

插畫：牛肉

實現Node客戶端小怪獸發送"今晚的月色真美"，Java服務端小怪獸收到電報內容，并回復"I love you too"。

通過Spring Boot創建Java項目，pom.xml中加入如下依賴

    
        org.springframework.boot
        spring-boot-starter
    
    
        org.springframework.boot
        spring-boot-starter-test
        test
    
    
        io.grpc
        grpc-netty-shaded
        1.21.0
    
    
        io.grpc
        grpc-protobuf
        1.21.0
    
    
        io.grpc
        grpc-stub
        1.21.0
    



    
        
            kr.motd.maven
            os-maven-plugin
            1.5.0.Final
        
    
    
        
            org.xolstice.maven.plugins
            protobuf-maven-plugin
            0.5.1
            
                com.google.protobuf:protoc:3.7.1:exe:${os.detected.classifier}
                grpc-java
                io.grpc:protoc-gen-grpc-java:1.21.0:exe:${os.detected.classifier}
                
                src/main/java
                
                false
            
            
                
                    
                        compile
                        compile-custom
                    
                
            
        
        
            org.springframework.boot
            spring-boot-maven-plugin
        
    

定義IDL文件

syntax = "proto3";

option java_multiple_files = true;
option java_package = "net.changjinglu.proto";
option java_outer_classname = "TelegraphProto";

package telegraph;

// The greeting service definition.
service TelegraphService {
    // Sends a greeting
    rpc SayLove (LoveRequest) returns (LoveReply) {}
}

// The request message containing the user"s name.
message LoveRequest {
    string message = 1;
}

// The response message containing the greetings
message LoveReply {
    string message = 1;
}

編譯生成IDL定義的Java服務接口，相關代碼會生成到配置對應的路徑下

mvn clean install

?

實現IDL定義的Java服務接口

public class TelegraphGreeterImpl extends TelegraphServiceGrpc.TelegraphServiceImplBase {

    @Override
    public void sayLove(LoveRequest request, StreamObserver responseObserver) {
        System.out.println("收到Node小怪獸的消息:"+request.getMessage());

        responseObserver.onNext(LoveReply.newBuilder().setMessage("I Love U Too").build());

        //結束
        responseObserver.onCompleted();
    }
}

編寫并啟動Java服務端

public class GrpcServer {

    /** GRPC 服務端 */
    private Server server;

    public static void main(String[] args) throws IOException, InterruptedException {
        GrpcServer grpcService = new GrpcServer();

        grpcService.start();
        System.out.println("GRPC 服務端啟動成功");

        //GRPC 服務端需要手動阻塞線程
        grpcService.waitTermination();


    }

    private void start() throws IOException {
        //綁定接口、啟動服務
        this.server = ServerBuilder.forPort(8899)
                .addService(new TelegraphGreeterImpl())
                .build()
                .start();

        System.out.println("server start!");

        //這里是為了防止jvm關閉了，但是tcp還沒有關閉的情況
        Runtime.getRuntime().addShutdownHook(new Thread(()->{
            System.out.println("關閉jvm");
            GrpcServer.this.stop();
        }));
    }

    private void stop() {
        if (this.server != null) {
            this.server.shutdown();
        }
    }

    private void waitTermination() throws InterruptedException {

        if (this.server != null) {
            server.awaitTermination();
        }
    }
}

?

編寫并啟動Nodejs客戶端，客戶端使用相同的IDL

var PROTO_FILE_PATH = "/Users/wenyuan/Nodejs/grpc/proto/telegraph.proto";
var grpc = require("grpc");
var grpcService = grpc.load(PROTO_FILE_PATH).telegraph;


function main() {
    var stub = new grpcService.TelegraphService("localhost:8899",grpc.credentials.createInsecure());

    stub.sayLove({message:"今晚的月色真美"},function (error, result) {
        console.log("收到Java小怪獸的消息: " + result.message);
    });
}

main();

Java服務端收到消息并回復

?

Nodejs客戶端收到Java服務端的回復