receivethread.java

Java实例入门

package simplechatclient;
import java.io.*;
import javax.swing.text.*;
/**
 * Title:        聊天小程序
 * Description:  这是一个使用SOCKET制作的网络聊天程序
 * Copyright:    Copyright (c) 2001
 * Company:
 * @author
 * @version 1.0
 */

public class ReceiveThread extends Thread {
  private String strName;
  private DataInputStream inputStream;
  private JTextComponent textOutput;
  private ChatSocket parent=null;
  public ReceiveThread(String name,InputStream in,JTextComponent component) {
     strName=name;
     inputStream=new DataInputStream(in);
     textOutput=component;
  }
  public void run(){
     try{
          String strInput="";
          while(!strInput.equals("BYE") ){
             try{
                  strInput=inputStream.readLine();
              }catch(java.io.InterruptedIOException ex){
                 Thread.sleep(50);
              }
             if(strInput.length() >0){
                synchronized(this){
                     textOutput.setText(textOutput.getText()
                                        +strName+" 接收: "
                                        +strInput+"\n" );
                 }
              }
          }
          if(parent!=null) parent.close();
         return;
     }catch(Exception e){
         return;
     }
  }
  public void setParent(ChatSocket chatSocket){
    parent=chatSocket;
  }
}