clientthread.java~1~

1． 消息即时通信 2． 消息发送实现一对一、一对多等多种发送模式 3． 发送的消息实现多彩文本编辑

import java.net.*;
import java.io.*;
import javax.swing.text.BadLocationException;
public class ClientThread extends Thread {
  static DataOutputStream out;
  DataInputStream in;
  Socket socket=null;
  String message=null;
  public ClientThread(Socket socket,DataOutputStream out,DataInputStream in){
    this.socket=socket;
    this.out=out;
    this.in=in;
  }
  public void run(){
    while(true){
      try{
        message=in.readUTF();
        if(message.startsWith("PRIVATEMESSAGE")){
          try{
            ChatArea.privateChatDocument.insertString(ChatArea.
                privateChatDocument.getLength(), message, ChatArea.char_style);
          }catch(BadLocationException e){

          }

        }
        else if(message.startsWith("PUBLICMESSAGE:")){

        }
        else if(message.startsWith("LOGIN_PEOPLE")){

        }
        else if(message.startsWith("SENGD_FILE:")){

        }
        else if(message.startsWith("AGREE_ACCEPT:")){

        }
        else if(message.startsWith("DISAGREE_ACCEPT:")){

        }
        else if(message.startsWith("PEOPLE_LEAVE:")){

        }
      }catch(IOException e){
        e.printStackTrace();
      }
    }
  }

}