Cours d'Informatique
par Jacques LAFORGUE

      AdaptObserver.java 
import java.util.*; import fr.cnam.connecteur.*; public class AdaptObserver implements Observer {     private INotifier consommateur;     public AdaptObserver(INotifier consommateur)     {         this.consommateur = consommateur;     }     public void update(Observable obsva,Object any)     {         consommateur.notifier(any);     } }       Client1.java 
import java.util.*; import java.rmi.*; import fr.cnam.connecteur.*; public class Client1 {     public static void main(String[] args) throws Exception     {         IConnecteurClient connecteur1  = FactoryConnecteur.creerConnecteurClient(9110,"CANAL1_SERVEUR1");         IConnecteurClient connecteur2 = FactoryConnecteur.creerConnecteurClient(9111,"CANAL1_SERVEUR2");         Vue1 vue1 = new Vue1();         Vue2 vue2 = new Vue2();         Vue3 vue3 = new Vue3();         connecteur1.addConsommateur(vue1);         connecteur1.addConsommateur(vue2);         connecteur1.addConsommateur(vue3);         connecteur2.addConsommateur(vue3);     } } class Vue1 implements Observer {   public void update(Observable o,Object any)     {         System.out.println("----------- VUE1 -----------");         System.out.println((String)any);     }         } class Vue2 implements Observer {   public void update(Observable o,Object any)     {         System.out.println("----------- VUE2 -----------");         System.out.println((String)any);     }         } class Vue3 implements Observer {   public void update(Observable o,Object any)     {         System.out.println("----------- VUE3 -----------");         System.out.println((String)any);     }         }       Client2.java 
import java.util.*; import java.rmi.*; import fr.cnam.connecteur.*; public class Client2 {     public static void main(String[] args) throws Exception     {         IConnecteurClient connecteur1 = FactoryConnecteur.creerConnecteurClient(9112,"CANAL1_SERVEUR1");         Vue4 vue4 = new Vue4();         Vue5 vue5 = new Vue5();         connecteur1.addConsommateur(vue4);         connecteur1.addConsommateur(vue5);     } } class Vue4 implements Observer {   public void update(Observable o,Object any)     {         System.out.println("----------- VUE4 -----------");         System.out.println((String)any);     }         } class Vue5 implements Observer {   public void update(Observable o,Object any)     {         System.out.println("----------- VUE5 -----------");         System.out.println((String)any);     }         }       Client3.java 
import java.util.*; import java.rmi.*; import fr.cnam.connecteur.*; public class Client3 {     public static void main(String[] args) throws Exception     {         IConnecteurClient connecteur1 = FactoryConnecteur.creerConnecteurClient(9113,"CANAL1_SERVEUR2");         Vue6 vue6 = new Vue6();         Vue7 vue7 = new Vue7();         connecteur1.addConsommateur(vue6);         connecteur1.addConsommateur(vue7);     } } class Vue6 implements Observer {   public void update(Observable o,Object any)     {         System.out.println("----------- VUE6 -----------");         System.out.println((String)any);     }         } class Vue7 implements Observer {   public void update(Observable o,Object any)     {         System.out.println("----------- VUE7 -----------");         System.out.println((String)any);     }         }       Serveur1.java 
import java.util.*; import fr.cnam.connecteur.*; public class Serveur1 {     public static void main(String[] args) throws Exception     {         IConnecteurServeur csv1 = FactoryConnecteur.creerConnecteurServeur(9101,"CANAL1_SERVEUR1");         IConnecteurServeur csv2 = FactoryConnecteur.creerConnecteurServeur(9102,"CANAL2_SERVEUR1");         Scanner sc = new Scanner(System.in);         while (true)             {                 System.out.print("Information a notifier : ");                 String info = sc.next();                 csv1.notifier(info);                 csv2.notifier(info);             }     } }       Serveur2.java 
import java.util.*; import java.rmi.*; import fr.cnam.connecteur.*; public class Serveur2 {     public static void main(String[] args) throws Exception     {         IConnecteurServeur csv = FactoryConnecteur.creerConnecteurServeur(9103,"CANAL1_SERVEUR2");         Scanner sc = new Scanner(System.in);         while (true)             {                 System.out.print("Information a notifier : ");                 String info = sc.next();                 csv.notifier(info);             }     } }       ServeurIntru.java 
import java.util.*; import java.rmi.*; import fr.cnam.connecteur.*; public class ServeurIntru {     public static void main(String[] args) throws Exception     {         IConnecteurServeur csvIntru = (IConnecteurServeur)Naming.lookup("rmi://localhost:9100/CANAL1_SERVEUR1");         Scanner sc = new Scanner(System.in);         while (true)             {                 System.out.print("Information a notifier : ");                 String info = sc.next();                 csvIntru.notifier(info+" (INTRU)");             }     } }       compil.bat 
mkdir bin del /f /s /q bin\*.class javac -d bin -classpath "."  *.java pause       fr
         cnam
            connecteur
               ConnecteurClient.java 
package fr.cnam.connecteur; import java.util.*; import java.rmi.*; import java.rmi.server.*; public class ConnecteurClient extends UnicastRemoteObject implements IConnecteurClient {     IConnecteurServeur csv;     ObservableClient obsva;     public ConnecteurClient(int portRmi,String host,int port,String name) throws Exception     {         super(portRmi);         csv = (IConnecteurServeur)Naming.lookup("rmi://"+host+":"+port+"/"+name);         csv.connecter(RemoteObject.toStub(this));         this.obsva = new ObservableClient();     }   public void addConsommateur(Observer consommateur)   {     obsva.addObserver(consommateur);   }     public void push(Object any)     {         System.out.println("push");         obsva.setChanged();         obsva.notifyObservers(any);     }           }                ConnecteurServeur.java 
package fr.cnam.connecteur; import java.util.*; import java.rmi.*; import java.rmi.server.*; import java.rmi.registry.*; import fr.cnam.connecteur.*; public class ConnecteurServeur extends UnicastRemoteObject implements IConnecteurServeur {     private ObservableServeur obsva;     public ConnecteurServeur(int portRMI,String name) throws Exception     {         super(portRMI);         try{             LocateRegistry.createRegistry(9100);         } catch(Exception ex){};                  Naming.rebind("rmi://localhost:9100/"+name,this);         obsva = new ObservableServeur();     }     public void connecter(Remote stub) throws RemoteException     {         obsva.addObserver(new ObserverClient((IConnecteurClient)stub));     }     public void notifier(Object any)  throws RemoteException     {         try{             System.out.println("notifier");             obsva.setChanged();             obsva.notifyObservers(any);         }catch(Exception ex){System.out.println(ex);}     } }                     FactoryConnecteur.java 
package fr.cnam.connecteur; import java.util.*; import fr.cnam.connecteur.*; public class FactoryConnecteur {   private static int    portRMIServeur = 9100;        // Adaptateur RMI   private static String hostServeur    = "localhost"; // Adaptateur RMI   static public IConnecteurServeur creerConnecteurServeur(int portRMI,String nomCanal)   {     try{       return new ConnecteurServeur(portRMI,nomCanal);     }catch(Exception ex){System.out.println(ex);};     return null;   }   static public IConnecteurClient creerConnecteurClient(int portRMIClient,                                                         String nomCanal)   {     try{       return new ConnecteurClient(portRMIClient,                                   hostServeur,                                   portRMIServeur,                                   nomCanal);     }catch(Exception ex){System.out.println(ex);};     return null;   } }                IConnecteurClient.java 
package fr.cnam.connecteur; import java.util.*; import java.rmi.*; public interface IConnecteurClient extends Remote {   public void push(Object any) throws RemoteException;   public void addConsommateur(Observer consommateur)  throws RemoteException; }                IConnecteurServeur.java 
package fr.cnam.connecteur; import java.rmi.*; public interface IConnecteurServeur extends Remote {   public void connecter(Remote stub) throws RemoteException;   public void notifier(Object any) throws RemoteException; }                INotifier.java 
package fr.cnam.connecteur; public interface INotifier {     public void notifier(Object any); }                ObservableClient.java 
package fr.cnam.connecteur; import java.util.*; public class ObservableClient extends Observable {     public void setChanged()     {         super.setChanged();     } }                ObservableServeur.java 
package fr.cnam.connecteur; import java.util.*; public class ObservableServeur extends Observable {     public void setChanged()     {         super.setChanged();     } }                ObserverClient.java 
package fr.cnam.connecteur; import java.util.*; import fr.cnam.connecteur.*; public class ObserverClient implements Observer {     private IConnecteurClient client;          public ObserverClient(IConnecteurClient client)     {         this.client = client;     }     public void update(Observable obsva,Object any)     {         try{             client.push(any);         }catch(Exception ex){System.out.println(ex);}     } }       runClient1.bat 
cd bin java -classpath "." Client1 pause       runClient2.bat 
cd bin java -classpath "." Client2 pause       runClient3.bat 
cd bin java -classpath "." Client3 pause       runProgLocal.bat 
cd bin java -classpath "." ProgLocal pause       runSeveur1.bat 
cd bin java -classpath "." Serveur1 pause       runSeveur2.bat 
cd bin java -classpath "." Serveur2 pause       runSeveurIntru.bat 
cd bin java -classpath "." ServeurIntru pause