Initial commit Eclipse

Author: Ciphermoth

mstoverlay/Registry.java

@@ -0,0 +1,67 @@
+package cs455.mstoverlay;
+
+import java.io.*;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class Registry {
+    private ServerSocket goodListener;
+
+    public Registry(int port) throws IOException {
+        goodListener = new ServerSocket(port);
+        System.out.println("YAY connection");
+        initiateConnectionAndMaxConnectionTime();
+    }
+
+    /**
+     * Accepts up to 15 client connections, sends a welcome message,
+     * and enforces a maximum connection time before closing.
+     */
+    private void initiateConnectionAndMaxConnectionTime() throws IOException {
+        // Accept up to 15 client connections
+        for (int i = 0; i < 15; i++) {
+            Socket clientSocket = goodListener.accept();
+            System.out.println("Accepted connection #" + (i + 1) + " from " + clientSocket.getInetAddress());
+
+            // Send a welcome message to the client
+            PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
+            out.println("Hello!" + (i + 1));
+
+            // Track when this connection started
+            long connectionStart = System.currentTimeMillis();
+            long maxDuration = 90 * 1000; // 90 seconds in milliseconds 
+
+            // Read messages until timeout or disconnect
+            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
+            String clientMessage;
+            while ((clientMessage = in.readLine()) != null) {
+                System.out.println("Client #" + (i + 1) + " said: " + clientMessage);
+
+                // Check elapsed time
+                long elapsed = System.currentTimeMillis() - connectionStart;
+                if (elapsed > maxDuration) {
+                    System.out.println("Closing connection for Client #" + (i + 1) + " after 30 seconds.");
+                    break;
+                }
+            }
+
+            // Close the connection
+            clientSocket.close();
+        }
+
+        System.out.println("Reached max of 15 connections. Closing server...");
+        goodListener.close();
+    }
+
+    public static void main(String[] args) {
+        try {
+            new Registry(5008);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}
+
+
+
+

mstoverlay/TestServerClient.java

@@ -0,0 +1,37 @@
+package cs455.mstoverlay;
+
+
+
+	import java.io.*;
+	import java.net.Socket;
+
+	public class TestServerClient {
+	    public static void main(String[] args) {
+	        String host = "localhost"; // or your server's IP
+	        int port = 5008;           
+
+	        try (
+	            Socket socket = new Socket(host, port);
+	            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
+	            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))
+	        ) {
+	            System.out.println("Connected to Registry at " + host + ":" + port);
+
+	            // message to the server
+	            out.println("Hello TestServerClient!");
+
+	            // reply from the server
+	            String response = in.readLine();
+	            if (response != null) {
+	                System.out.println("Server replied: " + response);
+	            } else {
+	                System.out.println("No reply from server.");
+	            }
+
+	        } catch (IOException e) {
+	            e.printStackTrace();
+	        }
+	    }
+	}
+
+