connectpond.java

用hibernata连接数据库的java聊天室 有服务器端可踢人

package cr;

import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Vector;

public class ConnectPond {
    private Vector vecConnect;
    public ConnectPond() {
        vecConnect=new Vector();
    }

    public void add(Socket socConnect){
        vecConnect.add(socConnect);
    }

    public void remove(int intConnect){
        vecConnect.removeElementAt(intConnect);
    }

    public void remove(Socket socConnect){
        vecConnect.remove(socConnect);
    }

    public int indesOf(Socket socConnect){
        return vecConnect.indexOf(socConnect);
    }
    public void sendAll(String strMessage){
        PrintWriter writer=null;
        Socket sock;
        for (int i=0;i<vecConnect.size();i++){
            sock=(Socket)vecConnect.elementAt(i);
            try {
                writer = new PrintWriter(sock.getOutputStream(), true);
            }
            catch (IOException ex) {
                System.out.println("群发消息失败！");
            }
            if(writer!=null){writer.println(strMessage);}
        }
    }

    public void sendTo(int intObject,String strMessage){
        Socket socObject;
        PrintWriter pwrObject=null;

        socObject=(Socket)vecConnect.elementAt(intObject);
        try {
            pwrObject = new PrintWriter(socObject.getOutputStream(), true);
        } catch (IOException ex) {
            System.out.println("发送消息失败！");
        }
        if(pwrObject!=null){
            pwrObject.println(strMessage);
        }
    }
}