chatsocket.java

Java实例入门

package simplechatserver;

import java.net.*;
import java.io.*;
import javax.swing.text.*;

/**
 * Title:        网络聊天程序的服务器端
 * Description:
 * Copyright:    Copyright (c) 2001
 * Company:
 * @author
 * @version 1.0
 */

public class ChatSocket {
  public String Name="chatScoket";
  private String remoteAddr;
  private int remotePort;
  private JTextComponent outText;
  private Socket socket;
  private Sender sender;
  private ReceiveThread receiver;
  private servThread parent=null;
  public ChatSocket(String hostAddr,int port) {
     remoteAddr=hostAddr;
     remotePort=port;
  }
  public ChatSocket(String strName,Socket newSocket) {
     socket=newSocket;
     Name=strName;
     remoteAddr=socket.getInetAddress().toString();
     remotePort=socket.getPort();
  }
  public void setOutTextComponent(JTextComponent component){
     outText=component;
  }
  public void setName(String newName){
     Name=newName;
  }
  public String getName(){
     return Name;
  }
  public void setParent(servThread serverThread){
     parent=serverThread;
  }
  public boolean connect(){
    try{
        if(socket==null)
            socket=new Socket(remoteAddr,remotePort);
         socket.setSoTimeout(0);
         sender=new Sender(socket.getOutputStream());
         receiver=new ReceiveThread(Name,socket.getInputStream(),outText);
         receiver.setParent(this);
         receiver.start();
    }
    catch(Exception e){

    }
    return true;
  }
  public void disConnect(){
     send("BYE");
     close();
  }
  public void close(){
    try{
        sender=null;
        receiver=null;
        socket.close();
        if(parent!=null) parent.removeChat(this);
    }catch(Exception e){
        System.out.println(e);
    }
  }
  public boolean send(String msg){
    return(sender.send(msg));
  }
}