chatclient.java

本程序是用JAVA写的

import java.io.*;
import java.net.*;
public class chatClient
{
	public static void main(String[] str)
	{
		String serverName="";
		
		Socket cltSoc;
		ObjectOutputStream objOut=null;
		ObjectInputStream  objIn=null;
		try{
	        InetAddress address=InetAddress.getByName(serverName);
			cltSoc=new Socket(address,6666);
			objOut=new ObjectOutputStream(cltSoc.getOutputStream());
			objIn=new ObjectInputStream(cltSoc.getInputStream());
			System.out.println("Connected to the server successfully...");
			System.out.println("If you want to exit this program,type QUIT!");
			} 
		   catch(Exception e){System.exit(0);}
		   getMsg get=new getMsg(objIn);
		   get.start();
		   sendMsg send =new sendMsg(objOut);
		   send.start();
		   }
		   
}
class getMsg extends Thread
{
ObjectInputStream objIn;
public getMsg(ObjectInputStream in)
{
objIn=in;
}
public void run()
{
    String strMsg="";
    while(true)
    {
      try{
         strMsg=(String)objIn.readObject();
         System.out.println("The server said:"+strMsg);
         if(strMsg.equals("QUIT"))System.exit(0);
        }
      catch(Exception e){}
}
}
}
class sendMsg extends Thread
{
     ObjectOutputStream objOut;
     public sendMsg(ObjectOutputStream out)
     {
       objOut=out;
    }
     public void run()
     {
       String strMsg="";
       while(true)
       {
         try{
              strMsg=(new BufferedReader(new
              InputStreamReader(System.in))).readLine();
              objOut.writeObject(strMsg);
              if(strMsg.equals("QUIT"))System.exit(0);
          }
         catch(Exception e){}//System.out.println(strMsg);
      }
}
}