Se añade loop while para mantenerse escuchando al servidor

Author: begandroide

KnockSockets/KnockKnockClient.java

@@ -26,21 +26,32 @@ public static void main(String[] args) throws IOException {
             String fromUser;
             String fromServer = "";
 
-            byte[] messageByte = new byte[10000];
-
-            while (in.available()>0) {
-                int bytesRead = in.read(messageByte);
-                fromServer += new String(messageByte, 0, bytesRead);
-                
-                System.out.println(fromServer);
-                fromServer = "";
-                
-                fromUser = stdIn.readLine();
-                if (fromUser != null) {
-                    // enviamos al server peticion del usuario
-                    out.println(fromUser);
-                }
+            byte[] messageByte = new byte[1000];
+
+            Boolean brokePipe = false;
+            while(!brokePipe){
+
+                    while (in.available() > 0) {
+                        System.out.println("Nuevo mensaje disponible");
+                        int bytesRead = in.read(messageByte);
+                        fromServer += new String(messageByte, 0, bytesRead);
+                        System.out.println(fromServer);
+                        fromServer = "";
+                        
+                        fromUser = stdIn.readLine();
+                        if(fromUser.equals( "5")){
+                                brokePipe = true;
+                                break;
+                        } 
+                        if (fromUser != null) {
+                                System.out.println("Se ha enviado petición: "+ fromUser + " al servidor");
+                                // enviamos al server peticion del usuario
+                                out.println(fromUser);
+                                out.flush();
+                        }
+                    }
             }
+            System.out.println("Chao compare!");
         } catch (UnknownHostException e) {
             System.err.println("Don't know about host " + hostName);
             System.exit(1);

KnockSockets/KnockKnockServer.java

@@ -28,15 +28,17 @@ public static void main(String[] args) throws IOException {
             KnockKnockProtocol kkp = new KnockKnockProtocol();
             outputLine = kkp.processInput(null);
             out.println(outputLine);
-            // out.flush();
+            out.flush();
             outputLine = "";
 
             while ((inputLine = in.readLine()) != null) {
+                System.out.println("Ha llegado: "+ inputLine + " desde el cliente");
                 outputLine = kkp.processInput(inputLine);
-                System.out.println(outputLine);
+                System.out.println("Petición procesada -> :" + outputLine);
                 out.println(outputLine);
-                if (outputLine.equals("Bye ma' friend!"))
-                    break;
+                System.out.println("Respuesta enviada -> :" + outputLine);
+                // if (outputLine.equals("Bye ma' friend!"))
+                //     break;
             }
         } catch (IOException e) {
             System.out.println("Exception caught when trying to listen on port "

KnockSockets/Makefile

@@ -1,8 +1,10 @@
-javac ./*.java
+
+all:
+	javac ./*.java
 
 clean:
 	rm ./*.class
 
 run:
 	java EchoServer 7 &
-	java EchoClient localhost 7
+	java EchoClient localhost 7