ClientReceive.java import java.net.*; import java.io.*; public class ClientReceive extends Thread { Socket client; static String name; static ObjectOutputStream output; static ObjectInputStream input; public ClientReceive(Socket c,String n) { client=c; name=n; try { output=new ObjectOutputStream(c.getOutputStream()); output.flush(); input=new ObjectInputStream(c.getInputStream()); }catch(Exception ex) { ex.printStackTrace(); } } public static ObjectOutputStream getStream() { return output; } public void run() { String message=""; String tokens[]=null; do { try { message=(String)input.readObject(); tokens=message.split("#"); if(tokens[0].equals("From")|| tokens[0].equals("Server")) { message=removeHash(message); Client.setRecievedMessages(removeHash(message)); } else if(tokens[0].equals("Client")) Client.LoadList(message.substring(7,message.length())); else Client.setRecievedMessages(removeHash(message)); }catch(Exception ex) { ex.printStackTrace(); } }while(!message.equals("Server
Posted on: Thu, 11 Jul 2013 17:19:14 +0000
Trending Topics
Recently Viewed Topics
© 2015