1.（必做）整合你上次作业的 httpclient/okhttp；

bl03615 · bl03615 · commit c60c14023527 · 2021-08-19T00:52:32.000+08:00
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/client/HttpClientTest.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/client/HttpClientTest.java
@@ -0,0 +1,50 @@
+package io.github.kimmking.gateway.client;
+
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpStatus;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+
+import java.io.IOException;
+import java.util.Objects;
+
+public class HttpClientTest {
+
+    public static void main(String[] args) throws IOException {
+
+        CloseableHttpResponse response = null;
+        HttpGet get = null;
+
+        CloseableHttpClient client = HttpClients.createDefault();
+
+        try {
+            StringBuilder url = new StringBuilder("http://localhost:8888");
+            get = new HttpGet(url.toString());
+
+            response = client.execute(get);
+            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
+                HttpEntity entity = response.getEntity();
+                String html = EntityUtils.toString(entity, "utf-8");
+                System.out.println(html);
+            }
+        } catch (Exception e){
+            e.printStackTrace();
+        }
+        finally {
+            if (Objects.nonNull(response)) {
+                response.close();
+            }
+
+            if (Objects.nonNull(get)) {
+                get.releaseConnection();
+            }
+
+            client.close();
+        }
+
+    }
+
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java
@@ -53,6 +53,7 @@ public void run() throws Exception {
             System.out.println("&#24320;&#21551;netty http&#26381;&#21153;&#22120;&#65292;&#30417;&#21548;&#22320;&#22336;&#21644;&#31471;&#21475;&#20026; http://127.0.0.1:" + port + '/');
             ch.closeFuture().sync();
         } finally {
+            System.out.println("&#20851;&#38381;&#32447;&#31243;&#32452;");
             bossGroup.shutdownGracefully();
             workerGroup.shutdownGracefully();
         }
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/server/HttpServerTest.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/server/HttpServerTest.java
@@ -0,0 +1,60 @@
+package io.github.kimmking.gateway.server;
+
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class HttpServerTest {
+
+    static int port = 8801;
+
+    public static void main(String[] args) throws IOException {
+
+        if (args != null && args.length > 0) {
+            try {
+                port = Integer.valueOf(args[0]);
+            } catch (NumberFormatException e) {
+                e.printStackTrace();
+            }
+
+        }
+
+        ServerSocket serverSocket = new ServerSocket(port);
+
+        while (true){
+            try {
+                Socket socket = serverSocket.accept();
+                service(socket);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+    }
+
+    private static void service(Socket socket) {
+
+        try {
+            PrintWriter printWriter = new PrintWriter(socket.getOutputStream(),true);
+            printWriter.println("HTTP/1.1 200 OK");
+            printWriter.println("Content-Type:text/html;charset=utf-8");
+            String body = "hello,nio" + port;
+            printWriter.println("Content-Length:" + body.getBytes().length);
+            printWriter.println();
+
+            printWriter.write(body);
+            printWriter.close();
+
+            //&#36825;&#37324;&#20027;&#35201;&#26159;&#20026;&#20102;&#35753;httpClient&#21487;&#20197;&#22312;server&#30340;socket&#20851;&#38381;&#21069;&#65292;&#25343;&#21040;&#36820;&#22238;&#30340;&#32467;&#26524;
+            Thread.sleep(10);
+
+            socket.close();
+
+        } catch (IOException | InterruptedException e) {
+            e.printStackTrace();
+        }
+
+    }
+
+}

Original file line number	Diff line number	Diff line change
`@@ -53,6 +53,7 @@ public void run() throws Exception {`
`53`	`53`	`System.out.println("开启netty http服务器，监听地址和端口为 http://127.0.0.1:" + port + '/');`
`54`	`54`	`ch.closeFuture().sync();`
`55`	`55`	`} finally {`
	`56`	`+ System.out.println("关闭线程组");`
`56`	`57`	`bossGroup.shutdownGracefully();`
`57`	`58`	`workerGroup.shutdownGracefully();`
`58`	`59`	`}`