Построение gRPC

# Обратите внимание на настройку зависимости gmock --- (заблокирован)
./autogen.sh
```./configure --prefix=/usr
make && make check && make install

syntax = "proto3";

option java_multiple_files = true;

package pb;

// Определение службы приветствия.
service Greeter {
    // Отправляет приветствие
    rpc  SayHello (HelloRequest) returns (HelloResponse){}
}

service Test {
    // Отправляет приветствие
    rpc  SayHello (HelloRequest) returns (HelloResponse){}
}


// Запрос, содержащий имя пользователя.
message HelloRequest {
    string name = 1;
}

// Ответ, содержащий приветствие.
message HelloResponse {
    string message = 1;
}

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">


    <modelVersion>4.0.0</modelVersion>


    <properties>
        <protobuf.version>3.0.0-beta-2</protobuf.version>
        <grpc.version>0.9.0</grpc.version>
    </properties>

    // Модули, необходимые для зависимости gRPC
    <dependencies>
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-core</artifactId>
            <version>${grpc.version}</version>
        </dependency>```xml
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-stub</artifactId>
            <version>${grpc.version}</version>
        </dependency>

        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-protobuf</artifactId>
            <version>${grpc.version}</version>
        </dependency>

        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-netty</artifactId>
            <version>${grpc.version}</version>
        </dependency>

        <dependency>
            <groupId>com.google.protobuf</groupId>
            <artifactId>protobuf-java</artifactId>
            <version>${protobuf.version}</version>
        </dependency>```xml
<build>
    <extensions>
        <extension>
            <groupId>kr.motd.maven</groupId>
            <artifactId>os-maven-plugin</artifactId>
            <version>1.4.0.Final</version>
        </extension>
    </extensions>
    <plugins>
        <!-- плагин gRPC -->
        <plugin>
            <groupId>com.google.protobuf.tools</groupId>
            <artifactId>maven-protoc-plugin</artifactId>
            <version>0.4.4</version>
            <configuration>
                <!--
                  Версия protoc должна соответствовать версии protobuf-java. Если вы не используете
                  protobuf-java напрямую, вы будете транзитивно зависеть от версии protobuf-java,
                  на которую зависит gRPC.
                -->
                <pluginId>grpc-java</pluginId>
                <protocArtifact>com.google.protobuf:protoc:3.0.0-beta-2:exe:${os.detected.classifier}
                </protocArtifact>
                <pluginArtifact>io.grpc:protoc-gen-grpc-java:0.9.0:exe:${os.detected.classifier}</pluginArtifact>
            </configuration>
            <executions>
                <execution>
                    <goals>
                        <goal>compile</goal>
                        <goal>compile-custom</goal>
                    </goals>
                </execution>
            </executions>
        </plugin>
    </plugins>
</build>
</project>
```### Сгенерированный объект разбора

public void sayHello(pb.HelloRequest request,
    io.grpc.stub.StreamObserver<pb.HelloResponse> responseObserver);

/**
 * Клиентская реализация интерфейса
 */

public pb.HelloResponse sayHello(pb.HelloRequest request);

/**
 * Метод вызова
*/
@java.lang.Override
public void sayHello(pb.HelloRequest request,
    io.grpc.stub.StreamObserver<pb.HelloResponse> responseObserver) {
  asyncUnaryCall(
      getChannel().newCall(METHOD_SAY_HELLO, getCallOptions()), request, responseObserver);
}

    /**
     * Пул потоков для обработки логики
     * Используется для выполнения бизнес-логики
     */
    private static final ExecutorService executorService =
            Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()
                    , new NamedThreadFactory("logic-handler"));
```    /**
     * Запуск службы
     *
     * @throws Exception
     */
    public void startGrpc() throws Exception {

        // инициализация билдера
        initServerBuilder();

        // привязка службы
        server = nettyServerBuilder.build().start();
    }
``````java
        // регистрируем хук
        Runtime.getRuntime().addShutdownHook(new Thread() {
            @Override
            public void run() {
                // Используем stderr, так как логгер может быть сброшен хуком завершения JVM.
                logger.debug("*** завершение работы gRPC-сервера, так как JVM завершает работу");
                if (server != null) {
                    server.shutdown(); // завершение работы
                }
                executorService.shutdown();
                logger.debug("*** сервер завершил работу");
            }
        });
``````markdown
        if (logger.isDebugEnabled()) {
            logger.debug("grpc_server bind service port:" + port);
        }

    }

    /**
     * Приостановить службу, предоставить постоянную внешнюю службу
     * @throws InterruptedException
     */
    public void awaitTermination() throws InterruptedException {
        server.awaitTermination();
    }

    if (PlatformDependent.isAndroid()) { // платформа Android
        channel = OkHttpChannelBuilder.forAddress(host, port)
                .usePlaintext(true)
                .build();
    } else {
        ManagedChannelBuilder managedChannelBuilder = ManagedChannelBuilder.forAddress(host, port);
        if (managedChannelBuilder instanceof NettyChannelBuilder) {
            NettyChannelBuilder nettyChannelBuilder = (NettyChannelBuilder) managedChannelBuilder;

#### Простое использование
```java
  /**
     * В качестве одиночного объекта
     */
    HelloWorldClient client = new HelloWorldClient("localhost", 50051);
    // создание блокирующего stub (клиент)----
    GreeterGrpc.GreeterBlockingClient greeterBlockingClient =
                       GreeterGrpc.newBlockingStub(grpcClient.getChannel());
    // создание отправляемых данных
    HelloRequest request = HelloRequest.newBuilder().setName(name).build();
    grpcClient.shutdown();
```#### Демонстрация
```