public class Posluzitelj{
    ServerSocket server = null;
    String linija;
    BufferedReader is;
    PrintWriter os;
    Socket klijent = null;
    Posluzitelj(){
        try {
            server = new ServerSocket(1000, 2);
            System.out.println("Postavljeni posluzitelj: "+ server.toString());
        }
        catch(IOException greska){
            System.err.println("Greska");
            System.exit(1);
        }
    }
    public void cekanjeKlijenta(){
        try {
            klijent = server.accept();
            System.out.println("SERVER: Imamo klijenta" + klijent.getInetAddress());
            is = new BufferedReader(new InputStreamReader(klijent.getInputStream()));
            os = new PrintWriter(new OutputStreamWriter(klijent.getOutputStream()),true);
            boolean cenza;
            int ids = is.read();
            String cenzura[] = {"psovka1", "psovka2", "psovka3"};
            while ((linija = is.readLine()) != null) {
                cenza = false;
                for(int i=0;i<cenzura.length; ++i) {
                    if(linija.equals(cenzura[i])) {
                        System.out.print("(ID:" + ids + ") ");
                        for(int j = 0; j < cenzura[i].length(); j++) System.out.print("*");
                        System.out.print("\n");
                        cenza = true;
                    }
                }
                if(cenza == false) System.out.println("(ID:" + ids + ") " + linija);
            }
        }
        catch(IOException g) {
            System.err.println("Greska");
        }
    }
}