[JAVA] RMI Comunicazione fra Server e Client

[JohnMarston]

Ciao,
sto cercando di capire come creare un canale in modo tale che il client resti in ascolto e stampi i valori passati dal server. Mancano dei blocchi di codice, semplicemente perché non ho idea come andare avanti.

Questa è la classe server

public class Server {
    RemoteImpl impl;
    
    public void Server() {
    }

    public void timer(){
        try { 
            impl = new RemoteImpl();
            Registry reg = LocateRegistry.createRegistry(Constant.RMI_PORT);
            reg.bind(Constant.RMI_ID, impl);
            System.out.println("Server Partito!"); 

        } catch (Exception exc) {        
            System.out.println("SERVER - RMI Eccezione "+exc);                       
        }
        final ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
        service.scheduleAtFixedRate(new Runnable(){
            @Override
            public void run(){              
                try { 
                    DateFormat df = new SimpleDateFormat("MM/dd/yyyy HH:mm:ss");
                    Date today = Calendar.getInstance().getTime();        
                    String reportDate = df.format(today);
                    System.out.println("Server: Time " + reportDate);
                    impl.getTimeServer(reportDate);
                } catch (Exception exc) {
                    System.out.println("SERVER - Timer Eccezione "+exc);                         
                }
            }
        }, 0, 1, TimeUnit.SECONDS);
    }
    
    public static void main(String[] args) throws RemoteException, AlreadyBoundException {      
        new Server().timer();        
    }

}

Questa è l'interfaccia

public class RemoteImpl extends UnicastRemoteObject implements TestRemote{

    protected  RemoteImpl() throws RemoteException {
        super();

    }
    @Override
    public boolean isLoginValid(String username) throws RemoteException {
        if(username.equals("test")){
            return true;
        }
        return false;
    }

    @Override
    public void getTimeServer(String time) throws RemoteException {
        System.out.println("RemoteImpl: Time "+time);
    }
    
}

Questo è il client

public class Client {

    public Client() throws RemoteException, NotBoundException {
        System.out.println("RMI_PORT "+Constant.RMI_PORT);
        System.out.println("RMI_ID "+Constant.RMI_ID);
        
        Registry registry = LocateRegistry.getRegistry("localhost", Constant.RMI_PORT);
        TestRemote remote = (TestRemote)registry.lookup(Constant.RMI_ID);
        
        System.out.println(remote.isLoginValid("test"));              
    }

    public static void main(String[] args)throws RemoteException, NotBoundException {
        new Client();

    }
    
}

In pratica il client dovrebbe continuare a stampare la data che il server passa e quest'ultimo dovrebbe consentire a più client di collegarsi.