public class Klijent extends Thread{

    public int ID;
    private Thread t;
    Socket klijent;
    InputStream in;
    OutputStream ou;
    Posluzitelj server;
    public Klijent(Posluzitelj srv) {
        ID = (int) (Math.random() * 50 + 1);
        server = srv;
        try {
            klijent = new Socket("127.1.1.1", 7777);
            System.out.println("KLIJENT (ID:" + ID + "): " + klijent);
            in = klijent.getInputStream();
            ou = klijent.getOutputStream();
        } catch (IOException greska) {
            System.err.println("Greska");
        }
    }
    public void run(){
        synchronized(server){
            server.cekanjeKlijenta();
            System.out.println("Cekanje na pozevivanje klijenta.");
        }
    }
    public void start(){
        System.out.println("Pozevivanje klijenta.");
         if (t == null) {
         t = new Thread (this);
         t.start ();
      }
    }
    public void chat() {
        BufferedReader bis = new BufferedReader(new InputStreamReader(in));
        PrintWriter ps = new PrintWriter(new PrintStream(ou), true);

        Scanner sc = new Scanner(System.in);
        ps.write(ID);
        String linija = null;
        while ((linija = sc.next()) != null) {
            ps.println(linija);
        }
    }
}