概述

本文將會介紹兩部分內容：
1、window 7 上搭建grpc環境;
2、構建關於grpc的java小demo.

下載grpc java依賴包

為了能生成針對java的grpc客戶端和服務端程式碼(官方叫stub),需要下載一些java包和grpc編譯器以及一些gradle 外掛

java依賴包

compile ‘io.grpc:grpc-netty:1.4.0’
compile ‘io.grpc:grpc-protobuf:1.4.0’
compile ‘io.grpc:grpc-stub:1.4.0’

gradle構建指令碼

buildscript {
  repositories {
    mavenCentral()
  }
  dependencies {
    classpath 'com.google.protobuf:protobuf-gradle-plugin:0.8.1'
 

  }
}

protobuf {
  protoc {
    artifact = "com.google.protobuf:protoc:3.2.0"
  }
  plugins {
    grpc {
      artifact = 'io.grpc:protoc-gen-grpc-java:1.4.0'
    }
  }
  generateProtoTasks {
    all()*.plugins {
      grpc {}
    }
  }
}

使用gradle命令

gradle clean build

由於要下載很多依賴包,時間會比較長.

備註

最好使用gradle 3來構建,gradle 2太舊了

編寫proto檔案

src/main/proto/grpc/firstdemo/Student.proto

syntax = "proto3";
package firstdemo;
option optimize_for=SPEED;
option java_package="firstdemo";
option java_outer_classname="StudentProto";
option java_multiple_files=true;

service StudentService {
    rpc getRealname(RequestInfo) returns (ResponseInfo) {}
}

message
 
 RequestInfo {
    string username = 1;
}

message ResponseInfo {
    string realname = 1;
}

注意這裡需要使用proto3

syntax = “proto3”;

生成gprc java stub類

先執行

gradle clean build

再執行

gradle generateProto

執行成功後,會生成如下目錄

grpc
java

將兩個目錄下的java檔案拷貝到

src/main/proto/grpc/firstdemo/generated

拷貝完後src/main/proto/grpc/firstdemo/generated目錄下會有如下檔案

RequestInfo.java
ResponseInfo.java
ResponseInfoOrBuilder.java
StudentProto.java
StudentServiceGrpc.java

備註

整合grpc後,不能再使用之前的proto2的protoc編譯命令了,這個命令只是會生成用於傳遞的訊息物件,並不會生成客戶端好服務端的stub類

編寫業務實現類

package grpc.firstdemo.server;

import grpc.firstdemo.generated.RequestInfo;
import grpc.firstdemo.generated.ResponseInfo;
import grpc.firstdemo.generated.StudentServiceGrpc.StudentServiceImplBase;
import io.grpc.stub.StreamObserver;

public class StudentBizService extends StudentServiceImplBase{

    @Override
    public void getRealname(RequestInfo request, StreamObserver<ResponseInfo> responseObserver) {
        System.out.println("接收到客戶端的資訊:"+request.getUsername());
        ResponseInfo responseInfo = ResponseInfo.newBuilder().setRealname("Sam").build();
        responseObserver.onNext(responseInfo);
        responseObserver.onCompleted();
    }
}

需要繼承StudentServiceImplBase類,覆蓋getRealname方法.

服務端程式碼

package grpc.firstdemo.server;

import java.io.IOException;

import io.grpc.Server;
import io.grpc.ServerBuilder;

public class GrpcServer {
   private Server server;

   private void start() throws IOException {
       this.server = ServerBuilder.forPort(8899)
                     .addService(new StudentBizService())
                     .build().start();
       System.out.println("server started");

       Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
        @Override
        public void run() {
            GrpcServer.this.stop();
        }
    }));
   }

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

   private void awaitTermination() throws InterruptedException {
       if (this.server != null) {
           this.server.awaitTermination();
       }
   }

   public static void main(String[] args) throws IOException, InterruptedException {
    GrpcServer grpcServer = new GrpcServer();
    grpcServer.start();
    //讓grpc server啟動後,處於等待狀態,監聽客戶端請求
    grpcServer.awaitTermination();
}
}

客戶端程式碼

package grpc.firstdemo.client;

import grpc.firstdemo.generated.RequestInfo;
import grpc.firstdemo.generated.ResponseInfo;
import grpc.firstdemo.generated.StudentServiceGrpc;
import grpc.firstdemo.generated.StudentServiceGrpc.StudentServiceBlockingStub;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;

public class GrpcClient {

    public static void main(String[] args) {
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 8899)
                             .usePlaintext(true)
                             .build();

        StudentServiceBlockingStub blockStub = StudentServiceGrpc.newBlockingStub(channel);
        ResponseInfo responseInfo = blockStub.getRealname(RequestInfo.newBuilder().setUsername("sam").build());
        System.out.println(responseInfo.getRealname());
    }
}

執行程式碼

分別執行GrpcServer類和GrpcClient類的main方法,啟動服務端和客戶端,正常情況下會列印如下日誌:

接收到客戶端的資訊:sam

csdn code 路徑

這個專案的原始碼放置在csdn code上,歡迎訪問。
netty_study