增加feature存根,该存根为同步非阻塞

quding · quding · commit 8012c8c3f4a0 · 2017-02-08T22:59:54.000+08:00
diff --git a/gRPC-Demo/src/main/java/cn/mrdear/grpc/clientProcess/forwardExample/InterceptTest.java b/gRPC-Demo/src/main/java/cn/mrdear/grpc/clientProcess/forwardExample/InterceptTest.java
@@ -6,6 +6,7 @@
  * @date 2017/2/4
  */
 public class InterceptTest {
+
     public static void main(String[] args) {
         Client client = new ClientImp();//主要想执行的方法
         //构造第一个拦截器
diff --git a/gRPC-Demo/src/main/java/cn/mrdear/grpc/hello/HelloWorldClient.java b/gRPC-Demo/src/main/java/cn/mrdear/grpc/hello/HelloWorldClient.java
@@ -17,22 +17,25 @@ public class HelloWorldClient {
 
     private final ManagedChannel channel; //一个gRPC信道
     private final GreeterGrpc.GreeterBlockingStub blockingStub;//阻塞/同步 存根
+    private GreeterGrpc.GreeterFutureStub futureStub;//非阻塞/同步 存根
+    private GreeterGrpc.GreeterStub asyncStub;//非阻塞/异步 存根
 
    //初始化信道和存根
     public HelloWorldClient(String host,int port){
         this(ManagedChannelBuilder.forAddress(host, port)
-                                  // Channels are secure by default (via SSL/TLS). For the example we disable TLS to avoid
-                                  // needing certificates.
                                   .usePlaintext(true));
     }
 
-    /** Construct client for accessing RouteGuide server using the existing channel. */
     private HelloWorldClient(ManagedChannelBuilder<?> channelBuilder) {
+        //信道应该是长连接,存根则每次调用创建一个
         channel = channelBuilder.build();
         //使用gzip压缩
         blockingStub = GreeterGrpc.newBlockingStub(channel).withCompression("gzip");
+//        futureStub = GreeterGrpc.newFutureStub(channel).withCompression("gzip");
+//        asyncStub = GreeterGrpc.newStub(channel).withCompression("gzip");
     }
 
+
     public void shutdown() throws InterruptedException {
         channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);
     }
diff --git a/gRPC-Demo/src/main/java/cn/mrdear/grpc/hello/HelloWorldServer.java b/gRPC-Demo/src/main/java/cn/mrdear/grpc/hello/HelloWorldServer.java
@@ -20,26 +20,22 @@ public class HelloWorldServer {
 
     /**
      * 启动服务
-     * @throws IOException
      */
     private void start() throws IOException {
+
+        System.out.println("service start...");
         server = ServerBuilder.forPort(port)
                               .addService(new GreeterImpl())
                               .build()
                               .start();
-
-        System.out.println("service start...");
+      System.out.println("service started");
 
         //程序正常退出,系统调用 System.exit方法或虚拟机被关闭时执行该调用
-        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");
-            }
-        });
+        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
+            System.err.println("*** shutting down gRPC server since JVM is shutting down");
+            HelloWorldServer.this.stop();
+            System.err.println("*** server shut down");
+        }));
     }
 
     private void stop() {
diff --git a/gRPC-Demo/src/main/java/cn/mrdear/grpc/route/RouteGuideClient.java b/gRPC-Demo/src/main/java/cn/mrdear/grpc/route/RouteGuideClient.java
@@ -23,6 +23,7 @@
  * @date 2017/2/2
  */
 public class RouteGuideClient {
+
     private final ManagedChannel channel;//grpc信道,需要指定端口和地址
     private final RouteGuideGrpc.RouteGuideBlockingStub blockingStub;//阻塞/同步存根
     private final RouteGuideGrpc.RouteGuideStub asyncStub;//非阻塞,异步存根
