outputthread.java

用JAVA写的一个小型聊天室的客户端

/**
 * Email: [e-mail]
 *
 * @author taorundong
 * @version 1.00 07/02/06
 */
 
 import javax.swing.*;
 import java.net.*;
 import java.io.*;
 
 public class OutputThread extends Thread{
 	
 	private
 	DataInputStream input = null;
 	DataOutputStream output = null;
 	String message = null;
 	Socket own = null;
 	JTextArea chatingContent = null;
 	
 	OutputThread(JTextArea text){
 		
 		
 		try{//here connect to server
 			own = new Socket((InetAddress.getLocalHost()),6000);
 		}
 		catch(Exception e){
 			e.printStackTrace();
 			//here will show the state window when unconnect to server
 		}
 		
  		try{
 			input = new DataInputStream(own.getInputStream());
 			output = new DataOutputStream(own.getOutputStream());
 		}
 		catch(Exception e){
 			e.printStackTrace();
 		}
 		
 		chatingContent = text;
 		
 		init();
 		chat();
 	}
 	
 	
 	public void init(){
 		
 		if(own.isConnected()){
 			try{
 				output.writeUTF(NameRequest.getClientName());
 				message = input.readUTF();
 				//System.out.println(getMessage());
 				chatingContent.append(message+"\n");
 			}
 			catch(Exception e){
 				e.printStackTrace();
 				initError();
 			}
 			
 		}
 	}
 	
 	public void chat(){
 		
 		for(int i=0;i<5;i++){
 			try{
 				Thread.sleep(3000);
 				output.writeUTF("Hello");//To reposition to the messageBox
 				message = input.readUTF();
 				//System.out.println("send"+getMessage());
 				chatingContent.append(getMessage()+"\n");
 			}
 			catch(Exception e){
 				e.printStackTrace();
 				chatError();
 				this.destroy();
 			}
 		}
 		try{
 			own.close();
 		}
 		catch(Exception e){
 			e.printStackTrace();
 		}
 	}
 	
 	public DataOutputStream getOutput(){
 		return output;
 	}
 	
 	
 	public String getMessage(){
 		return message;
 	}
 	
 	public String initError(){//To show the chating information
 		return "Net init error!";
 	}
 	
 	public String chatError(){
 		return "Error when chating!";
 	}
 	
 }