Migrate from standard socket to Netty for improved performance

pom.xml

@@ -58,6 +58,14 @@
         </dependency>
 
 
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.72.Final</version> <!-- Versiyon numarasını ihtiyacınıza göre güncelleyebilirsiniz -->
+        </dependency>
+
+
+
 
 
     </dependencies>

src/main/java/tech/bingulhan/webserver/app/AureliusApplication.java

@@ -3,7 +3,7 @@
 import lombok.Getter;
 import org.yaml.snakeyaml.Yaml;
 import tech.bingulhan.webserver.app.ui.ApplicationUI;
-import tech.bingulhan.webserver.server.HttpServer;
+import tech.bingulhan.webserver.server.HttpNettyServer;
 
 import java.io.File;
 import java.io.FileInputStream;
@@ -30,7 +30,7 @@ public class AureliusApplication {
 
     private static AureliusApplication instance;
 
-    private HttpServer server;
+    private HttpNettyServer server;
 
     public static synchronized AureliusApplication getInstance() {
         return instance;
@@ -118,10 +118,11 @@ public Map<String, Object> readYaml(String filePath) throws IOException {
     }
 
     public void start(String[] args) {
-
-        server = new HttpServer(this,port, args);
+        server= new HttpNettyServer(this, args);
         server.start();
     }
 
 
+
+
 }

src/main/java/tech/bingulhan/webserver/app/ui/ApplicationUI.java

@@ -76,7 +76,7 @@ public void start(Stage stage) throws Exception {
         Scene scene = new Scene(root, 600, 400);
 
         stage.setOnCloseRequest(event -> AureliusApplication.getInstance().stop());
-        stage.setTitle("Aurelius 0.4.6 - Server Status");
+        stage.setTitle("Aurelius 0.5 - Server Status");
         stage.setScene(scene);
         stage.setResizable(false);
 

src/main/java/tech/bingulhan/webserver/response/NettyResponseHandler.java

@@ -0,0 +1,23 @@
+package tech.bingulhan.webserver.response;
+
+public interface NettyResponseHandler {
+
+
+    void handleResponse(NettyResponseService service, RequestStructure structure);
+
+    static void handle(NettyResponseService service, RequestStructure structure) {
+        String[] paths = structure.getRoot().split("/");
+        if (paths.length>1) {
+            for (NettyResponseType type: NettyResponseType.values()) {
+                if (type.path.equals(paths[1])) {
+                    type.handler.handleResponse(service, structure);
+                    return;
+                }
+            }
+        }
+
+        NettyResponseType.PAGE.handler.handleResponse(service,structure);
+
+
+    }
+}

src/main/java/tech/bingulhan/webserver/response/NettyResponseService.java

@@ -0,0 +1,22 @@
+package tech.bingulhan.webserver.response;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.DefaultHttpRequest;
+import lombok.Getter;
+import tech.bingulhan.webserver.app.AureliusApplication;
+
+@Getter
+public class NettyResponseService {
+
+    private DefaultHttpRequest request;
+
+    private ChannelHandlerContext ctx;
+
+    private AureliusApplication application;
+
+    public NettyResponseService(AureliusApplication application, DefaultHttpRequest request, ChannelHandlerContext ctx) {
+        this.application = application;
+        this.request = request;
+        this.ctx = ctx;
+    }
+}

src/main/java/tech/bingulhan/webserver/response/NettyResponseType.java

@@ -0,0 +1,19 @@
+package tech.bingulhan.webserver.response;
+
+import tech.bingulhan.webserver.response.impl.media.NettyResponseMediaHandler;
+import tech.bingulhan.webserver.response.impl.mvc.NettyResponseMvcHandler;
+
+public enum NettyResponseType {
+
+    PAGE("", new NettyResponseMvcHandler()),
+    MEDIA("public", new NettyResponseMediaHandler());
+    ;
+    public String path;
+
+    public NettyResponseHandler handler;
+    NettyResponseType(String path, NettyResponseHandler handler) {
+        this.path = path;
+        this.handler = handler;
+    }
+
+}