client.java

java编写的聊天室程序

import java.net.*;
import java.io.*;

class Client extends Thread                   //客户机的接受线程
{BufferedReader inStream1;
 Socket clientSocket1;
 static PrintStream outStream1;
 
 
	Client(String address,QQer qqer)throws Exception
	{try
        {clientSocket1=new Socket(address,8888);         //创建客户机
        
         InputStream inStr=clientSocket1.getInputStream();
   	     InputStreamReader inReader=new InputStreamReader(inStr);
	     inStream1=new BufferedReader(inReader);
        
         OutputStream outStr=clientSocket1.getOutputStream();
         ObjectOutputStream outObject=new ObjectOutputStream(outStr);
         outObject.writeObject(qqer);                      //发送一个对象给服务器
         
         outStream1=new PrintStream(outStr);
                        
         }
      catch(IOException e)
        {System.out.println("与服务器连接失败!"+e);
         throw new Exception();
        }
      System.out.println("已与服务器建立连接!");
		
	  this.start();
	 }
	 
	 
	 
	 
	 
	public void run()
	{while(true)
	     {try
	        {String str1=inStream1.readLine();
	         	        
	         if(str1.compareTo("setListDate")==0)
	           {try
	              {int length=Integer.parseInt(inStream1.readLine());
	               String[]listDate=new String[length];
	               
	               for(int i=0;i<length;i++)
	                  {listDate[i]=inStream1.readLine();
	                  // System.out.println(listDate[i]);
	                  }
	                 
	               MyQQ.setList(listDate);         //设置LIST的数组
	 
	              }
                catch(Exception e)
                  {System.out.println("listDate接收异常!"+e);
                  }	            
	           }
	         else
	           MyQQ.appendText(str1);             //写进编辑框   
	       
	         }
	      catch(IOException e)
	        {System.out.println("与服务器失去连接 "+e);
	         return;
	        }
	     }
	}
	
	
	
	
	public static void sendMessage(String message)
	{outStream1.println(message);
	}
	
}