22

Author: ahndmal

pom.xml

@@ -7,10 +7,10 @@
     <groupId>com.andmal</groupId>
     <artifactId>java-examples</artifactId>
 
-    <version>1.0.2</version>
+    <version>1.0.3</version>
 
     <properties>
-        <java.version>21</java.version>
+        <java.version>22</java.version>
         <junit.version>5.8.1</junit.version>
     </properties>
 

src/main/java/com/anma/java/core/net/socket/MultithreadedTCPServer.java

@@ -0,0 +1,49 @@
+package com.anma.java.core.net.socket;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.Socket;
+
+public class MultithreadedTCPServer extends TCPServerEx {
+    public void run(Socket data) {
+        try {
+            DataOutputStream dos =
+                    new DataOutputStream(data.getOutputStream());
+
+            dos.writeByte(TypeServerConstants.WELCOME);
+
+            DataInputStream dis =
+                    new DataInputStream(data.getInputStream());
+
+            while (true) {
+
+                byte b = dis.readByte();
+
+                if (b != TypeServerConstants.GET_STRING_REQUEST) {
+                    System.out.println("Client sent unknown request " + b);
+                    continue;
+                }
+
+                dos.writeByte(TypeServerConstants.GET_STRING_RESPONSE);
+                dos.writeUTF("Thisisateststring");
+                dos.flush();
+            }
+        } catch (Exception e) {
+            System.out.println("Client terminating: " + e);
+            return;
+        }
+    }
+
+    public static void main(String[] args) throws IOException {
+        TCPServerEx ts = new TCPServerEx();
+        ts.startServer(Integer.parseInt(args[0]));
+        System.out.println("Server ready and waiting...");
+    }
+}
+
+class TypeServerConstants {
+    public final static byte WELCOME = 0;
+    public final static byte GET_STRING_REQUEST = 1;
+    public final static byte GET_STRING_RESPONSE = 2;
+}

src/main/java/com/anma/java/core/net/socket/TCPServerEx.java

@@ -0,0 +1,52 @@
+package com.anma.java.core.net.socket;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class TCPServerEx implements Cloneable, Runnable {
+
+    Thread runner = null;
+    ServerSocket server = null;
+    Socket data = null;
+    private boolean done = false;
+
+    public synchronized void startServer(int port) throws IOException {
+        if (runner == null) {
+            server = new ServerSocket(port);
+            runner = new Thread(this);
+            runner.start();
+        }
+    }
+
+    public synchronized void stopServer() {
+        done = true;
+        runner.interrupt();
+    }
+
+    protected synchronized boolean getDone() {
+        return done;
+    }
+
+    public void run() {
+        if (server != null) {
+            while (!getDone()) {
+                try {
+                    Socket datasocket = server.accept();
+                    TCPServerEx newSocket = (TCPServerEx) clone();
+                    newSocket.server = null;
+                    newSocket.data = datasocket;
+                    newSocket.runner =
+                            new Thread(newSocket);
+                    newSocket.runner.start();
+                } catch (Exception e) {
+                }
+            }
+        } else {
+            run(data);
+        }
+    }
+
+    public void run(Socket data) {
+    }
+}