From 88c12994b47e4ad84c89fd5cdd4225c4bca5f756 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=A8=8B=E7=A8=8B?= <chengcheng8536@gmail.com>
Date: Sun, 11 Jul 2021 23:31:06 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AC=AC=E4=B8=89=E5=91=A8=E4=BD=9C=E4=B8=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 02nio/nio02/pom.xml                           | 28 ++++++-
 .../gateway/filter/ProxyRequestFilter.java    | 30 +++++++
 .../okhttp/OkhttpOutboundHandler.java         | 80 +++++++++++++++++++
 3 files changed, 137 insertions(+), 1 deletion(-)
 create mode 100644 02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/ProxyRequestFilter.java

diff --git a/02nio/nio02/pom.xml b/02nio/nio02/pom.xml
index 005de90a..09898c6f 100644
--- a/02nio/nio02/pom.xml
+++ b/02nio/nio02/pom.xml
@@ -57,7 +57,33 @@
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
         </dependency>
-    
+
+
+        <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpcore -->
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpcore</artifactId>
+            <version>4.4.10</version>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5.6</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>3.3.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>5.7.3</version>
+        </dependency>
         <!--
         <dependency>
             <groupId>org.springframework.boot</groupId>
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/ProxyRequestFilter.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/ProxyRequestFilter.java
new file mode 100644
index 00000000..60974c73
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/ProxyRequestFilter.java
@@ -0,0 +1,30 @@
+package io.github.kimmking.gateway.filter;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.FullHttpRequest;
+
+/**
+ * @author yangcheng
+ * @version 1.0
+ * @date 2021-07-11 23:21
+ * @description
+ */
+public class ProxyRequestFilter  implements HttpRequestFilter  {
+    @Override
+    public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
+        //获取url
+        String uri = fullRequest.uri();
+        System.out.println("当前请求的"+uri);
+        //设置过滤规则
+        //例如 只有anxing 开头的请求才能通过
+        if(!uri.startsWith("anxing")){
+            throw new RuntimeException("不支持的请求，请重试");
+        }else{
+            //解析请求并调用
+            //之前做过一次通过反射调用指定的类
+            //纯路由功能可以调用okhttp或者httpclient来远程调用请求
+        }
+
+
+    }
+}
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
index 5f194588..76b41468 100644
--- 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
@@ -1,4 +1,84 @@
 package io.github.kimmking.gateway.outbound.okhttp;
 
+import cn.hutool.json.JSONUtil;
+import okhttp3.*;
+
+import java.io.IOException;
+
 public class OkhttpOutboundHandler {
+    private OkHttpClient okHttpClient = new OkHttpClient();
+
+    public String base_url = "http://localhost:8801";
+
+    /**
+     * get 请求，常用于获取请求
+     *
+     * @param api
+     */
+    public void testGet(String api) throws IOException {
+        Request request = new Request.Builder()
+                .url(base_url + api)
+                .get()
+                .build();
+        Call call = okHttpClient.newCall(request);
+        Response response = call.execute();
+        System.out.println(response.body().toString());
+
+    }
+
+    /**
+     * put 请求,常用于更新请求
+     *
+     * @param api
+     */
+    public void testPut(String api) throws IOException {
+        TestModel testModel = new TestModel();
+        RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"),
+                JSONUtil.toJsonStr(testModel));
+        Request request = new Request.Builder()
+                .url(base_url + api)
+                .put(requestBody)
+                .build();
+        Call call = okHttpClient.newCall(request);
+        Response response = call.execute();
+        System.out.println(response.body().toString());
+    }
+
+    /**
+     * POST 请求,常用于新增或复杂的获取请求
+     *
+     * @param api
+     */
+    public void testPost(String api) throws IOException {
+        TestModel testModel = new TestModel();
+        RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"),
+                JSONUtil.toJsonStr(testModel));
+        Request request = new Request.Builder()
+                .url(base_url + api)
+                .post(requestBody)
+                .build();
+        Call call = okHttpClient.newCall(request);
+        Response response = call.execute();
+        System.out.println(response.body().toString());
+    }
+
+    /**
+     * DELETE 请求,常用于删除请求
+     *
+     * @param api
+     */
+    public void testDelete(String api) throws IOException {
+        Request request = new Request.Builder()
+                .url(base_url + api)
+                .delete()
+                .build();
+        Call call = okHttpClient.newCall(request);
+        Response response = call.execute();
+        System.out.println(response.body().toString());
+    }
+
+    private class TestModel {
+        private Integer testVo;
+    }
+
 }