添加filter

romanlu · romanlu · commit dcec3400adab · 2020-11-04T23:45:04.000+08:00
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HttpRequestFilterImpl.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HttpRequestFilterImpl.java
@@ -0,0 +1,21 @@
+package io.github.kimmking.gateway.filter;
+
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.FullHttpRequest;
+
+import java.nio.charset.Charset;
+
+/**
+ * @author romanlu
+ * @date 2020-11-04 23:41
+ * @Description:
+ */
+public class HttpRequestFilterImpl implements HttpRequestFilter {
+
+    @Override
+    public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
+        System.out.println("请求处理器1");
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer("hello word1" , Charset.forName("gb2312")));
+    }
+}
