feat: add clients handler via thread

app/src/main/java/clientserver/server/ClientHandler.java

@@ -0,0 +1,74 @@
+package clientserver.server;
+
+import clientserver.client.Client;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+
+public class ClientHandler implements Runnable {
+
+    private final DatagramSocket socket;
+    private final Client client;
+    private boolean running = true;
+
+    public ClientHandler(DatagramSocket socket, Client client) {
+        this.socket = socket;
+        this.client = client;
+    }
+
+    public void stop() {
+        running = false;
+        if (socket != null && !socket.isClosed()) {
+            socket.close();
+        }
+    }
+
+    @Override
+    public void run() {
+        System.out.println(
+            "Started handler for client " +
+            client.getAddress() +
+            ":" +
+            client.getPort()
+        );
+
+        // try {
+        //     socket.setSoTimeout(30000);
+        // } catch (Exception e) {
+        //     System.err.println("Could not set socket timeout");
+        // }
+
+        while (running && !socket.isClosed()) {
+            DatagramPacket packet = Server.receivePacket(socket);
+            if (packet == null) continue;
+
+            String message = new String(
+                packet.getData(),
+                0,
+                packet.getLength()
+            );
+            System.out.println(
+                "Received from " +
+                client.getAddress() +
+                ":" +
+                client.getPort() +
+                ": " +
+                message
+            );
+            // Reply with echo
+            // String response = "ECHO: " + message;
+            // Server.sendMessage(
+            //     socket,
+            //     response,
+            //     client.getAddress(),
+            //     client.getPort()
+            // );
+        }
+
+        System.out.println(
+            "Client handler terminated for " +
+            client.getAddress() +
+            ":" +
+            client.getPort()
+        );
+    }
+}