diff --git a/.idea/misc.xml b/.idea/misc.xml index c3f3b0a..fdc35ea 100644 --- a/.idea/misc.xml +++ b/.idea/misc.xml @@ -1,3 +1,4 @@ + @@ -7,7 +8,7 @@ - + \ No newline at end of file diff --git a/pom.xml b/pom.xml index 7e1cf4c..991eb7f 100644 --- a/pom.xml +++ b/pom.xml @@ -9,8 +9,8 @@ 1.0 - 17 - 17 + 21 + 21 UTF-8 @@ -18,7 +18,7 @@ io.netty netty-all - 4.1.86.Final + 4.1.101.Final @@ -30,7 +30,7 @@ org.projectlombok lombok - 1.18.28 + 1.18.30 @@ -48,7 +48,7 @@ cn.hutool hutool-all - 5.8.18 + 5.8.20 @@ -61,26 +61,30 @@ - org.apache.maven.plugins - maven-assembly-plugin - 3.4.2 + org.graalvm.buildtools + native-maven-plugin + 0.9.28 - package + native - single + compile-no-fork + package - - jar-with-dependencies - - - - lion.Main - - + lion.Main + storageNode + false + true + true + + -H:+ReportExceptionStackTraces + + + true + diff --git a/src/main/java/lion/Main.java b/src/main/java/lion/Main.java index da07d45..3d17736 100644 --- a/src/main/java/lion/Main.java +++ b/src/main/java/lion/Main.java @@ -1,17 +1,7 @@ package lion; -import lion.ErrorCode.ErrorCode; import lombok.extern.log4j.Log4j; -import java.io.IOException; -import java.net.InetSocketAddress; -import java.nio.ByteBuffer; -import java.nio.channels.FileChannel; -import java.nio.channels.SocketChannel; -import java.nio.file.Path; -import java.nio.file.StandardOpenOption; - - @Log4j public class Main { @@ -21,8 +11,4 @@ public class Main { new storageNode(); } - - - - } diff --git a/src/main/java/lion/Message/MessageCodec.java b/src/main/java/lion/Message/MessageCodec.java index 46d16cf..c9b947a 100644 --- a/src/main/java/lion/Message/MessageCodec.java +++ b/src/main/java/lion/Message/MessageCodec.java @@ -32,7 +32,6 @@ public class MessageCodec extends ByteToMessageCodec { protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List list) throws Exception { byte messageType = byteBuf.readByte(); int length = byteBuf.readInt(); - System.out.println(length); byte[] bytes = new byte[length]; byteBuf.readBytes(bytes); final String metadata = new String(bytes, StandardCharsets.UTF_8); diff --git a/src/main/java/lion/MultiThreadedHTTPServer.java b/src/main/java/lion/MultiThreadedHTTPServer.java index a53711e..9c7d7d4 100644 --- a/src/main/java/lion/MultiThreadedHTTPServer.java +++ b/src/main/java/lion/MultiThreadedHTTPServer.java @@ -18,8 +18,7 @@ public class MultiThreadedHTTPServer { String real_ip; try{ real_ip = InetAddress.getByName("lionwebsite.xyz").getHostAddress(); - } - catch (UnknownHostException ignored){ + } catch (UnknownHostException ignored){ real_ip = "207.60.50.74"; } try(ServerSocket serverSocket = new ServerSocket(PORT)) { diff --git a/src/main/java/lion/storageNode.java b/src/main/java/lion/storageNode.java index 50817ae..1d02af4 100644 --- a/src/main/java/lion/storageNode.java +++ b/src/main/java/lion/storageNode.java @@ -59,10 +59,8 @@ public class storageNode { channel.pipeline().addLast(new LengthFieldBasedFrameDecoder(100000000, 1, 4)); channel.pipeline().addLast(new MessageCodec()); channel.pipeline().addLast(new MyChannelInboundHandlerAdapter(tempQueue)); - } - }).option(ChannelOption.SO_BACKLOG, 128) - .childOption(ChannelOption.SO_KEEPALIVE, true) + }) .bind(26321); log.info("listen port:8080");