class Serwer extends Thread {
    protected int port;
    static Vector<ServerThread> klienci;
    public Serwer(int port) {
        this.port = port;
    }
    public void rozeslij(String wiadomosc, Socket omin){
        for(int i = 0; i<klienci.size();i++){
            if(klienci.get(i).channel==omin)
                continue;

        klienci.get(i).wyslij(wiadomosc);
        }
    }
    @Override public void run() {
        ServerSocket serwer = null;
        try {
            serwer = new ServerSocket(port);
        } catch (IOException e) {}

        ServerThread t;
        while(true) {
            try {
                Socket channel = serwer.accept();
                t = new ServerThread(channel);
                klienci.add(t);
                t.start();
            } catch (IOException e) {}
        }
    }


}
class ServerThread extends Thread {
    protected Socket channel;
    protected PrintWriter out;
    public BufferedReader in = null;


    public ServerThread(Socket s) {
        channel = s;
        try {
            in = new BufferedReader(new InputStreamReader(s.getInputStream()));
            out = new PrintWriter(s.getOutputStream(), true);
        } catch (Exception e) {}
    }

    public void wyslij(String wiadomosc) {
        try {
            wiadomosc=wiadomosc+"\n";
            out.print(wiadomosc);
            out.flush();

            } catch (Exception e) {}
    }

    public String odbierz() {
        String wiadomosc="";
        try {
                wiadomosc = in.readLine();

        } catch (Exception e) {}

        return wiadomosc;
    }
    protected void rozlacz() {
        try {
            channel.close();
        } catch(Exception ex) {}
    }




    @Override public void run() {
        String wiadomosc;
        while (channel.isConnected()) {
            wiadomosc = odbierz();
            System.out.print(wiadomosc);
                if (wiadomosc!="") {
                    wyslij(wiadomosc);
                        wiadomosc="";
                }
        }
    }
}


public class SerwerTest{
public static void main(String[] args){
    Serwer serwer = new Serwer(8000);
    serwer.start();
}
}