ClientHttp整合，过滤器添加

02nio/nio02/src/main/java/io/github/kimmking/gateway/clientFilter/HeaderHttpClientRequestFilter.java

@@ -0,0 +1,13 @@
+package io.github.kimmking.gateway.clientFilter;
+
+import io.github.kimmking.gateway.filter.HttpRequestFilter;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.FullHttpRequest;
+
+public class HeaderHttpClientRequestFilter implements HttpRequestFilter {
+
+    @Override
+    public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
+        fullRequest.headers().set("testClient", "testClient");
+    }
+}

02nio/nio02/src/main/java/io/github/kimmking/gateway/clientFilter/HeaderHttpClientResponseFilter.java

@@ -0,0 +1,11 @@
+package io.github.kimmking.gateway.clientFilter;
+
+import io.github.kimmking.gateway.filter.HttpResponseFilter;
+import io.netty.handler.codec.http.FullHttpResponse;
+
+public class HeaderHttpClientResponseFilter implements HttpResponseFilter {
+    @Override
+    public void filter(FullHttpResponse response) {
+        response.headers().set("test", "test-nio");
+    }
+}

02nio/nio02/src/main/java/io/github/kimmking/gateway/clientFilter/HttpClientRequestFilter.java

@@ -0,0 +1,10 @@
+package io.github.kimmking.gateway.clientFilter;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.FullHttpRequest;
+
+public interface HttpClientRequestFilter {
+
+    void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx);
+
+}

02nio/nio02/src/main/java/io/github/kimmking/gateway/clientFilter/HttpClientResponseFilter.java

@@ -0,0 +1,9 @@
+package io.github.kimmking.gateway.clientFilter;
+
+import io.netty.handler.codec.http.FullHttpResponse;
+
+public interface HttpClientResponseFilter {
+
+    void filter(FullHttpResponse response);
+
+}

02nio/nio02/src/main/java/io/github/kimmking/gateway/clientHttp/HttpClientTest2.java

@@ -0,0 +1,58 @@
+package io.github.kimmking.gateway.clientHttp;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.UnsupportedEncodingException;
+import java.net.URI;
+
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.DefaultHttpClient;
+
+public class HttpClientTest2 {
+	public static void main(String[] args) throws ClientProtocolException, IOException {
+		String url = "http://localhost:8801";
+		get(url);
+	}
+
+	public static String get(String url) throws ClientProtocolException, IOException {
+		long startTime=System.currentTimeMillis();
+
+        HttpClient httpClient = new DefaultHttpClient();
+        HttpGet httpGet = new HttpGet();
+        httpGet.setURI(URI.create(url));
+        HttpResponse response = httpClient.execute(httpGet);
+        String httpEntityContent = getHttpEntityContent(response);
+        httpGet.abort();
+
+        long endTime=System.currentTimeMillis();
+		float excTime=(float)(endTime-startTime)/1000;
+		System.out.println("执行时间为："+excTime+"s");
+
+        return httpEntityContent;
+    }
+
+	private static String getHttpEntityContent(HttpResponse response) throws IOException, UnsupportedEncodingException {
+	        HttpEntity entity = response.getEntity();
+	        if (entity != null) {
+	            InputStream is = entity.getContent();
+	            BufferedReader br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
+	            String line = br.readLine();
+	            StringBuilder sb = new StringBuilder();
+	            while (line != null) {
+	                sb.append(line + "\n");
+	                line = br.readLine();
+	            }
+	            br.close();
+	            is.close();
+	            return sb.toString();
+	        }
+	        return "";
+	    }
+
+
+}