类DemoServiceBlockingStub

类定义

这个类是通过grpc的proto编译器生成的类，它的package由.proto文件中的 java_package 选项指定，如：

option java_package = “io.grpc.examples.demo”;

类定义如下，继承AbstractStub，并实现DemoServiceBlockingClient接口：

  1. package io.grpc.examples.demo;
  3. @javax.annotation.Generated("by gRPC proto compiler")
  4. public static class DemoServiceBlockingStub extends io.grpc.stub.AbstractStub<DemoServiceBlockingStub>
  5.   implements DemoServiceBlockingClient {
  6. }

构造函数

构造函数非常简单，直接调用基类 AbstractStub 的构造函数，传入Channel和CallOptions：

  1.     private DemoServiceBlockingStub(io.grpc.Channel channel) {
  2.       super(channel);
  3.     }
  5.     private DemoServiceBlockingStub(io.grpc.Channel channel,
  6.         io.grpc.CallOptions callOptions) {
  7.       super(channel, callOptions);
  8.     }
  9. }

方法

首先实现了基类 AbstractStub 的抽象方法build()，只是简单的构造了自身的一个新的实例:

  1. @java.lang.Override
  2. protected DemoServiceBlockingStub build(io.grpc.Channel channel,
  3.     io.grpc.CallOptions callOptions) {
  4.     return new DemoServiceBlockingStub(channel, callOptions);
  5. }

业务方法实现

然后就是实现业务定义的service方法了，这里是定义在 DemoServiceBlockingClient 接口中。先看 DemoServiceBlockingClient 接口的定义：

  1. public static interface DemoServiceBlockingClient {
  2.     public io.grpc.examples.demo.LoginResponse login(io.grpc.examples.demo.LoginRequest request);
  3.     ......
  4. }

这些方法对应于.proto文件中service定义的rpc方法：

  1. service DemoService {
  2.     rpc login (LoginRequest) returns (LoginResponse) {}
  3.     ......
  4. }

DemoServiceBlockingStub 中一一实现这些服务方法：

  1. @java.lang.Override
  2. public io.grpc.examples.demo.LoginResponse login(io.grpc.examples.demo.LoginRequest request) {
  3.       return blockingUnaryCall(getChannel(), METHOD_LOGIN, getCallOptions(), request);
  4. }