private static Kontroler instanca;
    DBBroker db;
    private Kontroler() {
        db=new DBBroker();
    }

    public static Kontroler getInstanca() {
        if(instanca==null)
            instanca=new Kontroler();
        return instanca;
    }
//****************************************************************************************************************************************
//DBBROKER
Connection konekcija;


    public void ucitajDrajver() {
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException ex) {
            Logger.getLogger(DBBroker.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
    public void otvoriKonekciju(){
        String url="jdbc:mysql://localhost:3306/prosoftjul16g1";
        String user="root";
        String pass="";

        try {
            konekcija=DriverManager.getConnection(url, user, pass);
            konekcija.setAutoCommit(false);
        } catch (SQLException ex) {
            Logger.getLogger(DBBroker.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public void zatvoriKonekciju() {
        try {
            konekcija.close();
        } catch (SQLException ex) {
            Logger.getLogger(DBBroker.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public void commit(){

        try {
            konekcija.commit();
        } catch (SQLException ex) {
            Logger.getLogger(DBBroker.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public void rollback(){

        try {
            konekcija.rollback();
        } catch (SQLException ex) {
            Logger.getLogger(DBBroker.class.getName()).log(Level.SEVERE, null, ex);
        }

    }
//**************************************************************************************************************************************
//OBRADJIVANJEKLIJENTSKIHZAHTEVA
Socket s;

    public ObradjivanjeKlijentskihZahteva(Socket s) {
        this.s = s;
    }

    @Override
    public void run() {
        while (true){
        KlijentskiZahtev kz=primiZahtev();

        ServerskiOdgovor so=new ServerskiOdgovor();

        switch(kz.getOperacija()){

        }



        posaljiOdgovor(so);
        }
        //super.run(); //To change body of generated methods, choose Tools | Templates.
    }

    private KlijentskiZahtev primiZahtev() {
        KlijentskiZahtev kz=new KlijentskiZahtev();

         try {
             ObjectInputStream ois=new ObjectInputStream(s.getInputStream());
             kz=(KlijentskiZahtev) ois.readObject();

//throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
         } catch (IOException ex) {
             Logger.getLogger(ObradjivanjeKlijentskihZahteva.class.getName()).log(Level.SEVERE, null, ex);
         } catch (ClassNotFoundException ex) {
             Logger.getLogger(ObradjivanjeKlijentskihZahteva.class.getName()).log(Level.SEVERE, null, ex);
         }

         return kz;
    }

    private void posaljiOdgovor(ServerskiOdgovor so) {
         try {
             ObjectOutputStream ous=new ObjectOutputStream(s.getOutputStream());
             ous.writeObject(so);
             System.out.println("SADA SMO U METODI POSALJIODGOVOR"+so.getOdgovor());
             // throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
         } catch (IOException ex) {
             Logger.getLogger(ObradjivanjeKlijentskihZahteva.class.getName()).log(Level.SEVERE, null, ex);
         }
    }



}
//POKRETANJESERVERA
    public PokretanjeServera() {
    }

    @Override
    public void run() {

        try {
            ServerSocket ss= new ServerSocket(9000);
            System.out.println("Server je pokrenut");

            while(true){
                Socket s=ss.accept();
                System.out.println("Klijent se povezao");
                ObradjivanjeKlijentskihZahteva o=new ObradjivanjeKlijentskihZahteva(s);
                o.start();
            }


        } catch (IOException ex) {
            Logger.getLogger(PokretanjeServera.class.getName()).log(Level.SEVERE, null, ex);
        }


        //super.run(); //To change body of generated methods, choose Tools | Templates.
    }


//**************************************************************************************************************************************
public class KomunikacijaSaServerom {
    Socket s;

    private static KomunikacijaSaServerom instanca;

    private KomunikacijaSaServerom() {
        try {
            s = new Socket("localhost", 9000);
            System.out.println("POVEZIVANJE USPESNO SA STRANE KLIJENTA");
        } catch (IOException ex) {
            Logger.getLogger(KomunikacijaSaServerom.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public static KomunikacijaSaServerom getInstanca() {
        if(instanca == null)
            instanca = new KomunikacijaSaServerom();
        return instanca;
    }

    public void posaljiZahtev(KlijentskiZahtev kz){
          try {
              ObjectOutputStream oos=new ObjectOutputStream(s.getOutputStream());
              oos.writeObject(kz);
              System.out.println("zahtev poslat od strane klijenta");
          } catch (IOException ex) {
              Logger.getLogger(KomunikacijaSaServerom.class.getName()).log(Level.SEVERE, null, ex);
          }

    }

    public ServerskiOdgovor primiOdgovor(){
        ServerskiOdgovor so=new ServerskiOdgovor();

          try {
              ObjectInputStream ois=new ObjectInputStream(s.getInputStream());
              so=(ServerskiOdgovor) ois.readObject();
          } catch (IOException ex) {
              Logger.getLogger(KomunikacijaSaServerom.class.getName()).log(Level.SEVERE, null, ex);
        return so;
             } catch (ClassNotFoundException ex) {
              Logger.getLogger(KomunikacijaSaServerom.class.getName()).log(Level.SEVERE, null, ex);
          }

          System.out.println("odgovor primljen od strane klijenta");
          return so;
    }


}
//**************************************KOMUNIKACIJA SA KLIJENTOM
    private static KomunikacijaSaKlijentom instanca;

    private KomunikacijaSaKlijentom() {
    }

    public static KomunikacijaSaKlijentom getInstanca() {
        if(instanca==null)
            instanca=new KomunikacijaSaKlijentom();
        return instanca;
    }

    public void posaljiOdgovor(ServerskiOdgovor so, Socket s){
          try {
            ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream());
            oos.writeObject(so);
        } catch (IOException ex) {
            Logger.getLogger(KomunikacijaSaKlijentom.class.getName()).log(Level.SEVERE, null, ex);
        }

    }

    public KlijentskiZahtev primiZahtev(Socket s) throws Exception{
        KlijentskiZahtev kz=new KlijentskiZahtev();


            ObjectInputStream ois=new ObjectInputStream(s.getInputStream());
            kz=(KlijentskiZahtev) ois.readObject();

        return kz;
    }



//*************************************OBRADA SERVERSKOG ODGOVORA
public class ObradaServerskogOdgovora extends Thread {

    KlijentForma kf;

    public ObradaServerskogOdgovora(KlijentForma kf) {
        this.kf = kf;
    }

    public void run() {
        try {
            while (true) {
                ServerskiOdgovor so = KomunikacijaSaServerom.getInstanca().primiOdgovor();

                switch (so.getOperacija()) {
                    case Opracije.PREKID_RADA:
                        kf.prekidRada(so);
                        break;

                    case Opracije.LOG_IN:

                        kf.infoLogovanje(so);
                        break;

                    case Opracije.BROJ_NA_MREZI:
                        kf.pokaziBrojNaMrezi(so);
                        break;

                    case Opracije.IZBACI_KLIJENTA:
                        kf.izbaciKlijenta();
                        break;

                    case Opracije.PROBA:
                        kf.analiziraj(so);
                        break;
                }

            }

            // super.run(); //To change body of generated methods, choose Tools | Templates.
        } catch (Exception e) {
            System.out.println("DISKONTKETOVAO SE");

        }
    }

}