diff --git a/assignments/src/MV3500Cohort2022MayJune/homework2/Duran/DuranTcpExample3Client.java b/assignments/src/MV3500Cohort2022MayJune/homework2/Duran/DuranTcpExample3Client.java index a6acefb9a2bc0987c1b3f2935dd82584c31bc2d7..fb243cf8fb18882e735cdb5ffda16c542b131c87 100644 --- a/assignments/src/MV3500Cohort2022MayJune/homework2/Duran/DuranTcpExample3Client.java +++ b/assignments/src/MV3500Cohort2022MayJune/homework2/Duran/DuranTcpExample3Client.java @@ -1,22 +1,12 @@ package MV3500Cohort2022MayJune.homework2.Duran; -import MV3500Cohort2021JulySeptember.homework2.Domonique.*; import java.io.*; import java.net.*; public class DuranTcpExample3Client { - /** IPv6 String constant for localhost address, similarly IPv4 127.0.0.1 - * @see <a href="https://en.wikipedia.org/wiki/localhost">https://en.wikipedia.org/wiki/localhost</a> - * @see <a href="https://en.wikipedia.org/wiki/IPv6_address">https://en.wikipedia.org/wiki/IPv6_address</a> - */ - public final static String LOCALHOST = "0:0:0:0:0:0:0:1"; + public final static String LOCALHOST = "127.0.0.1"; - /** - * Program invocation, execution starts here - * @param args command-line arguments - * @throws java.lang.InterruptedException user can cancel execution - */ public static void main(String[] args) throws InterruptedException { // Local variables/fields @@ -26,58 +16,53 @@ public class DuranTcpExample3Client { BufferedReader br; String serverMessage; int clientLoopCount = 0; + int times = 0; try { - while (true) + while (times < 5) { - clientLoopCount++; // increment at beginning of loop for reliability + clientLoopCount++; System.out.println(DuranTcpExample3Client.class.getName() + " creating socket..."); - // We request an IP to connect to ("localhost") and - // port number at that IP (2317). This establishes - // a connection to that IP in the form of a Socket - // object; the server uses a ServerSocket to wait for - // connections. - socket = new Socket(LOCALHOST, 2317); // locohost? + + socket = new Socket(LOCALHOST, 1414); - // Now hook everything up (i.e. set up the streams), Java style: + is = socket.getInputStream(); isr = new InputStreamReader(is); br = new BufferedReader(isr); - // Read a single line written by the server. We'd - // do things a bit differently if there were many lines to be read - // from the server instead of one only. + serverMessage = br.readLine(); System.out.println("=================================================="); -// System.out.print ("Client loop " + clientLoopCount + ": "); - System.out.println("I am hungry"); +// System.out.println("The message the server sent was: '" + serverMessage + "'"); - // socket gets closed, either automatically/silently by this code (or possibly by the server) - Thread.sleep(500l); // slow things down, for example 500l (long) = 500 msec (1/2 second) - } // end while(true) // infinite loops are dangerous, be sure to kill this process! + Thread.sleep(10000); + times++; + + } } catch (IOException e) { System.err.println("Problem with " + DuranTcpExample3Client.class.getName() + " networking:"); // describe what is happening System.err.println("Error: " + e); - // Provide more helpful information to user if exception occurs due to running twice at one time + if (e instanceof java.net.BindException) { System.err.println("*** Be sure to stop any other running instances of programs using this port!"); } } - finally // occurs after any other activity when shutting down + finally { try { if (socket != null) socket.close(); } catch (IOException e) {} - // program exit: tell somebody about that happening. Likely cause: server drops connection. + System.out.println(); System.out.println(DuranTcpExample3Client.class.getName() + " exit"); } diff --git a/assignments/src/MV3500Cohort2022MayJune/homework2/Duran/DuranTcpExampleServer.java b/assignments/src/MV3500Cohort2022MayJune/homework2/Duran/DuranTcpExampleServer.java index 1120aac11e135f405740aab101753a8d2cec0897..3c11b3db8126a55eccc6bf26fff07008ded49597 100644 --- a/assignments/src/MV3500Cohort2022MayJune/homework2/Duran/DuranTcpExampleServer.java +++ b/assignments/src/MV3500Cohort2022MayJune/homework2/Duran/DuranTcpExampleServer.java @@ -7,44 +7,31 @@ import java.net.*; public class DuranTcpExampleServer { - /** - * Program invocation, execution starts here - * If already compiled, can run using console in directory ../../build/classes/ by invoking \ - * java -classpath . TcpExamples.TcpExample3Server - * @param args command-line arguments - */ public static void main(String[] args) { try { + + System.out.println(DuranTcpExampleServer.class.getName() + " has started..."); - // ServerSocket waits for a connection from a client. - // Notice that it is outside the loop; ServerSocket - // needs to be made only once. - System.out.println(DuranTcpExampleServer.class.getName() + " has started..."); // it helps debugging to put this on console first - - ServerSocket serverSocket = new ServerSocket(2317); + ServerSocket serverSocket = new ServerSocket(1414); OutputStream os; PrintStream ps; InetAddress localAddress, remoteAddress; int localPort, remotePort; int serverLoopCount = 0; - // Server is up and waiting (i.e. "blocked" or paused) - // Loop, infinitely, waiting for client connections. - // Stop the program somewhere else. while (true) { - // block until connected to a client + try (Socket clientConnectionSocket = serverSocket.accept()) { - serverLoopCount++; // increment at beginning of loop for reliability + serverLoopCount++; - // Now hook everything up (i.e. set up the streams), Java style: + os = clientConnectionSocket.getOutputStream(); ps = new PrintStream(os); ps.println("now " + serverLoopCount + " i am connected"); // this gets sent back to client! - // Print some information locally about the Socket connection. - // This includes the port and IP numbers on both sides (the socket pair). + localAddress = clientConnectionSocket.getLocalAddress(); remoteAddress = clientConnectionSocket.getInetAddress(); localPort = clientConnectionSocket.getLocalPort(); @@ -52,11 +39,7 @@ public class DuranTcpExampleServer { System.out.print ("Server loop " + serverLoopCount + ": "); - // My socket pair connection looks like this, to localhost: - // Socket pair: (( /0:0:0:0:0:0:0:1, 2317 ), ( /0:0:0:0:0:0:0:1, 54876 )) - // Socket pair: (( /0:0:0:0:0:0:0:1, 2317 ), ( /0:0:0:0:0:0:0:1, 54881 )) - // Why is the first IP/port the same, while the second set has different ports? System.out.println(DuranTcpExampleServer.class.getName() + " socket pair showing host name, address, port:"); System.out.println(" (( " + localAddress.getHostName() + "=" + localAddress.getHostAddress() + ", " + localPort + " ), ( " + @@ -66,18 +49,14 @@ public class DuranTcpExampleServer { remoteAddress.getHostName().equals(remoteAddress.getHostAddress())) System.out.println(" note HostName matches address if host has no DNS name"); - // Notice the use of flush() and try w/ resources. Without - // the try w/ resources the Socket object may stay open for - // a while after the client has stopped needing this - // connection. try w/ resources explicitly ends the connection. + ps.flush(); - // like it or not, you're outta here! + } } } catch (IOException e) { System.err.println("Problem with " + DuranTcpExampleServer.class.getName() + " networking: " + e); - // Provide more helpful information to user if exception occurs due to running twice at one time if (e instanceof java.net.BindException) { System.err.println("*** Be sure to stop any other running instances of programs using this port!"); }