add file store

Author: kimmking

02nio/nio02/pom.xml

@@ -29,7 +29,7 @@
         <dependency>
             <groupId>io.netty</groupId>
             <artifactId>netty-all</artifactId>
-            <version>4.1.45.Final</version>
+            <version>4.1.104.Final</version>
         </dependency>
 
         <dependency>

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

@@ -2,7 +2,10 @@
 
 
 import io.github.kimmking.gateway.inbound.HttpInboundServer;
+import io.netty.util.internal.PlatformDependent;
 
+import java.lang.reflect.Constructor;
+import java.nio.ByteBuffer;
 import java.util.Arrays;
 
 public class NettyServerApplication {
@@ -12,6 +15,13 @@ public class NettyServerApplication {
 
     public static void main(String[] args) {
 
+//        sun.misc.Unsafe unsafe = sun.misc.Unsafe.getUnsafe();
+//        System.out.println(unsafe.addressSize());
+
+
+        System.out.println("PlatformDependent.hasUnsafe = " + PlatformDependent.javaVersion());
+        System.out.println("PlatformDependent.hasUnsafe = " + PlatformDependent.hasUnsafe());
+
         String proxyPort = System.getProperty("proxyPort","8888");
 
         // 这是之前的单个后端url的例子

02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpResponseFilter.java

@@ -1,10 +1,24 @@
 package io.github.kimmking.gateway.filter;
 
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
 import io.netty.handler.codec.http.FullHttpResponse;
+import io.netty.handler.codec.http.HttpResponseStatus;
 
 public class HeaderHttpResponseFilter implements HttpResponseFilter {
     @Override
     public void filter(FullHttpResponse response) {
         response.headers().set("kk", "java-1-nio");
+        response.setStatus(HttpResponseStatus.CREATED);
+//        byte[] array = response.content().array();
+//        String content = new String(array);
+//        System.out.println(content);
+//        content = content + ",kimmking";
+        byte[] bytes = "hello,kimm.".getBytes();
+        //response.headers().setInt("Content-Length", bytes.length);
+        ByteBuf byteBuf = Unpooled.wrappedBuffer(bytes);
+        ByteBuf content = response.content();
+        content.clear();
+        content.writeBytes(byteBuf);
     }
 }

02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java

@@ -39,9 +39,14 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
 //            if (uri.contains("/test")) {
 //                handlerTest(fullRequest, ctx);
 //            }
-    
-            handler.handle(fullRequest, ctx, filter);
-    
+
+            String uri = fullRequest.getUri();
+            System.out.println("  uri ==>> " + uri);
+            if(uri.contains("/netty/info")) {
+                NettyInfoHandler.INSTANCE.handle(fullRequest, ctx);
+            } else {
+                handler.handle(fullRequest, ctx, filter);
+            }
         } catch(Exception e) {
             e.printStackTrace();
         } finally {

02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/NettyInfoHandler.java

@@ -0,0 +1,83 @@
+package io.github.kimmking.gateway.inbound;
+
+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.FullHttpResponse;
+import io.netty.handler.codec.http.HttpUtil;
+import io.netty.util.internal.PlatformDependent;
+import lombok.SneakyThrows;
+
+import java.lang.reflect.Field;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicLong;
+
+import static io.netty.handler.codec.http.HttpResponseStatus.OK;
+import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
+
+/**
+ * Description for this class.
+ *
+ * @Author : kimmking(kimmking@apache.org)
+ * @create 2024/5/31 下午7:13
+ */
+public class NettyInfoHandler {
+
+    public final static NettyInfoHandler INSTANCE = new NettyInfoHandler();
+
+    public void handle(final FullHttpRequest fullRequest, final ChannelHandlerContext ctx) {
+        System.out.println("NettyInfoHandler.handle...");
+        Map<String, String> infos = new HashMap<>();
+        infos.put("netty.usedDirectMemory", ""+getNettyUsedDirectMemory());
+        infos.put("netty.directMemoryLimit", ""+getNettyDirectMemoryLimit());
+        StringBuilder sb = new StringBuilder();
+        sb.append("{");
+        infos.forEach((k, v) -> {
+            sb.append("\"").append(k).append("\"")
+                    .append(":")
+                    .append("\"").append(v).append("\"").append(",");
+        });
+        if(sb.length()>1) {
+            sb.deleteCharAt(sb.length()-1);
+        }
+        sb.append("}");
+
+        byte[] body = ("{\"code\":200,\"msg\":\"success\",\"data\":" + sb +"}").getBytes();
+        FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(body));
+
+        response.headers().set("Content-Type", "application/json");
+        response.headers().setInt("Content-Length", body.length);
+        response.headers().set("kk.gw.hanlder", "netty.info");
+
+        if (fullRequest != null) {
+            if (!HttpUtil.isKeepAlive(fullRequest)) {
+                ctx.write(response).addListener(ChannelFutureListener.CLOSE);
+            } else {
+                //response.headers().set(CONNECTION, KEEP_ALIVE);
+                ctx.write(response);
+            }
+        }
+        ctx.flush();
+        //ctx.close();
+
+    }
+
+    @SneakyThrows
+    private static long getNettyUsedDirectMemory() {
+        Field field = PlatformDependent.class.getDeclaredField("DIRECT_MEMORY_COUNTER");
+        field.setAccessible(true);
+        AtomicLong o = (AtomicLong)field.get(null);
+        return o.get();
+    }
+
+    @SneakyThrows
+    private static long getNettyDirectMemoryLimit() {
+        Field field = PlatformDependent.class.getDeclaredField("DIRECT_MEMORY_LIMIT");
+        field.setAccessible(true);
+        return (Long)field.get(null);
+    }
+
+}