grpc interface,service,client

pom.xml

@@ -22,6 +22,9 @@
         <module>whatsmars-spring</module>
         <module>whatsmars-spring-boot</module>
         <module>whatsmars-grpc</module>
+        <module>whatsmars-grpc-interface</module>
+        <module>whatsmars-grpc-service</module>
+        <module>whatsmars-grpc-client</module>
     </modules>
 
     <properties>

whatsmars-grpc-client/pom.xml

+<?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">
+    <parent>
+        <artifactId>whatsmars-parent</artifactId>
+        <groupId>com.itlong</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>whatsmars-grpc-client</artifactId>
+    <packaging>jar</packaging>
+    <name>${project.artifactId}</name>
+    <url>http://maven.apache.org</url>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-netty</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-protobuf</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-stub</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.itlong</groupId>
+            <artifactId>whatsmars-grpc-interface</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <finalName>${project.artifactId}</finalName>
+        <extensions>
+            <extension>
+                <groupId>kr.motd.maven</groupId>
+                <artifactId>os-maven-plugin</artifactId>
+                <version>1.4.1.Final</version>
+            </extension>
+        </extensions>
+        <plugins>
+            <plugin>
+                <groupId>org.xolstice.maven.plugins</groupId>
+                <artifactId>protobuf-maven-plugin</artifactId>
+                <version>0.5.0</version>
+                <configuration>
+                    <protocArtifact>com.google.protobuf:protoc:3.0.0:exe:${os.detected.classifier}</protocArtifact>
+                    <pluginId>grpc-java</pluginId>
+                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.0.0:exe:${os.detected.classifier}</pluginArtifact>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>compile</goal>
+                            <goal>compile-custom</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
\ No newline at end of file

whatsmars-grpc-client/src/main/java/com/itlong/whatsmars/grpc/client/HelloWorldClient.java

+package com.itlong.whatsmars.grpc.client;
+
+import com.itlong.whatsmars.grpc.service.HelloRequest;
+import com.itlong.whatsmars.grpc.service.HelloResponse;
+import com.itlong.whatsmars.grpc.service.HelloServiceGrpc;
+import io.grpc.ManagedChannel;
+import io.grpc.ManagedChannelBuilder;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Created by shenhongxi on 2017/5/5.
+ */
+public class HelloWorldClient {
+
+    private final ManagedChannel channel;
+    private final HelloServiceGrpc.HelloServiceBlockingStub blockingStub;
+
+    public HelloWorldClient(String host, int port){
+        channel = ManagedChannelBuilder.forAddress(host, port)
+                .usePlaintext(true)
+                .build();
+
+        blockingStub = HelloServiceGrpc.newBlockingStub(channel);
+    }
+
+    public void shutdown() throws InterruptedException {
+        channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);
+    }
+
+    public void greet(String name){
+        HelloRequest request = HelloRequest.newBuilder().setName(name).build();
+        HelloResponse response = blockingStub.sayHello(request);
+        System.out.println(response.getMessage());
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+        HelloWorldClient client = new HelloWorldClient("127.0.0.1", 50051);
+        for(int i = 0; i < 5; i++) {
+            client.greet("world:" + i);
+        }
+        client.shutdown();
+    }
+}

whatsmars-grpc-interface/pom.xml

+<?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">
+    <parent>
+        <artifactId>whatsmars-parent</artifactId>
+        <groupId>com.itlong</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>whatsmars-grpc-interface</artifactId>
+    <packaging>jar</packaging>
+    <name>${project.artifactId}</name>
+    <url>http://maven.apache.org</url>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-netty</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-protobuf</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-stub</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <finalName>${project.artifactId}</finalName>
+        <extensions>
+            <extension>
+                <groupId>kr.motd.maven</groupId>
+                <artifactId>os-maven-plugin</artifactId>
+                <version>1.4.1.Final</version>
+            </extension>
+        </extensions>
+        <plugins>
+            <plugin>
+                <groupId>org.xolstice.maven.plugins</groupId>
+                <artifactId>protobuf-maven-plugin</artifactId>
+                <version>0.5.0</version>
+                <configuration>
+                    <protocArtifact>com.google.protobuf:protoc:3.0.0:exe:${os.detected.classifier}</protocArtifact>
+                    <pluginId>grpc-java</pluginId>
+                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.0.0:exe:${os.detected.classifier}</pluginArtifact>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>compile</goal>
+                            <goal>compile-custom</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
\ No newline at end of file

whatsmars-grpc-interface/src/main/proto/helloworld.proto

+syntax = "proto3";
+
+option java_multiple_files = true;
+option java_package = "com.itlong.whatsmars.grpc.service";
+option java_outer_classname = "HelloWorldProto";
+option objc_class_prefix = "HLW";
+
+package helloworld;
+
+// The greeting service definition.
+service HelloService {
+  // Sends a greeting
+  rpc sayHello (HelloRequest) returns (HelloResponse) {}
+}
+
+// The request message containing the user's name.
+message HelloRequest {
+  string name = 1;
+}
+
+// The response message containing the greetings
+message HelloResponse {
+  string message = 1;
+}
\ No newline at end of file

whatsmars-grpc-service/pom.xml

+<?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">
+    <parent>
+        <artifactId>whatsmars-parent</artifactId>
+        <groupId>com.itlong</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>whatsmars-grpc-service</artifactId>
+    <packaging>jar</packaging>
+    <name>${project.artifactId}</name>
+    <url>http://maven.apache.org</url>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-netty</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-protobuf</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-stub</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.itlong</groupId>
+            <artifactId>whatsmars-grpc-interface</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <finalName>${project.artifactId}</finalName>
+    </build>
+
+</project>
\ No newline at end of file

whatsmars-grpc-service/src/main/java/com/itlong/whatsmars/grpc/server/HelloWorldServer.java

+package com.itlong.whatsmars.grpc.server;
+
+import com.itlong.whatsmars.grpc.service.impl.HelloServiceImpl;
+import io.grpc.Server;
+import io.grpc.ServerBuilder;
+
+import java.io.IOException;
+
+/**
+ * Created by shenhongxi on 2017/5/5.
+ */
+public class HelloWorldServer {
+
+    private int port = 50051;
+    private Server server;
+
+    private void start() throws IOException {
+        server = ServerBuilder.forPort(port)
+                .addService(new HelloServiceImpl())
+                .build()
+                .start();
+
+        System.out.println("service start...");
+
+        Runtime.getRuntime().addShutdownHook(new Thread() {
+
+            @Override
+            public void run() {
+
+                System.err.println("*** shutting down gRPC server since JVM is shutting down");
+                HelloWorldServer.this.stop();
+                System.err.println("*** server shut down");
+            }
+        });
+    }
+
+    private void stop() {
+        if (server != null) {
+            server.shutdown();
+        }
+    }
+
+    // block 一直到退出程序 
+    private void blockUntilShutdown() throws InterruptedException {
+        if (server != null) {
+            server.awaitTermination();
+        }
+    }
+
+    public static void main(String[] args) throws IOException, InterruptedException {
+        final HelloWorldServer server = new HelloWorldServer();
+        server.start();
+        server.blockUntilShutdown();
+    }
+
+}

whatsmars-grpc-service/src/main/java/com/itlong/whatsmars/grpc/service/impl/HelloServiceImpl.java

+package com.itlong.whatsmars.grpc.service.impl;
+
+import com.itlong.whatsmars.grpc.service.HelloRequest;
+import com.itlong.whatsmars.grpc.service.HelloResponse;
+import com.itlong.whatsmars.grpc.service.HelloServiceGrpc;
+import io.grpc.stub.StreamObserver;
+
+/**
+ * Created by shenhongxi on 2017/5/5.
+ */
+public class HelloServiceImpl extends HelloServiceGrpc.HelloServiceImplBase {
+
+    public void sayHello(HelloRequest req, StreamObserver<HelloResponse> responseObserver) {
+        System.out.println("service:" + req.getName());
+        HelloResponse response = HelloResponse.newBuilder().setMessage(("Hello: " + req.getName())).build();
+        responseObserver.onNext(response);
+        responseObserver.onCompleted();
+    }
+}

whatsmars-grpc/src/main/java/com/itlong/whatsmars/grpc/client/HelloWorldClient.java

@@ -2,7 +2,7 @@ package com.itlong.whatsmars.grpc.client;
 
 import io.grpc.ManagedChannel;
 import io.grpc.ManagedChannelBuilder;
-import com.itlong.whatsmars.grpc.service.GreeterGrpc;
+import com.itlong.whatsmars.grpc.service.HelloServiceGrpc;
 import com.itlong.whatsmars.grpc.service.HelloRequest;
 import com.itlong.whatsmars.grpc.service.HelloResponse;
 
@@ -14,14 +14,14 @@ import java.util.concurrent.TimeUnit;
 public class HelloWorldClient {
 
     private final ManagedChannel channel;
-    private final GreeterGrpc.GreeterBlockingStub blockingStub;
+    private final HelloServiceGrpc.HelloServiceBlockingStub blockingStub;
 
     public HelloWorldClient(String host,int port){
         channel = ManagedChannelBuilder.forAddress(host, port)
                 .usePlaintext(true)
                 .build();
 
-        blockingStub = GreeterGrpc.newBlockingStub(channel);
+        blockingStub = HelloServiceGrpc.newBlockingStub(channel);
     }
 
     public void shutdown() throws InterruptedException {

whatsmars-grpc/src/main/java/com/itlong/whatsmars/grpc/server/HelloWorldServer.java

@@ -3,7 +3,7 @@ package com.itlong.whatsmars.grpc.server;
 import io.grpc.Server;
 import io.grpc.ServerBuilder;
 import io.grpc.stub.StreamObserver;
-import com.itlong.whatsmars.grpc.service.GreeterGrpc;
+import com.itlong.whatsmars.grpc.service.HelloServiceGrpc;
 import com.itlong.whatsmars.grpc.service.HelloRequest;
 import com.itlong.whatsmars.grpc.service.HelloResponse;
 
@@ -19,7 +19,7 @@ public class HelloWorldServer {
 
     private void start() throws IOException {
         server = ServerBuilder.forPort(port)
-                .addService(new GreeterImpl())
+                .addService(new HelloServiceImpl())
                 .build()
                 .start();
 
@@ -57,7 +57,7 @@ public class HelloWorldServer {
     }
 
     // 实现 定义一个实现服务接口的类 
-    private class GreeterImpl extends GreeterGrpc.GreeterImplBase {
+    private class HelloServiceImpl extends HelloServiceGrpc.HelloServiceImplBase {
 
         public void sayHello(HelloRequest req, StreamObserver<HelloResponse> responseObserver) {
             System.out.println("service:" + req.getName());

whatsmars-grpc/src/main/proto/helloworld.proto

@@ -8,7 +8,7 @@ option objc_class_prefix = "HLW";
 package helloworld;
 
 // The greeting service definition.
-service Greeter {
+service HelloService {
   // Sends a greeting
   rpc sayHello (HelloRequest) returns (HelloResponse) {}
 }