From 9f1c21d68ff279264affe376cb758a8a1cfd10d4 Mon Sep 17 00:00:00 2001
From: IceX2020 <IceX2020@163.com>
Date: Tue, 17 Nov 2020 00:03:29 +0800
Subject: [PATCH 1/3] sync

---
 02nio/nio01/.classpath                        | 44 +++++++++
 02nio/nio01/.project                          | 34 +++++++
 .../.settings/org.eclipse.jdt.apt.core.prefs  |  2 +
 .../.settings/org.eclipse.jdt.core.prefs      |  9 ++
 .../.settings/org.eclipse.m2e.core.prefs      |  4 +
 02nio/nio02/.classpath                        | 44 +++++++++
 02nio/nio02/.project                          | 34 +++++++
 .../org.eclipse.core.resources.prefs          |  3 +
 .../.settings/org.eclipse.jdt.apt.core.prefs  |  2 +
 .../.settings/org.eclipse.jdt.core.prefs      | 10 ++
 .../.settings/org.eclipse.m2e.core.prefs      |  4 +
 02nio/nio02/pom.xml                           |  7 +-
 .../gateway/filter/Http4InboundFilter.java    | 17 ++++
 .../gateway/inbound/HttpInboundHandler.java   | 55 +++--------
 .../httpclient4/HttpOutboundHandler.java      |  5 +
 .../httpclient5/Http5OutboundHandler.java     | 77 +++++++++++++++
 .../outbound/netty4/NettyHttpClient.java      | 98 ++++++++++---------
 .../okhttp/OkhttpOutboundHandler.java         |  4 -
 03concurrency/0301/.classpath                 | 44 +++++++++
 03concurrency/0301/.project                   | 34 +++++++
 .../.settings/org.eclipse.jdt.apt.core.prefs  |  2 +
 .../0301/.settings/org.eclipse.jdt.core.prefs |  9 ++
 .../0301/.settings/org.eclipse.m2e.core.prefs |  4 +
 .../java/java0/conc0303/Homework03_01.java    | 65 ++++++++++++
 .../java/java0/conc0303/Homework03_02.java    | 71 ++++++++++++++
 25 files changed, 589 insertions(+), 93 deletions(-)
 create mode 100644 02nio/nio01/.classpath
 create mode 100644 02nio/nio01/.project
 create mode 100644 02nio/nio01/.settings/org.eclipse.jdt.apt.core.prefs
 create mode 100644 02nio/nio01/.settings/org.eclipse.jdt.core.prefs
 create mode 100644 02nio/nio01/.settings/org.eclipse.m2e.core.prefs
 create mode 100644 02nio/nio02/.classpath
 create mode 100644 02nio/nio02/.project
 create mode 100644 02nio/nio02/.settings/org.eclipse.core.resources.prefs
 create mode 100644 02nio/nio02/.settings/org.eclipse.jdt.apt.core.prefs
 create mode 100644 02nio/nio02/.settings/org.eclipse.jdt.core.prefs
 create mode 100644 02nio/nio02/.settings/org.eclipse.m2e.core.prefs
 create mode 100644 02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/Http4InboundFilter.java
 create mode 100644 02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient5/Http5OutboundHandler.java
 delete mode 100644 02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
 create mode 100644 03concurrency/0301/.classpath
 create mode 100644 03concurrency/0301/.project
 create mode 100644 03concurrency/0301/.settings/org.eclipse.jdt.apt.core.prefs
 create mode 100644 03concurrency/0301/.settings/org.eclipse.jdt.core.prefs
 create mode 100644 03concurrency/0301/.settings/org.eclipse.m2e.core.prefs
 create mode 100644 03concurrency/0301/src/main/java/java0/conc0303/Homework03_01.java
 create mode 100644 03concurrency/0301/src/main/java/java0/conc0303/Homework03_02.java

diff --git a/02nio/nio01/.classpath b/02nio/nio01/.classpath
new file mode 100644
index 00000000..f0257c5a
--- /dev/null
+++ b/02nio/nio01/.classpath
@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="target/classes" path="src/main/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="src/test/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" path="target/generated-sources/annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="target/generated-test-sources/test-annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path="target/classes"/>
+</classpath>
diff --git a/02nio/nio01/.project b/02nio/nio01/.project
new file mode 100644
index 00000000..51d5310f
--- /dev/null
+++ b/02nio/nio01/.project
@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>nio01</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.m2e.core.maven2Builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.m2e.core.maven2Nature</nature>
+	</natures>
+	<filteredResources>
+		<filter>
+			<id>1604369931325</id>
+			<name></name>
+			<type>30</type>
+			<matcher>
+				<id>org.eclipse.core.resources.regexFilterMatcher</id>
+				<arguments>node_modules|.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
+			</matcher>
+		</filter>
+	</filteredResources>
+</projectDescription>
diff --git a/02nio/nio01/.settings/org.eclipse.jdt.apt.core.prefs b/02nio/nio01/.settings/org.eclipse.jdt.apt.core.prefs
new file mode 100644
index 00000000..d4313d4b
--- /dev/null
+++ b/02nio/nio01/.settings/org.eclipse.jdt.apt.core.prefs
@@ -0,0 +1,2 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.apt.aptEnabled=false
diff --git a/02nio/nio01/.settings/org.eclipse.jdt.core.prefs b/02nio/nio01/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 00000000..1b6e1ef2
--- /dev/null
+++ b/02nio/nio01/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,9 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.processAnnotations=disabled
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8
diff --git a/02nio/nio01/.settings/org.eclipse.m2e.core.prefs b/02nio/nio01/.settings/org.eclipse.m2e.core.prefs
new file mode 100644
index 00000000..f897a7f1
--- /dev/null
+++ b/02nio/nio01/.settings/org.eclipse.m2e.core.prefs
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff --git a/02nio/nio02/.classpath b/02nio/nio02/.classpath
new file mode 100644
index 00000000..f0257c5a
--- /dev/null
+++ b/02nio/nio02/.classpath
@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="target/classes" path="src/main/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="src/test/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" path="target/generated-sources/annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="target/generated-test-sources/test-annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path="target/classes"/>
+</classpath>
diff --git a/02nio/nio02/.project b/02nio/nio02/.project
new file mode 100644
index 00000000..0bd324f7
--- /dev/null
+++ b/02nio/nio02/.project
@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>netty-gateway</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.m2e.core.maven2Builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.m2e.core.maven2Nature</nature>
+	</natures>
+	<filteredResources>
+		<filter>
+			<id>1604369931312</id>
+			<name></name>
+			<type>30</type>
+			<matcher>
+				<id>org.eclipse.core.resources.regexFilterMatcher</id>
+				<arguments>node_modules|.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
+			</matcher>
+		</filter>
+	</filteredResources>
+</projectDescription>
diff --git a/02nio/nio02/.settings/org.eclipse.core.resources.prefs b/02nio/nio02/.settings/org.eclipse.core.resources.prefs
new file mode 100644
index 00000000..e9441bb1
--- /dev/null
+++ b/02nio/nio02/.settings/org.eclipse.core.resources.prefs
@@ -0,0 +1,3 @@
+eclipse.preferences.version=1
+encoding//src/main/java=UTF-8
+encoding/<project>=UTF-8
diff --git a/02nio/nio02/.settings/org.eclipse.jdt.apt.core.prefs b/02nio/nio02/.settings/org.eclipse.jdt.apt.core.prefs
new file mode 100644
index 00000000..d4313d4b
--- /dev/null
+++ b/02nio/nio02/.settings/org.eclipse.jdt.apt.core.prefs
@@ -0,0 +1,2 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.apt.aptEnabled=false
diff --git a/02nio/nio02/.settings/org.eclipse.jdt.core.prefs b/02nio/nio02/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 00000000..951833c6
--- /dev/null
+++ b/02nio/nio02/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,10 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.methodParameters=generate
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.processAnnotations=disabled
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8
diff --git a/02nio/nio02/.settings/org.eclipse.m2e.core.prefs b/02nio/nio02/.settings/org.eclipse.m2e.core.prefs
new file mode 100644
index 00000000..f897a7f1
--- /dev/null
+++ b/02nio/nio02/.settings/org.eclipse.m2e.core.prefs
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff --git a/02nio/nio02/pom.xml b/02nio/nio02/pom.xml
index 6cbbeffd..8af12a6e 100644
--- a/02nio/nio02/pom.xml
+++ b/02nio/nio02/pom.xml
@@ -52,7 +52,12 @@
             <artifactId>httpasyncclient</artifactId>
             <version>4.1.4</version>
         </dependency>
-    
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>4.4.0</version>
+        </dependency>
+
         <!--
         <dependency>
             <groupId>org.springframework.boot</groupId>
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/Http4InboundFilter.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/Http4InboundFilter.java
new file mode 100644
index 00000000..1ee70e46
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/Http4InboundFilter.java
@@ -0,0 +1,17 @@
+package io.github.kimmking.gateway.filter;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.FullHttpRequest;
+
+public class Http4InboundFilter implements HttpRequestFilter{
+    private final String nameServer;
+
+    public Http4InboundFilter(String nameServer) {
+        this.nameServer = nameServer;
+    }
+
+    @Override
+    public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
+        fullRequest.headers().set("nio", "卡");
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
index 22fb2525..1d930213 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
@@ -1,6 +1,9 @@
 package io.github.kimmking.gateway.inbound;
 
+import io.github.kimmking.gateway.filter.Http4InboundFilter;
+import io.github.kimmking.gateway.filter.HttpRequestFilter;
 import io.github.kimmking.gateway.outbound.httpclient4.HttpOutboundHandler;
+import io.github.kimmking.gateway.outbound.httpclient5.Http5OutboundHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.handler.codec.http.FullHttpRequest;
@@ -12,13 +15,19 @@ public class HttpInboundHandler extends ChannelInboundHandlerAdapter {
 
     private static Logger logger = LoggerFactory.getLogger(HttpInboundHandler.class);
     private final String proxyServer;
-    private HttpOutboundHandler handler;
-    
+
+    //    private HttpOutboundHandler handler;
+    private Http5OutboundHandler handler;
+    private HttpRequestFilter filter;
+
     public HttpInboundHandler(String proxyServer) {
         this.proxyServer = proxyServer;
-        handler = new HttpOutboundHandler(this.proxyServer);
+//        handler = new HttpOutboundHandler(this.proxyServer);
+        handler = new Http5OutboundHandler(this.proxyServer);
+        filter = (HttpRequestFilter)new Http4InboundFilter("ka");
+
     }
-    
+
     @Override
     public void channelReadComplete(ChannelHandlerContext ctx) {
         ctx.flush();
@@ -27,14 +36,9 @@ public void channelReadComplete(ChannelHandlerContext ctx) {
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) {
         try {
-            //logger.info("channelRead流量接口请求开始，时间为{}", startTime);
             FullHttpRequest fullRequest = (FullHttpRequest) msg;
-//            String uri = fullRequest.uri();
-//            //logger.info("接收到的请求url为{}", uri);
-//            if (uri.contains("/test")) {
-//                handlerTest(fullRequest, ctx);
-//            }
-    
+
+            filter.filter(fullRequest,ctx);
             handler.handle(fullRequest, ctx);
     
         } catch(Exception e) {
@@ -44,33 +48,4 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
         }
     }
 
-//    private void handlerTest(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
-//        FullHttpResponse response = null;
-//        try {
-//            String value = "hello,kimmking";
-//            response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(value.getBytes("UTF-8")));
-//            response.headers().set("Content-Type", "application/json");
-//            response.headers().setInt("Content-Length", response.content().readableBytes());
-//
-//        } catch (Exception e) {
-//            logger.error("处理测试接口出错", e);
-//            response = new DefaultFullHttpResponse(HTTP_1_1, NO_CONTENT);
-//        } finally {
-//            if (fullRequest != null) {
-//                if (!HttpUtil.isKeepAlive(fullRequest)) {
-//                    ctx.write(response).addListener(ChannelFutureListener.CLOSE);
-//                } else {
-//                    response.headers().set(CONNECTION, KEEP_ALIVE);
-//                    ctx.write(response);
-//                }
-//            }
-//        }
-//    }
-//
-//    @Override
-//    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
-//        cause.printStackTrace();
-//        ctx.close();
-//    }
-
 }
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
index 856dc168..f441d913 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
@@ -61,6 +61,11 @@ public void handle(final FullHttpRequest fullRequest, final ChannelHandlerContex
     
     private void fetchGet(final FullHttpRequest inbound, final ChannelHandlerContext ctx, final String url) {
         final HttpGet httpGet = new HttpGet(url);
+        for(String key: (inbound.headers().names())){
+            String value = inbound.headers().get(key);
+            httpGet.setHeader(key,value);
+            System.out.println(key+":"+value);
+        }
         //httpGet.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_CLOSE);
         httpGet.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_KEEP_ALIVE);
         httpclient.execute(httpGet, new FutureCallback<HttpResponse>() {
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient5/Http5OutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient5/Http5OutboundHandler.java
new file mode 100644
index 00000000..dddea295
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient5/Http5OutboundHandler.java
@@ -0,0 +1,77 @@
+package io.github.kimmking.gateway.outbound.httpclient5;
+
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.DefaultFullHttpResponse;
+import io.netty.handler.codec.http.FullHttpRequest;
+import io.netty.handler.codec.http.HttpUtil;
+import org.apache.hc.client5.http.classic.methods.HttpGet;
+import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
+import org.apache.hc.client5.http.impl.classic.HttpClients;
+import org.apache.hc.core5.http.ClassicHttpResponse;
+import org.apache.hc.core5.http.HttpEntity;
+import org.apache.hc.core5.http.HttpStatus;
+import org.apache.hc.core5.http.io.HttpClientResponseHandler;
+import org.apache.hc.core5.http.io.entity.EntityUtils;
+import org.apache.http.protocol.HTTP;
+
+import java.io.IOException;
+
+import static io.netty.handler.codec.http.HttpResponseStatus.OK;
+import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
+
+public class Http5OutboundHandler {
+    
+    private String backendUrl;
+    
+    public Http5OutboundHandler(String backendUrl) {
+        this.backendUrl = backendUrl.endsWith("/") ? backendUrl.substring(0, backendUrl.length() - 1) : backendUrl;
+    }
+
+    public void handle(final FullHttpRequest fullRequest, final ChannelHandlerContext ctx) throws IOException {
+        String responseBody = "";
+//        System.out.println(fullRequest);
+        try (CloseableHttpClient httpclient = HttpClients.createDefault()) {
+            HttpGet httpget = new HttpGet("http://127.0.0.1:8088/api/hello");
+            for(String key: (fullRequest.headers().names())){
+                if(key.equals("content-length")){
+                    continue;
+                }
+                String value = fullRequest.headers().get(key);
+                httpget.setHeader(key,value);
+//                System.out.println(key+":"+value);
+            }
+            httpget.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_KEEP_ALIVE);
+            HttpClientResponseHandler<String> responseHandler = new HttpClientResponseHandler<String>() {
+                @Override
+                public String handleResponse(ClassicHttpResponse response) throws IOException {
+                    int status = response.getCode();
+                    if (status >= HttpStatus.SC_SUCCESS && status < HttpStatus.SC_REDIRECTION) {
+                        final HttpEntity entity = response.getEntity();
+                        byte[] body = EntityUtils.toByteArray(entity);
+                        DefaultFullHttpResponse fhresponse = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(body));
+                        fhresponse.headers().set("Content-Type", "application/json");
+                        fhresponse.headers().setInt("Content-Length", Integer.parseInt(response.getFirstHeader("Content-Length").getValue()));
+                        if (fullRequest != null) {
+                            if (!HttpUtil.isKeepAlive(fullRequest)) {
+                                ctx.write(fhresponse).addListener(ChannelFutureListener.CLOSE);
+                            } else {
+                                ctx.write(fhresponse);
+                            }
+                        }
+                        ctx.flush();
+                    } else {
+                        exceptionCaught(ctx,null);
+                    }
+                    return null;
+                }
+            };
+            responseBody = httpclient.execute(httpget,responseHandler);
+        }
+    }
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
+        cause.printStackTrace();
+        ctx.close();
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
index 79aeb148..a1bb3130 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
@@ -1,51 +1,53 @@
-//package io.github.kimmking.gateway.outbound;
-//
-//import io.netty.bootstrap.Bootstrap;
-//import io.netty.channel.ChannelFuture;
-//import io.netty.channel.ChannelInitializer;
-//import io.netty.channel.ChannelOption;
-//import io.netty.channel.EventLoopGroup;
-//import io.netty.channel.nio.NioEventLoopGroup;
-//import io.netty.channel.socket.SocketChannel;
-//import io.netty.channel.socket.nio.NioSocketChannel;
-//import io.netty.handler.codec.http.HttpRequestEncoder;
-//import io.netty.handler.codec.http.HttpResponseDecoder;
-//
-//public class NettyHttpClient {
-//    public void connect(String host, int port) throws Exception {
-//        EventLoopGroup workerGroup = new NioEventLoopGroup();
-//
-//        try {
-//            Bootstrap b = new Bootstrap();
-//            b.group(workerGroup);
-//            b.channel(NioSocketChannel.class);
-//            b.option(ChannelOption.SO_KEEPALIVE, true);
-//            b.handler(new ChannelInitializer<SocketChannel>() {
-//                @Override
-//                public void initChannel(SocketChannel ch) throws Exception {
-//                    // 客户端接收到的是httpResponse响应，所以要使用HttpResponseDecoder进行解码
-//                    ch.pipeline().addLast(new HttpResponseDecoder());
+package io.github.kimmking.gateway.outbound.netty4;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelOption;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.http.HttpRequestEncoder;
+import io.netty.handler.codec.http.HttpResponseDecoder;
+
+public class NettyHttpClient {
+    public void connect(String host, int port) throws Exception {
+        EventLoopGroup workerGroup = new NioEventLoopGroup();
+
+        try {
+            Bootstrap b = new Bootstrap();
+            b.group(workerGroup);
+            b.channel(NioSocketChannel.class);
+            b.option(ChannelOption.SO_KEEPALIVE, true);
+
+            b.handler(new ChannelInitializer<SocketChannel>() {
+                @Override
+                public void initChannel(SocketChannel ch) throws Exception {
+                    // 客户端接收到的是httpResponse响应，所以要使用HttpResponseDecoder进行解码
+                    ch.pipeline().addLast(new HttpResponseDecoder());
 //                     客户端发送的是httprequest，所以要使用HttpRequestEncoder进行编码
-//                    ch.pipeline().addLast(new HttpRequestEncoder());
+                    ch.pipeline().addLast(new HttpRequestEncoder());
 //                    ch.pipeline().addLast(new HttpClientOutboundHandler());
-//                }
-//            });
-//
-//            // Start the client.
-//            ChannelFuture f = b.connect(host, port).sync();
-//
-//           
+                }
+            });
+
+            // Start the client.
+            ChannelFuture f = b.connect(host, port).sync();
+
+
 //            f.channel().write(request);
-//            f.channel().flush();
-//            f.channel().closeFuture().sync();
-//        } finally {
-//            workerGroup.shutdownGracefully();
-//        }
-//
-//    }
-//
-//    public static void main(String[] args) throws Exception {
-//        NettyHttpClient client = new NettyHttpClient();
-//        client.connect("127.0.0.1", 8844);
-//    }
-//}
\ No newline at end of file
+            f.channel().flush();
+            f.channel().closeFuture().sync();
+        } finally {
+            workerGroup.shutdownGracefully();
+        }
+
+    }
+
+    public static void main(String[] args) throws Exception {
+        NettyHttpClient client = new NettyHttpClient();
+
+        client.connect("127.0.0.1", 8808);
+    }
+}
\ No newline at end of file
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
deleted file mode 100644
index 5f194588..00000000
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
+++ /dev/null
@@ -1,4 +0,0 @@
-package io.github.kimmking.gateway.outbound.okhttp;
-
-public class OkhttpOutboundHandler {
-}
diff --git a/03concurrency/0301/.classpath b/03concurrency/0301/.classpath
new file mode 100644
index 00000000..f0257c5a
--- /dev/null
+++ b/03concurrency/0301/.classpath
@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="target/classes" path="src/main/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="src/test/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" path="target/generated-sources/annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="target/generated-test-sources/test-annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path="target/classes"/>
+</classpath>
diff --git a/03concurrency/0301/.project b/03concurrency/0301/.project
new file mode 100644
index 00000000..7dbde43d
--- /dev/null
+++ b/03concurrency/0301/.project
@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>0301</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.m2e.core.maven2Builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.m2e.core.maven2Nature</nature>
+	</natures>
+	<filteredResources>
+		<filter>
+			<id>1604369931292</id>
+			<name></name>
+			<type>30</type>
+			<matcher>
+				<id>org.eclipse.core.resources.regexFilterMatcher</id>
+				<arguments>node_modules|.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
+			</matcher>
+		</filter>
+	</filteredResources>
+</projectDescription>
diff --git a/03concurrency/0301/.settings/org.eclipse.jdt.apt.core.prefs b/03concurrency/0301/.settings/org.eclipse.jdt.apt.core.prefs
new file mode 100644
index 00000000..d4313d4b
--- /dev/null
+++ b/03concurrency/0301/.settings/org.eclipse.jdt.apt.core.prefs
@@ -0,0 +1,2 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.apt.aptEnabled=false
diff --git a/03concurrency/0301/.settings/org.eclipse.jdt.core.prefs b/03concurrency/0301/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 00000000..1b6e1ef2
--- /dev/null
+++ b/03concurrency/0301/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,9 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.processAnnotations=disabled
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8
diff --git a/03concurrency/0301/.settings/org.eclipse.m2e.core.prefs b/03concurrency/0301/.settings/org.eclipse.m2e.core.prefs
new file mode 100644
index 00000000..f897a7f1
--- /dev/null
+++ b/03concurrency/0301/.settings/org.eclipse.m2e.core.prefs
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff --git a/03concurrency/0301/src/main/java/java0/conc0303/Homework03_01.java b/03concurrency/0301/src/main/java/java0/conc0303/Homework03_01.java
new file mode 100644
index 00000000..2a1c2451
--- /dev/null
+++ b/03concurrency/0301/src/main/java/java0/conc0303/Homework03_01.java
@@ -0,0 +1,65 @@
+package java0.conc0303;
+
+import java0.conc0303.tool.CountDownLatchDemo;
+import java0.conc0303.tool.SemaphoreDemo;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.Semaphore;
+
+/**
+ * 本周作业：（必做）思考有多少种方式，在main函数启动一个新线程或线程池，
+ * 异步运行一个方法，拿到这个方法的返回值后，退出主线程？
+ * 写出你的方法，越多越好，提交到github。
+ *
+ * 一个简单的代码参考：
+ */
+public class Homework03_01 {
+    private static int result;
+    public static void main(String[] args)  throws InterruptedException{
+        long start=System.currentTimeMillis();
+        // 在这里创建一个线程或线程池，
+        // 异步执行 下面方法
+        CountDownLatch countDownLatch = new CountDownLatch(1);
+        for(int i=0;i<1;i++){
+            new Thread(new Homework03_01.readNum(i,countDownLatch)).start();
+        }
+        countDownLatch.await(); // 注意跟CyclicBarrier不同，这里在主线程await
+        System.out.println("==>各个子线程执行结束。。。。");
+        System.out.println("==>主线程执行结束。。。。");
+
+        // 确保  拿到result 并输出
+        System.out.println("异步计算结果为："+result);
+         
+        System.out.println("使用时间："+ (System.currentTimeMillis()-start) + " ms");
+        
+        // 然后退出main线程
+    }
+    
+    private static int sum() {
+        return fibo(36);
+    }
+    
+    private static int fibo(int a) {
+        if ( a < 2) 
+            return 1;
+        return fibo(a-1) + fibo(a-2);
+    }
+
+    static class readNum  implements Runnable{
+        private int id;
+        private CountDownLatch latch;
+        public readNum(int id,CountDownLatch latch){
+            this.id = id;
+            this.latch = latch;
+        }
+        @Override
+        public void run() {
+            synchronized (this){
+                System.out.println("id:"+id+","+Thread.currentThread().getName());
+                //latch.countDown();
+                result = sum();
+                latch.countDown();
+            }
+        }
+    }
+}
diff --git a/03concurrency/0301/src/main/java/java0/conc0303/Homework03_02.java b/03concurrency/0301/src/main/java/java0/conc0303/Homework03_02.java
new file mode 100644
index 00000000..f05de36c
--- /dev/null
+++ b/03concurrency/0301/src/main/java/java0/conc0303/Homework03_02.java
@@ -0,0 +1,71 @@
+package java0.conc0303;
+
+import java.util.concurrent.CyclicBarrier;
+
+/**
+ * 本周作业：（必做）思考有多少种方式，在main函数启动一个新线程或线程池，
+ * 异步运行一个方法，拿到这个方法的返回值后，退出主线程？
+ * 写出你的方法，越多越好，提交到github。
+ *
+ * 一个简单的代码参考：
+ */
+public class Homework03_02 {
+    private static int result;
+    private static int flag = 0;
+
+    public static void main(String[] args)  throws InterruptedException{
+        long start=System.currentTimeMillis();
+        // 在这里创建一个线程或线程池，
+        // 异步执行 下面方法
+        CyclicBarrier cyclicBarrier = new CyclicBarrier(1, new Runnable() {
+            @Override
+            public void run() {
+                result = sum();
+                System.out.println("异步计算结果为："+result);
+                flag = 1;
+            }
+        });
+        for (int i = 0; i < 1; i++) {
+            new Thread(new Homework03_02.readNum(i,cyclicBarrier)).start();
+        }
+
+        // 确保拿到resul并输出
+        while(flag == 1) {
+            System.out.println("异步计算结果为：" + result);
+            System.out.println("使用时间："+ (System.currentTimeMillis()-start) + " ms");
+        }
+        // 然后退出main线程
+    }
+    
+    private static int sum() {
+        return fibo(36);
+    }
+    
+    private static int fibo(int a) {
+        if ( a < 2) 
+            return 1;
+        return fibo(a-1) + fibo(a-2);
+    }
+
+    static class readNum implements Runnable{
+        private int id;
+        private CyclicBarrier cyc;
+        public readNum(int id, CyclicBarrier cyc){
+            this.id = id;
+            this.cyc = cyc;
+        }
+        @Override
+        public void run() {
+            synchronized (this){
+                System.out.println("id:"+id+","+Thread.currentThread().getName());
+                try {
+                    //cyc.await();
+                    System.out.println("线程组任务" + id + "结束，其他任务继续");
+                    cyc.await();   // 注意跟CountDownLatch不同，这里在子线程await
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+}

From 5f31af7908e6c0ebac72d41340f1010e94661df7 Mon Sep 17 00:00:00 2001
From: IceX2020 <IceX2020@163.com>
Date: Tue, 17 Nov 2020 00:03:29 +0800
Subject: [PATCH 2/3] sync

---
 02nio/nio01/.classpath                        | 44 +++++++++
 02nio/nio01/.project                          | 34 +++++++
 .../.settings/org.eclipse.jdt.apt.core.prefs  |  2 +
 .../.settings/org.eclipse.jdt.core.prefs      |  9 ++
 .../.settings/org.eclipse.m2e.core.prefs      |  4 +
 02nio/nio02/.classpath                        | 44 +++++++++
 02nio/nio02/.project                          | 34 +++++++
 .../org.eclipse.core.resources.prefs          |  3 +
 .../.settings/org.eclipse.jdt.apt.core.prefs  |  2 +
 .../.settings/org.eclipse.jdt.core.prefs      | 10 ++
 .../.settings/org.eclipse.m2e.core.prefs      |  4 +
 02nio/nio02/pom.xml                           |  7 +-
 .../gateway/filter/Http4InboundFilter.java    | 17 ++++
 .../gateway/inbound/HttpInboundHandler.java   | 55 +++--------
 .../httpclient4/HttpOutboundHandler.java      |  5 +
 .../httpclient5/Http5OutboundHandler.java     | 77 +++++++++++++++
 .../outbound/netty4/NettyHttpClient.java      | 98 ++++++++++---------
 .../okhttp/OkhttpOutboundHandler.java         |  4 -
 03concurrency/0301/.classpath                 | 44 +++++++++
 03concurrency/0301/.project                   | 34 +++++++
 .../.settings/org.eclipse.jdt.apt.core.prefs  |  2 +
 .../0301/.settings/org.eclipse.jdt.core.prefs |  9 ++
 .../0301/.settings/org.eclipse.m2e.core.prefs |  4 +
 .../java/java0/conc0303/Homework03_01.java    | 65 ++++++++++++
 .../java/java0/conc0303/Homework03_02.java    | 71 ++++++++++++++
 25 files changed, 589 insertions(+), 93 deletions(-)
 create mode 100644 02nio/nio01/.classpath
 create mode 100644 02nio/nio01/.project
 create mode 100644 02nio/nio01/.settings/org.eclipse.jdt.apt.core.prefs
 create mode 100644 02nio/nio01/.settings/org.eclipse.jdt.core.prefs
 create mode 100644 02nio/nio01/.settings/org.eclipse.m2e.core.prefs
 create mode 100644 02nio/nio02/.classpath
 create mode 100644 02nio/nio02/.project
 create mode 100644 02nio/nio02/.settings/org.eclipse.core.resources.prefs
 create mode 100644 02nio/nio02/.settings/org.eclipse.jdt.apt.core.prefs
 create mode 100644 02nio/nio02/.settings/org.eclipse.jdt.core.prefs
 create mode 100644 02nio/nio02/.settings/org.eclipse.m2e.core.prefs
 create mode 100644 02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/Http4InboundFilter.java
 create mode 100644 02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient5/Http5OutboundHandler.java
 delete mode 100644 02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
 create mode 100644 03concurrency/0301/.classpath
 create mode 100644 03concurrency/0301/.project
 create mode 100644 03concurrency/0301/.settings/org.eclipse.jdt.apt.core.prefs
 create mode 100644 03concurrency/0301/.settings/org.eclipse.jdt.core.prefs
 create mode 100644 03concurrency/0301/.settings/org.eclipse.m2e.core.prefs
 create mode 100644 03concurrency/0301/src/main/java/java0/conc0303/Homework03_01.java
 create mode 100644 03concurrency/0301/src/main/java/java0/conc0303/Homework03_02.java

diff --git a/02nio/nio01/.classpath b/02nio/nio01/.classpath
new file mode 100644
index 00000000..f0257c5a
--- /dev/null
+++ b/02nio/nio01/.classpath
@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="target/classes" path="src/main/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="src/test/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" path="target/generated-sources/annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="target/generated-test-sources/test-annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path="target/classes"/>
+</classpath>
diff --git a/02nio/nio01/.project b/02nio/nio01/.project
new file mode 100644
index 00000000..51d5310f
--- /dev/null
+++ b/02nio/nio01/.project
@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>nio01</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.m2e.core.maven2Builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.m2e.core.maven2Nature</nature>
+	</natures>
+	<filteredResources>
+		<filter>
+			<id>1604369931325</id>
+			<name></name>
+			<type>30</type>
+			<matcher>
+				<id>org.eclipse.core.resources.regexFilterMatcher</id>
+				<arguments>node_modules|.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
+			</matcher>
+		</filter>
+	</filteredResources>
+</projectDescription>
diff --git a/02nio/nio01/.settings/org.eclipse.jdt.apt.core.prefs b/02nio/nio01/.settings/org.eclipse.jdt.apt.core.prefs
new file mode 100644
index 00000000..d4313d4b
--- /dev/null
+++ b/02nio/nio01/.settings/org.eclipse.jdt.apt.core.prefs
@@ -0,0 +1,2 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.apt.aptEnabled=false
diff --git a/02nio/nio01/.settings/org.eclipse.jdt.core.prefs b/02nio/nio01/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 00000000..1b6e1ef2
--- /dev/null
+++ b/02nio/nio01/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,9 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.processAnnotations=disabled
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8
diff --git a/02nio/nio01/.settings/org.eclipse.m2e.core.prefs b/02nio/nio01/.settings/org.eclipse.m2e.core.prefs
new file mode 100644
index 00000000..f897a7f1
--- /dev/null
+++ b/02nio/nio01/.settings/org.eclipse.m2e.core.prefs
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff --git a/02nio/nio02/.classpath b/02nio/nio02/.classpath
new file mode 100644
index 00000000..f0257c5a
--- /dev/null
+++ b/02nio/nio02/.classpath
@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="target/classes" path="src/main/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="src/test/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" path="target/generated-sources/annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="target/generated-test-sources/test-annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path="target/classes"/>
+</classpath>
diff --git a/02nio/nio02/.project b/02nio/nio02/.project
new file mode 100644
index 00000000..0bd324f7
--- /dev/null
+++ b/02nio/nio02/.project
@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>netty-gateway</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.m2e.core.maven2Builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.m2e.core.maven2Nature</nature>
+	</natures>
+	<filteredResources>
+		<filter>
+			<id>1604369931312</id>
+			<name></name>
+			<type>30</type>
+			<matcher>
+				<id>org.eclipse.core.resources.regexFilterMatcher</id>
+				<arguments>node_modules|.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
+			</matcher>
+		</filter>
+	</filteredResources>
+</projectDescription>
diff --git a/02nio/nio02/.settings/org.eclipse.core.resources.prefs b/02nio/nio02/.settings/org.eclipse.core.resources.prefs
new file mode 100644
index 00000000..e9441bb1
--- /dev/null
+++ b/02nio/nio02/.settings/org.eclipse.core.resources.prefs
@@ -0,0 +1,3 @@
+eclipse.preferences.version=1
+encoding//src/main/java=UTF-8
+encoding/<project>=UTF-8
diff --git a/02nio/nio02/.settings/org.eclipse.jdt.apt.core.prefs b/02nio/nio02/.settings/org.eclipse.jdt.apt.core.prefs
new file mode 100644
index 00000000..d4313d4b
--- /dev/null
+++ b/02nio/nio02/.settings/org.eclipse.jdt.apt.core.prefs
@@ -0,0 +1,2 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.apt.aptEnabled=false
diff --git a/02nio/nio02/.settings/org.eclipse.jdt.core.prefs b/02nio/nio02/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 00000000..951833c6
--- /dev/null
+++ b/02nio/nio02/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,10 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.methodParameters=generate
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.processAnnotations=disabled
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8
diff --git a/02nio/nio02/.settings/org.eclipse.m2e.core.prefs b/02nio/nio02/.settings/org.eclipse.m2e.core.prefs
new file mode 100644
index 00000000..f897a7f1
--- /dev/null
+++ b/02nio/nio02/.settings/org.eclipse.m2e.core.prefs
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff --git a/02nio/nio02/pom.xml b/02nio/nio02/pom.xml
index 6cbbeffd..8af12a6e 100644
--- a/02nio/nio02/pom.xml
+++ b/02nio/nio02/pom.xml
@@ -52,7 +52,12 @@
             <artifactId>httpasyncclient</artifactId>
             <version>4.1.4</version>
         </dependency>
-    
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>4.4.0</version>
+        </dependency>
+
         <!--
         <dependency>
             <groupId>org.springframework.boot</groupId>
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/Http4InboundFilter.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/Http4InboundFilter.java
new file mode 100644
index 00000000..1ee70e46
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/Http4InboundFilter.java
@@ -0,0 +1,17 @@
+package io.github.kimmking.gateway.filter;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.FullHttpRequest;
+
+public class Http4InboundFilter implements HttpRequestFilter{
+    private final String nameServer;
+
+    public Http4InboundFilter(String nameServer) {
+        this.nameServer = nameServer;
+    }
+
+    @Override
+    public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
+        fullRequest.headers().set("nio", "卡");
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
index 22fb2525..1d930213 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
@@ -1,6 +1,9 @@
 package io.github.kimmking.gateway.inbound;
 
+import io.github.kimmking.gateway.filter.Http4InboundFilter;
+import io.github.kimmking.gateway.filter.HttpRequestFilter;
 import io.github.kimmking.gateway.outbound.httpclient4.HttpOutboundHandler;
+import io.github.kimmking.gateway.outbound.httpclient5.Http5OutboundHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.handler.codec.http.FullHttpRequest;
@@ -12,13 +15,19 @@ public class HttpInboundHandler extends ChannelInboundHandlerAdapter {
 
     private static Logger logger = LoggerFactory.getLogger(HttpInboundHandler.class);
     private final String proxyServer;
-    private HttpOutboundHandler handler;
-    
+
+    //    private HttpOutboundHandler handler;
+    private Http5OutboundHandler handler;
+    private HttpRequestFilter filter;
+
     public HttpInboundHandler(String proxyServer) {
         this.proxyServer = proxyServer;
-        handler = new HttpOutboundHandler(this.proxyServer);
+//        handler = new HttpOutboundHandler(this.proxyServer);
+        handler = new Http5OutboundHandler(this.proxyServer);
+        filter = (HttpRequestFilter)new Http4InboundFilter("ka");
+
     }
-    
+
     @Override
     public void channelReadComplete(ChannelHandlerContext ctx) {
         ctx.flush();
@@ -27,14 +36,9 @@ public void channelReadComplete(ChannelHandlerContext ctx) {
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) {
         try {
-            //logger.info("channelRead流量接口请求开始，时间为{}", startTime);
             FullHttpRequest fullRequest = (FullHttpRequest) msg;
-//            String uri = fullRequest.uri();
-//            //logger.info("接收到的请求url为{}", uri);
-//            if (uri.contains("/test")) {
-//                handlerTest(fullRequest, ctx);
-//            }
-    
+
+            filter.filter(fullRequest,ctx);
             handler.handle(fullRequest, ctx);
     
         } catch(Exception e) {
@@ -44,33 +48,4 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
         }
     }
 
-//    private void handlerTest(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
-//        FullHttpResponse response = null;
-//        try {
-//            String value = "hello,kimmking";
-//            response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(value.getBytes("UTF-8")));
-//            response.headers().set("Content-Type", "application/json");
-//            response.headers().setInt("Content-Length", response.content().readableBytes());
-//
-//        } catch (Exception e) {
-//            logger.error("处理测试接口出错", e);
-//            response = new DefaultFullHttpResponse(HTTP_1_1, NO_CONTENT);
-//        } finally {
-//            if (fullRequest != null) {
-//                if (!HttpUtil.isKeepAlive(fullRequest)) {
-//                    ctx.write(response).addListener(ChannelFutureListener.CLOSE);
-//                } else {
-//                    response.headers().set(CONNECTION, KEEP_ALIVE);
-//                    ctx.write(response);
-//                }
-//            }
-//        }
-//    }
-//
-//    @Override
-//    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
-//        cause.printStackTrace();
-//        ctx.close();
-//    }
-
 }
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
index 856dc168..f441d913 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
@@ -61,6 +61,11 @@ public void handle(final FullHttpRequest fullRequest, final ChannelHandlerContex
     
     private void fetchGet(final FullHttpRequest inbound, final ChannelHandlerContext ctx, final String url) {
         final HttpGet httpGet = new HttpGet(url);
+        for(String key: (inbound.headers().names())){
+            String value = inbound.headers().get(key);
+            httpGet.setHeader(key,value);
+            System.out.println(key+":"+value);
+        }
         //httpGet.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_CLOSE);
         httpGet.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_KEEP_ALIVE);
         httpclient.execute(httpGet, new FutureCallback<HttpResponse>() {
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient5/Http5OutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient5/Http5OutboundHandler.java
new file mode 100644
index 00000000..dddea295
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient5/Http5OutboundHandler.java
@@ -0,0 +1,77 @@
+package io.github.kimmking.gateway.outbound.httpclient5;
+
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.DefaultFullHttpResponse;
+import io.netty.handler.codec.http.FullHttpRequest;
+import io.netty.handler.codec.http.HttpUtil;
+import org.apache.hc.client5.http.classic.methods.HttpGet;
+import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
+import org.apache.hc.client5.http.impl.classic.HttpClients;
+import org.apache.hc.core5.http.ClassicHttpResponse;
+import org.apache.hc.core5.http.HttpEntity;
+import org.apache.hc.core5.http.HttpStatus;
+import org.apache.hc.core5.http.io.HttpClientResponseHandler;
+import org.apache.hc.core5.http.io.entity.EntityUtils;
+import org.apache.http.protocol.HTTP;
+
+import java.io.IOException;
+
+import static io.netty.handler.codec.http.HttpResponseStatus.OK;
+import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
+
+public class Http5OutboundHandler {
+    
+    private String backendUrl;
+    
+    public Http5OutboundHandler(String backendUrl) {
+        this.backendUrl = backendUrl.endsWith("/") ? backendUrl.substring(0, backendUrl.length() - 1) : backendUrl;
+    }
+
+    public void handle(final FullHttpRequest fullRequest, final ChannelHandlerContext ctx) throws IOException {
+        String responseBody = "";
+//        System.out.println(fullRequest);
+        try (CloseableHttpClient httpclient = HttpClients.createDefault()) {
+            HttpGet httpget = new HttpGet("http://127.0.0.1:8088/api/hello");
+            for(String key: (fullRequest.headers().names())){
+                if(key.equals("content-length")){
+                    continue;
+                }
+                String value = fullRequest.headers().get(key);
+                httpget.setHeader(key,value);
+//                System.out.println(key+":"+value);
+            }
+            httpget.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_KEEP_ALIVE);
+            HttpClientResponseHandler<String> responseHandler = new HttpClientResponseHandler<String>() {
+                @Override
+                public String handleResponse(ClassicHttpResponse response) throws IOException {
+                    int status = response.getCode();
+                    if (status >= HttpStatus.SC_SUCCESS && status < HttpStatus.SC_REDIRECTION) {
+                        final HttpEntity entity = response.getEntity();
+                        byte[] body = EntityUtils.toByteArray(entity);
+                        DefaultFullHttpResponse fhresponse = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(body));
+                        fhresponse.headers().set("Content-Type", "application/json");
+                        fhresponse.headers().setInt("Content-Length", Integer.parseInt(response.getFirstHeader("Content-Length").getValue()));
+                        if (fullRequest != null) {
+                            if (!HttpUtil.isKeepAlive(fullRequest)) {
+                                ctx.write(fhresponse).addListener(ChannelFutureListener.CLOSE);
+                            } else {
+                                ctx.write(fhresponse);
+                            }
+                        }
+                        ctx.flush();
+                    } else {
+                        exceptionCaught(ctx,null);
+                    }
+                    return null;
+                }
+            };
+            responseBody = httpclient.execute(httpget,responseHandler);
+        }
+    }
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
+        cause.printStackTrace();
+        ctx.close();
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
index 79aeb148..a1bb3130 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
@@ -1,51 +1,53 @@
-//package io.github.kimmking.gateway.outbound;
-//
-//import io.netty.bootstrap.Bootstrap;
-//import io.netty.channel.ChannelFuture;
-//import io.netty.channel.ChannelInitializer;
-//import io.netty.channel.ChannelOption;
-//import io.netty.channel.EventLoopGroup;
-//import io.netty.channel.nio.NioEventLoopGroup;
-//import io.netty.channel.socket.SocketChannel;
-//import io.netty.channel.socket.nio.NioSocketChannel;
-//import io.netty.handler.codec.http.HttpRequestEncoder;
-//import io.netty.handler.codec.http.HttpResponseDecoder;
-//
-//public class NettyHttpClient {
-//    public void connect(String host, int port) throws Exception {
-//        EventLoopGroup workerGroup = new NioEventLoopGroup();
-//
-//        try {
-//            Bootstrap b = new Bootstrap();
-//            b.group(workerGroup);
-//            b.channel(NioSocketChannel.class);
-//            b.option(ChannelOption.SO_KEEPALIVE, true);
-//            b.handler(new ChannelInitializer<SocketChannel>() {
-//                @Override
-//                public void initChannel(SocketChannel ch) throws Exception {
-//                    // 客户端接收到的是httpResponse响应，所以要使用HttpResponseDecoder进行解码
-//                    ch.pipeline().addLast(new HttpResponseDecoder());
+package io.github.kimmking.gateway.outbound.netty4;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelOption;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.http.HttpRequestEncoder;
+import io.netty.handler.codec.http.HttpResponseDecoder;
+
+public class NettyHttpClient {
+    public void connect(String host, int port) throws Exception {
+        EventLoopGroup workerGroup = new NioEventLoopGroup();
+
+        try {
+            Bootstrap b = new Bootstrap();
+            b.group(workerGroup);
+            b.channel(NioSocketChannel.class);
+            b.option(ChannelOption.SO_KEEPALIVE, true);
+
+            b.handler(new ChannelInitializer<SocketChannel>() {
+                @Override
+                public void initChannel(SocketChannel ch) throws Exception {
+                    // 客户端接收到的是httpResponse响应，所以要使用HttpResponseDecoder进行解码
+                    ch.pipeline().addLast(new HttpResponseDecoder());
 //                     客户端发送的是httprequest，所以要使用HttpRequestEncoder进行编码
-//                    ch.pipeline().addLast(new HttpRequestEncoder());
+                    ch.pipeline().addLast(new HttpRequestEncoder());
 //                    ch.pipeline().addLast(new HttpClientOutboundHandler());
-//                }
-//            });
-//
-//            // Start the client.
-//            ChannelFuture f = b.connect(host, port).sync();
-//
-//           
+                }
+            });
+
+            // Start the client.
+            ChannelFuture f = b.connect(host, port).sync();
+
+
 //            f.channel().write(request);
-//            f.channel().flush();
-//            f.channel().closeFuture().sync();
-//        } finally {
-//            workerGroup.shutdownGracefully();
-//        }
-//
-//    }
-//
-//    public static void main(String[] args) throws Exception {
-//        NettyHttpClient client = new NettyHttpClient();
-//        client.connect("127.0.0.1", 8844);
-//    }
-//}
\ No newline at end of file
+            f.channel().flush();
+            f.channel().closeFuture().sync();
+        } finally {
+            workerGroup.shutdownGracefully();
+        }
+
+    }
+
+    public static void main(String[] args) throws Exception {
+        NettyHttpClient client = new NettyHttpClient();
+
+        client.connect("127.0.0.1", 8808);
+    }
+}
\ No newline at end of file
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
deleted file mode 100644
index 5f194588..00000000
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
+++ /dev/null
@@ -1,4 +0,0 @@
-package io.github.kimmking.gateway.outbound.okhttp;
-
-public class OkhttpOutboundHandler {
-}
diff --git a/03concurrency/0301/.classpath b/03concurrency/0301/.classpath
new file mode 100644
index 00000000..f0257c5a
--- /dev/null
+++ b/03concurrency/0301/.classpath
@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="target/classes" path="src/main/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="src/test/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" path="target/generated-sources/annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="target/generated-test-sources/test-annotations">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="ignore_optional_problems" value="true"/>
+			<attribute name="m2e-apt" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path="target/classes"/>
+</classpath>
diff --git a/03concurrency/0301/.project b/03concurrency/0301/.project
new file mode 100644
index 00000000..7dbde43d
--- /dev/null
+++ b/03concurrency/0301/.project
@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>0301</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.m2e.core.maven2Builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.m2e.core.maven2Nature</nature>
+	</natures>
+	<filteredResources>
+		<filter>
+			<id>1604369931292</id>
+			<name></name>
+			<type>30</type>
+			<matcher>
+				<id>org.eclipse.core.resources.regexFilterMatcher</id>
+				<arguments>node_modules|.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
+			</matcher>
+		</filter>
+	</filteredResources>
+</projectDescription>
diff --git a/03concurrency/0301/.settings/org.eclipse.jdt.apt.core.prefs b/03concurrency/0301/.settings/org.eclipse.jdt.apt.core.prefs
new file mode 100644
index 00000000..d4313d4b
--- /dev/null
+++ b/03concurrency/0301/.settings/org.eclipse.jdt.apt.core.prefs
@@ -0,0 +1,2 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.apt.aptEnabled=false
diff --git a/03concurrency/0301/.settings/org.eclipse.jdt.core.prefs b/03concurrency/0301/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 00000000..1b6e1ef2
--- /dev/null
+++ b/03concurrency/0301/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,9 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.processAnnotations=disabled
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8
diff --git a/03concurrency/0301/.settings/org.eclipse.m2e.core.prefs b/03concurrency/0301/.settings/org.eclipse.m2e.core.prefs
new file mode 100644
index 00000000..f897a7f1
--- /dev/null
+++ b/03concurrency/0301/.settings/org.eclipse.m2e.core.prefs
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff --git a/03concurrency/0301/src/main/java/java0/conc0303/Homework03_01.java b/03concurrency/0301/src/main/java/java0/conc0303/Homework03_01.java
new file mode 100644
index 00000000..2a1c2451
--- /dev/null
+++ b/03concurrency/0301/src/main/java/java0/conc0303/Homework03_01.java
@@ -0,0 +1,65 @@
+package java0.conc0303;
+
+import java0.conc0303.tool.CountDownLatchDemo;
+import java0.conc0303.tool.SemaphoreDemo;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.Semaphore;
+
+/**
+ * 本周作业：（必做）思考有多少种方式，在main函数启动一个新线程或线程池，
+ * 异步运行一个方法，拿到这个方法的返回值后，退出主线程？
+ * 写出你的方法，越多越好，提交到github。
+ *
+ * 一个简单的代码参考：
+ */
+public class Homework03_01 {
+    private static int result;
+    public static void main(String[] args)  throws InterruptedException{
+        long start=System.currentTimeMillis();
+        // 在这里创建一个线程或线程池，
+        // 异步执行 下面方法
+        CountDownLatch countDownLatch = new CountDownLatch(1);
+        for(int i=0;i<1;i++){
+            new Thread(new Homework03_01.readNum(i,countDownLatch)).start();
+        }
+        countDownLatch.await(); // 注意跟CyclicBarrier不同，这里在主线程await
+        System.out.println("==>各个子线程执行结束。。。。");
+        System.out.println("==>主线程执行结束。。。。");
+
+        // 确保  拿到result 并输出
+        System.out.println("异步计算结果为："+result);
+         
+        System.out.println("使用时间："+ (System.currentTimeMillis()-start) + " ms");
+        
+        // 然后退出main线程
+    }
+    
+    private static int sum() {
+        return fibo(36);
+    }
+    
+    private static int fibo(int a) {
+        if ( a < 2) 
+            return 1;
+        return fibo(a-1) + fibo(a-2);
+    }
+
+    static class readNum  implements Runnable{
+        private int id;
+        private CountDownLatch latch;
+        public readNum(int id,CountDownLatch latch){
+            this.id = id;
+            this.latch = latch;
+        }
+        @Override
+        public void run() {
+            synchronized (this){
+                System.out.println("id:"+id+","+Thread.currentThread().getName());
+                //latch.countDown();
+                result = sum();
+                latch.countDown();
+            }
+        }
+    }
+}
diff --git a/03concurrency/0301/src/main/java/java0/conc0303/Homework03_02.java b/03concurrency/0301/src/main/java/java0/conc0303/Homework03_02.java
new file mode 100644
index 00000000..f05de36c
--- /dev/null
+++ b/03concurrency/0301/src/main/java/java0/conc0303/Homework03_02.java
@@ -0,0 +1,71 @@
+package java0.conc0303;
+
+import java.util.concurrent.CyclicBarrier;
+
+/**
+ * 本周作业：（必做）思考有多少种方式，在main函数启动一个新线程或线程池，
+ * 异步运行一个方法，拿到这个方法的返回值后，退出主线程？
+ * 写出你的方法，越多越好，提交到github。
+ *
+ * 一个简单的代码参考：
+ */
+public class Homework03_02 {
+    private static int result;
+    private static int flag = 0;
+
+    public static void main(String[] args)  throws InterruptedException{
+        long start=System.currentTimeMillis();
+        // 在这里创建一个线程或线程池，
+        // 异步执行 下面方法
+        CyclicBarrier cyclicBarrier = new CyclicBarrier(1, new Runnable() {
+            @Override
+            public void run() {
+                result = sum();
+                System.out.println("异步计算结果为："+result);
+                flag = 1;
+            }
+        });
+        for (int i = 0; i < 1; i++) {
+            new Thread(new Homework03_02.readNum(i,cyclicBarrier)).start();
+        }
+
+        // 确保拿到resul并输出
+        while(flag == 1) {
+            System.out.println("异步计算结果为：" + result);
+            System.out.println("使用时间："+ (System.currentTimeMillis()-start) + " ms");
+        }
+        // 然后退出main线程
+    }
+    
+    private static int sum() {
+        return fibo(36);
+    }
+    
+    private static int fibo(int a) {
+        if ( a < 2) 
+            return 1;
+        return fibo(a-1) + fibo(a-2);
+    }
+
+    static class readNum implements Runnable{
+        private int id;
+        private CyclicBarrier cyc;
+        public readNum(int id, CyclicBarrier cyc){
+            this.id = id;
+            this.cyc = cyc;
+        }
+        @Override
+        public void run() {
+            synchronized (this){
+                System.out.println("id:"+id+","+Thread.currentThread().getName());
+                try {
+                    //cyc.await();
+                    System.out.println("线程组任务" + id + "结束，其他任务继续");
+                    cyc.await();   // 注意跟CountDownLatch不同，这里在子线程await
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+}

From bca64a6e860105960bb9878eecea6dbcf9976455 Mon Sep 17 00:00:00 2001
From: IceX2020 <IceX2020@163.com>
Date: Tue, 5 Jan 2021 23:58:56 +0800
Subject: [PATCH 3/3] ll

---
 07rpc/rpc01/rpcfx-core/pom.xml                | 13 +++-
 .../rpcfx/client/NettyClientHandler.java      | 60 ++++++++++++++++
 .../java/io/kimmking/rpcfx/client/Rpcfx.java  | 69 ++++++++++++++++---
 .../demo/consumer/RpcfxClientApplication.java |  4 +-
 .../demo/provider/RpcfxServerApplication.java |  2 +
 .../src/main/resources/application.yml        |  2 +-
 6 files changed, 137 insertions(+), 13 deletions(-)
 create mode 100644 07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/NettyClientHandler.java

diff --git a/07rpc/rpc01/rpcfx-core/pom.xml b/07rpc/rpc01/rpcfx-core/pom.xml
index 8f11dc5d..7375a87f 100644
--- a/07rpc/rpc01/rpcfx-core/pom.xml
+++ b/07rpc/rpc01/rpcfx-core/pom.xml
@@ -51,6 +51,17 @@
 				</exclusion>
 			</exclusions>
 		</dependency>
-	</dependencies>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.45.Final</version>
+        </dependency>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.34.Final</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
 
 </project>
diff --git a/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/NettyClientHandler.java b/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/NettyClientHandler.java
new file mode 100644
index 00000000..3adb1a31
--- /dev/null
+++ b/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/NettyClientHandler.java
@@ -0,0 +1,60 @@
+package io.kimmking.rpcfx.client;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.*;
+import io.netty.handler.codec.http.*;
+import io.netty.util.CharsetUtil;
+
+import java.net.InetSocketAddress;
+import java.util.concurrent.TimeUnit;
+
+public class NettyClientHandler extends ChannelInboundHandlerAdapter{
+    private String reqJson;
+
+    public NettyClientHandler(String reqJson) {
+        this.reqJson = reqJson;
+    }
+
+    // 客户端连接服务器后被调用
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        System.out.println("客户端连接服务器，开始发送数据……");
+        byte[] req = reqJson.getBytes("UTF-8");//消息
+        ByteBuf firstMessage = Unpooled.wrappedBuffer(req);//发送类
+
+        FullHttpRequest httpRequest = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1,HttpMethod.POST,"http://127.0.0.1:8090",firstMessage);
+        //https://blog.csdn.net/xbt312/article/details/99829118
+        //https://www.cnblogs.com/newyouth/p/14014708.html
+        httpRequest.headers().set(HttpHeaders.Names.HOST, "127.0.0.1");
+        httpRequest.headers().set(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
+        httpRequest.headers().set(HttpHeaders.Names.CONTENT_LENGTH, httpRequest.content().readableBytes());
+        httpRequest.headers().set(HttpHeaders.Names.CONTENT_TYPE, "application/json");
+
+        ctx.writeAndFlush(httpRequest);//flush
+        System.out.println("客户端连接服务器，开始发送数据……完成");
+    }
+
+    // • 从服务器接收到数据后调用
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object response)
+            throws Exception {
+        System.out.println("client 读取server数据..");
+        // 服务端返回消息后
+        FullHttpResponse msg = (FullHttpResponse)response;
+        String msgr = msg.content().toString(CharsetUtil.UTF_8);
+        System.out.println("服务端数据为 :" + msgr);
+        Rpcfx.RpcfxInvocationHandler.respJson = msgr;
+        ctx.channel().close();
+    }
+
+    // • 发生异常时被调用
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
+            throws Exception {
+        System.out.println("client exceptionCaught..");
+        // 释放资源
+        ctx.close();
+    }
+}
\ No newline at end of file
diff --git a/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java b/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java
index 3d7b3788..c680df84 100644
--- a/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java
+++ b/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java
@@ -5,15 +5,34 @@
 import com.alibaba.fastjson.parser.ParserConfig;
 import io.kimmking.rpcfx.api.RpcfxRequest;
 import io.kimmking.rpcfx.api.RpcfxResponse;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.handler.codec.LineBasedFrameDecoder;
+import io.netty.handler.codec.http.*;
+import io.netty.handler.codec.json.JsonObjectDecoder;
+import io.netty.handler.codec.string.StringDecoder;
+import io.netty.handler.codec.string.StringEncoder;
 import okhttp3.MediaType;
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
 import okhttp3.RequestBody;
 
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelOption;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+
 import java.io.IOException;
 import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.Method;
 import java.lang.reflect.Proxy;
+import java.lang.reflect.Type;
+import java.net.URI;
+import java.nio.charset.StandardCharsets;
 
 public final class Rpcfx {
 
@@ -31,9 +50,11 @@ public static <T> T create(final Class<T> serviceClass, final String url) {
     public static class RpcfxInvocationHandler implements InvocationHandler {
 
         public static final MediaType JSONTYPE = MediaType.get("application/json; charset=utf-8");
-
+        public static String respJson = null;
         private final Class<?> serviceClass;
         private final String url;
+        private final String host = "127.0.0.1";
+        private final String port = "8090";
         public <T> RpcfxInvocationHandler(Class<T> serviceClass, String url) {
             this.serviceClass = serviceClass;
             this.url = url;
@@ -58,20 +79,50 @@ public Object invoke(Object proxy, Method method, Object[] params) throws Throwa
             return JSON.parse(response.getResult().toString());
         }
 
-        private RpcfxResponse post(RpcfxRequest req, String url) throws IOException {
+        private RpcfxResponse post(RpcfxRequest req, String url) throws IOException, InterruptedException {
             String reqJson = JSON.toJSONString(req);
             System.out.println("req json: "+reqJson);
 
             // 1.可以复用client
             // 2.尝试使用httpclient或者netty client
-            OkHttpClient client = new OkHttpClient();
-            final Request request = new Request.Builder()
-                    .url(url)
-                    .post(RequestBody.create(JSONTYPE, reqJson))
-                    .build();
-            String respJson = client.newCall(request).execute().body().string();
-            System.out.println("resp json: "+respJson);
+
+//            OkHttpClient client = new OkHttpClient();
+//            final Request request = new Request.Builder()
+//                    .url(url)
+//                    .post(RequestBody.create(JSONTYPE, reqJson))
+//                    .build();
+//            String respJson = client.newCall(request).execute().body().string();
+
+//            使用netty实现
+            EventLoopGroup workerGroup = new NioEventLoopGroup();
+            try {
+                Bootstrap bootstrap = new Bootstrap();
+                bootstrap.group(workerGroup);
+                bootstrap.channel(NioSocketChannel.class);
+//                bootstrap.option(ChannelOption.SO_KEEPALIVE, true);
+                NettyClientHandler nettyhandle = new NettyClientHandler(reqJson);
+                bootstrap.handler(new ChannelInitializer<SocketChannel>() {
+                    @Override
+                    public void initChannel(SocketChannel ch) throws Exception {
+                        // 客户端接收到的是httpResponse响应，所以要使用HttpResponseDecoder进行解码
+                        ch.pipeline().addLast(new HttpClientCodec());
+                        /*聚合http为一个完整的报文*/
+                        ch.pipeline().addLast("aggregator", new HttpObjectAggregator(10*1024*1024));
+                        ch.pipeline().addLast(nettyhandle);
+                    }
+                });
+
+                ChannelFuture f = bootstrap.connect("127.0.0.1",8866).sync();
+                f.channel().closeFuture().sync();
+            }catch(Exception e){
+                System.out.println(e.toString());
+            }
+            finally {
+                workerGroup.shutdownGracefully();
+            }
+            System.out.println("======================" + respJson);
             return JSON.parseObject(respJson, RpcfxResponse.class);
         }
+
     }
 }
diff --git a/07rpc/rpc01/rpcfx-demo-consumer/src/main/java/io/kimmking/rpcfx/demo/consumer/RpcfxClientApplication.java b/07rpc/rpc01/rpcfx-demo-consumer/src/main/java/io/kimmking/rpcfx/demo/consumer/RpcfxClientApplication.java
index 17537bb9..bb5036d2 100644
--- a/07rpc/rpc01/rpcfx-demo-consumer/src/main/java/io/kimmking/rpcfx/demo/consumer/RpcfxClientApplication.java
+++ b/07rpc/rpc01/rpcfx-demo-consumer/src/main/java/io/kimmking/rpcfx/demo/consumer/RpcfxClientApplication.java
@@ -20,11 +20,11 @@ public static void main(String[] args) {
 		// UserService service = new xxx();
 		// service.findById
 
-		UserService userService = Rpcfx.create(UserService.class, "http://localhost:8080/");
+		UserService userService = Rpcfx.create(UserService.class, "http://127.0.0.1:8866/");
 		User user = userService.findById(1);
 		System.out.println("find user id=1 from server: " + user.getName());
 
-		OrderService orderService = Rpcfx.create(OrderService.class, "http://localhost:8080/");
+		OrderService orderService = Rpcfx.create(OrderService.class, "http://127.0.0.1:8866/");
 		Order order = orderService.findOrderById(1992129);
 		System.out.println(String.format("find order name=%s, amount=%f",order.getName(),order.getAmount()));
 
diff --git a/07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java b/07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java
index 266618de..1c4dcbd5 100644
--- a/07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java
+++ b/07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java
@@ -27,7 +27,9 @@ public static void main(String[] args) {
 
 	@PostMapping("/")
 	public RpcfxResponse invoke(@RequestBody RpcfxRequest request) {
+		System.out.println("heelp");
 		return invoker.invoke(request);
+//		return "hello world";
 	}
 
 	@Bean
diff --git a/07rpc/rpc01/rpcfx-demo-provider/src/main/resources/application.yml b/07rpc/rpc01/rpcfx-demo-provider/src/main/resources/application.yml
index 5164ac23..7e88dd93 100644
--- a/07rpc/rpc01/rpcfx-demo-provider/src/main/resources/application.yml
+++ b/07rpc/rpc01/rpcfx-demo-provider/src/main/resources/application.yml
@@ -1,5 +1,5 @@
 server:
-  port: 8080
+  port: 8090
   
   profiles:
     active: true