大概在好幾個月前吧，我們準備接入GRPC的接口，當時是某同事負責和服務器對接，所以從那個時候開始有了GRPC v1.0版。

GRPC V1.0

初版選擇的是使用Retrofix + protobuf + javaNano 生成了Android客戶端的偽GRPC的代碼，實現了客戶端與服務器的通信。 這里Retrofit用來進行網絡通信，protobuf + javanano 可以自動生成供Android端使用的接口代碼。 可以看看proto代碼構成,以cartsaver.proto為例：

syntax = "proto3";
package cartsaver;

option java_multiple_files = true;
option java_package = "com.daigou.sg.grpc";

service CartSaver {
    rpc Action(ActionReq) returns (ActionResp);
}

enum EAction {
    None = 0;
    AddCart = 1;
    Checkout = 2;
    Pay = 3;
    Invalid = 4;
}

// 若userId小于1，則從cookie 65_customer中獲取
message ActionReq {
    int64 userId = 1;
    EAction action = 2;
}

message ActionResp {
    bool ok = 1;
}

javanano不能生成Service，所以在第一版的時候我們手動將service去掉然后再生成代碼。 這里Service結構里包含的就是客戶端調用的接口 還有兩個message都是在通信時用到的，一個是request一個是response。 自動生成代碼操作請看此文檔 具體調用方法如下：

ArrayList<Protocol> protocolArrayList = new ArrayList<>();
protocolArrayList.add(Protocol.HTTP_1_1);
protocolArrayList.add(Protocol.HTTP_2);
OkHttpClient okHttpClient = new OkHttpClient.Builder()
        .protocols(protocolArrayList)
        .build();
Retrofit retrofit = new Retrofit.Builder()
        .client(okHttpClient)
        .addConverterFactory(ProtoConverterFactory.create())
        .baseUrl("http://192.168.199.64:14151")
        .build();
SimpleService service = retrofit.create(SimpleService.class);
ProductGpid productGpid = new ProductGpid();
productGpid.source = Product.ProductSourceEzbuy;
Call<ProductGpidResp> call = service.Gpid(productGpid);
call.enqueue(new Callback<ProductGpidResp>() {
    @Override
    public void onResponse(Call<ProductGpidResp> call, Response<ProductGpidResp> response) {
        Log.e("asd", response.body().toString());
    }

    @Override
    public void onFailure(Call<ProductGpidResp> call, Throwable t) {
        Log.e("asd", "onFailure");
    }
});

public interface SimpleService {
    @POST("/")
    Call<ProductGpidResp> Gpid(@Body ProductGpid impl);
}

GRPC V2.0

第二版在V1.0的基礎上實現方式并沒有改變，只是我們使用gradle插件自動生成代碼，不再使用命令行手動操作。 1.首先在android-ezbuy-rpc這個工程級的gradle文件中添加protobuf的插件：

classpath "com.google.protobuf:protobuf-gradle-plugin:0.8.0"

2.然后在rpcLibrary的gradle文件中添加如下代碼：

...
apply plugin: 'com.google.protobuf'
...
protobuf {
    protoc {
        artifact = 'com.google.protobuf:protoc:3.2.0'
    }
    plugins {
        javalite {
            artifact = "com.google.protobuf:protoc-gen-javalite:3.0.0"
        }
    }
    generateProtoTasks {
        all().each { task ->
            task.plugins {
                javalite {}
            }
        }
    }
}
...
    compile 'io.grpc:grpc-protobuf-lite:1.2.0'
...

由于protobuf不再支持javanano所以我們后來選擇用javalite替代javanano 至此，我們的代碼就成功生成并且做成了jar包 調用方法還是跟V1.0一樣，使用retrofit調用

GRPC V3.0

我們在V2.0的基礎上將GRPC官方調用方式加進去，替換掉retrofit，也就是當前版本V3.0，既然要用官方的實現方法，所以proto里的Service我們還是要生成的。 首先，還是要更改android-ezbuy-rpc中rpcLibrary的gradle文件。因為我們要加入Grpc調用，所以要加入依賴庫：

compile 'io.grpc:grpc-okhttp:1.2.0' // CURRENT_GRPC_VERSION
compile 'io.grpc:grpc-stub:1.2.0' // CURRENT_GRPC_VERSION

然后將protobuf更改如下

protobuf {
    protoc {
        artifact = 'com.google.protobuf:protoc:3.2.0'
    }
    plugins {
        javalite {
            artifact = "com.google.protobuf:protoc-gen-javalite:3.0.0"
        }
        //增加grpc插件
        grpc {
            artifact = 'io.grpc:protoc-gen-grpc-java:1.2.0' // CURRENT_GRPC_VERSION
        }
    }
    generateProtoTasks {
        all().each { task ->
            task.plugins {
                javalite {}
                //grpc
                grpc {
                    // Options added to --grpc_out
                    option 'lite'
                }
            }
        }
    }
}

然后在build.sh文件里添加grpc文件夾及proto文件 [圖片上傳失敗...(image-3a10e6-1524214716120)]

以后只要新增了proto文件只要在buil.sh里加上這段代碼，再編譯運行就可以生成grpc代碼了

cp -f ${API_DOC_PATH}/proto/cartsaver/cartsaver.proto ${Cur_Dir}/rpclibrary/src/main/proto/cartsaver.proto

這樣除了之前生成的Request和Response類以外，還會生成一個以Stub結尾的類，這個類相當于服務器在客戶端的存根，這里面會自動生成Service里的接口方法，通過stub調用接口，就可以實現和服務器端通信。 具體調用代碼如下：

    private static class GrpcTask extends AsyncTask<Void, Void, String> {
        ActionReq mReq;
        private ManagedChannel mChannel;

        public GrpcTask(ActionReq req) {
            mReq = req;
        }

        @Override
        protected String doInBackground(Void... nothing) {
            try {
                mChannel = OkHttpChannelBuilder.forAddress("192.168.199.64", 14090)
                        .usePlaintext(true)
                        .build();
                CartSaverGrpc.CartSaverBlockingStub saverStub = CartSaverGrpc.newBlockingStub(mChannel);
                Metadata headers = new Metadata();
                Metadata.Key<String> contentType = Metadata.Key.of("content-type", Metadata.ASCII_STRING_MARSHALLER);
                headers.put(contentType, "application/grpc");
                saverStub = MetadataUtils.attachHeaders(saverStub, headers);
                ActionResp resp = saverStub.action(mReq);
                return resp.getOk() + "";
            } catch (Exception e) {
                StringWriter sw = new StringWriter();
                PrintWriter pw = new PrintWriter(sw);
                e.printStackTrace(pw);
                pw.flush();
                return String.format("Failed... : %n%s", sw);
            }
    }
}
...
new GrpcTask(req).execute();