cs654/lab5: chat working

git-svn-id: svn://anubis/gvsu@15 45c1a28c-8058-47b2-ae61-ca45b979098e

cs654/lab5/partI/ChatClient.java

@@ -20,23 +20,18 @@ public class ChatClient {
       gui.input.addKeyListener(new EnterListener(this, gui));
       gui.addWindowListener(new ExitListener(this));
 	
-
-
-
-
-
-
       // create a socket, register and listen t the server
 
       try {
 
          socket = new Socket(server, port);
-?
+         in = new DataInputStream(socket.getInputStream());
-?
+         out = new DataOutputStream(socket.getOutputStream());
+
          out.writeUTF(name);
-         while (true) {
+         for (;;) {
             gui.output.append("\n" + in.readUTF());
-         };
+         }
       }	catch (Exception e)	{ 
          e.printStackTrace();
       }
@@ -45,7 +40,7 @@ public class ChatClient {
 
    protected void sendTextToChat(String str) {
       try {
-    ?
+          out.writeUTF(str);
       } catch (IOException e) {
          e.printStackTrace();
       }
@@ -53,7 +48,7 @@ public class ChatClient {
 
    protected void disconnect() {
       try {
-  ?
+          socket.close();
       } catch (IOException e) {
          e.printStackTrace();
       }

cs654/lab5/partI/ChatHandler.java

@@ -8,23 +8,23 @@ public class ChatHandler extends Thread {
    DataInputStream in; 
    DataOutputStream out;
    String name;
-   protected static Vector handlers = new Vector ();
+   protected static Vector<ChatHandler> handlers = new Vector<ChatHandler>();
     
    public ChatHandler (String name, Socket socket) throws IOException { 
       this.name = name;
       this.socket = socket; 
-      in = new DataInputStream (?);
+      in = new DataInputStream (socket.getInputStream());
-      out = new DataOutputStream (?);
+      out = new DataOutputStream (socket.getOutputStream());
    } 
     
    public void run () { 
 
       try { 
-         broadcast(name+" entered");
+         broadcast("** " + name + " entered chat **");
          handlers.addElement (this); 
 
          while (true) { 
-?
+             String message = in.readUTF();
              broadcast(name+": " + message); 
          } 
 
@@ -32,9 +32,9 @@ public class ChatHandler extends Thread {
          System.out.println("-- Connection to user lost.");
       } finally { 
          handlers.removeElement (this); 
-         ?
+         broadcast("** " + name + " left chat **");
          try { 
-            ?
+             socket.close();
          } catch (IOException ex) { 
             System.out.println("-- Socket to user already closed ?");
          }
@@ -44,12 +44,9 @@ public class ChatHandler extends Thread {
 
    protected static void broadcast (String message) { 
       synchronized (handlers) { 
-         Enumeration e = handlers.elements (); 
+         for (ChatHandler handler : handlers) {
-         while (e.?) { 
-            ChatHandler handler = (ChatHandler) e.nextElement (); 
             try { 
- ?
+                handler.out.writeUTF(message);
-               ?
             } catch (IOException ex) { 
                handler.stop (); 
             } 

cs654/lab5/partI/ChatServer.java

@@ -8,10 +8,10 @@ public class ChatServer {
       ServerSocket server = new ServerSocket (port); 
       while (true) { 
          Socket client = server.accept(); 
-         ?
+         DataInputStream in = new DataInputStream(client.getInputStream());
          String name = in.readUTF();
 
-         System.out.println ("New client "+name+" from " + ?);
+         System.out.println ("New client " + name + " from " + client.getInetAddress());
          ChatHandler c = new ChatHandler (name, client); 
          c.start (); 
       } 

cs654/lab5/partI/Makefile

@@ -0,0 +1,6 @@
+
+all:
+	javac -deprecation *.java
+
+clean:
+	-rm -f *.class *~