Java开发第四期作业

.gitignore

@@ -1,2 +1,28 @@
-*idea/
-*ignore/
+target/
+pom.xml.tag
+pom.xml.releaseBackup
+pom.xml.versionsBackup
+pom.xml.next
+release.properties
+dependency-reduced-pom.xml
+buildNumber.properties
+.mvn
+# https://github.com/takari/maven-wrapper#usage-without-binary-jar
+.mvn/wrapper/maven-wrapper.jar
+*/bin/tpid
+agent.log*
+logs/**
+log/**
+*.jar
+*.pyc
+*.log
+*/.settings
+/.idea/
+.idea/workspace.xml
+*.iml
+.project
+.history
+.vscode
+.classpath
+.factorypath
+org.eclipse*

developer/back-end/wen20200323/Java开发第三期作业.md

@@ -1,19 +1,12 @@
-# Java开发第三期作业
+# Java开发第四期作业
 
 ## 目的
 - 学会使用restful的风格开发接口
-
-- 了解RPC的基本概念及思想，熟悉gRPC的开发流程
+- 学会使用postman
 
 ## 内容
 
 ### 改造以前的作业为Restful风格形式
 - 名词，尽量不出现动词
 - 小写，以短横线‘-’连接
 - get/post/put/delete方法的使用
-
-### 完成一个gRPC服务器和客户端的搭建，熟悉proto文件格式
-
-- Web
-- Client
-- Proto

developer/back-end/wen20200323/chengwen/grpc-demo/src/main/java/com/changw98/grpcdemo/client/MyGrpcClient.java

@@ -0,0 +1,51 @@
+package com.changw98.grpcdemo.client;
+
+import com.changw98.grpcdemo.generate.MyRequest;
+import com.changw98.grpcdemo.generate.MyResponse;
+import com.changw98.grpcdemo.generate.MyServiceGrpc;
+import io.grpc.ManagedChannel;
+import io.grpc.ManagedChannelBuilder;
+
+import java.util.concurrent.TimeUnit;
+
+
+/**
+ * @Author: ChengWen
+ * @Date: 2020/3/25
+ * Time: 20:46
+ * Description:
+ */
+public class MyGrpcClient {
+
+    private final ManagedChannel channel;
+    private final MyServiceGrpc.MyServiceBlockingStub blockingStub;
+
+
+    public MyGrpcClient(String host,int port){
+        channel=ManagedChannelBuilder.forAddress(host,port)
+                .usePlaintext(true)
+                .build();
+        blockingStub=MyServiceGrpc.newBlockingStub(channel);
+    }
+
+    public void shutdown() throws InterruptedException
+    {
+        channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);
+    }
+
+    public void greet(String name)
+    {
+        MyRequest myRequest=MyRequest.newBuilder().setName(name).build();
+        MyResponse myResponse=blockingStub.sayHello(myRequest);
+        System.out.println(myResponse.getMessage());
+    }
+
+    public static void main(String[] args)throws InterruptedException {
+        MyGrpcClient myGrpcClient=new MyGrpcClient("127.0.0.1",5001);
+        System.out.println("-------------------客户端开始访问请求-------------------");
+        for (int i = 0; i < 100; i++) {
+            myGrpcClient.greet("你若想生存，绝处也能缝生: " + i);
+        }
+    }
+
+}