Cours CNAM par J. Laforgue

Exemple05_Connecteur

Retour

Télécharger

Codage d'un connecteur de notification synchrone de données entre un fournisseur et plusieurs consommateurs déployés sur une même machine

Diagramme.pdf

Appli.java

import java.util.*;
import fr.cnam.connecteur.*;
import fr.cnam.metier.*;

public class Appli
{
    public static void main(String[] args) throws Exception
    {
        Vue1 vue1 = new Vue1();
        ConnecteurClient.add(vue1);

Vue2 vue2 = new Vue2();
        ConnecteurClient.add(vue2);

Vue3 vue3 = new Vue3();
        ConnecteurClient.add(vue3);

// --------------------------------------------------------------------

FactoryPersonne  factory = new 
          FactoryPersonne(ConnecteurServeur.creer(ConnecteurClient.getInstance()));

IPersonne p1 = factory.creerPersonne("LAFONT","Pierre","Toulouse");
        IPersonne p2 = factory.creerPersonne("DUPONT","Paul","Marseille");

Scanner sc = new Scanner(System.in);
        while (true)
            {
                factory.lister();

System.out.print("Index : ");
                int index = sc.nextInt();
                System.out.print("Adresse : ");
                String adresse = sc.next();
                factory.get(index).setAdresse(adresse);
            }
        
    }
}

class Vue1 implements Observer
{
    public void update(Observable obsva,Object any)
    {
        Personne p = (Personne)any;
        System.out.println("----------- VUE1 -----------");
        System.out.println(p);
    }        
}

class Vue2 implements Observer
{
    public void update(Observable obsva,Object any)
    {
        Personne p = (Personne)any;
        System.out.println("----------- VUE2 -----------");
        System.out.println(p);
    }        
}

class Vue3 implements Observer
{
    public void update(Observable obsva,Object any)
    {
        Personne p = (Personne)any;
        System.out.println("-----xxxxxxxxxxx------ VUE3 -----------");
        System.out.println(p);
    }        
}

      Client.java
            Serveur.java
      compil.bat
      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, INotifier
{
  private static ConnecteurClient connecteur=null;
  private IConnecteurServeur serveur;
  private ObservableClient observable;

public ConnecteurClient(String host,int port,String name) throws Exception
  {
    try {
        serveur = (IConnecteurServeur)Naming.lookup("rmi://"+host+":"+port+"/"+name);
        serveur.connecter((IConnecteurClient)(RemoteObject.toStub(this)));
        this.observable = new ObservableClient();
      }
    catch(Exception ex)
      {
        serveur=null;
        this.observable = new ObservableClient();
        System.out.println("Le connecteur est utilise en LOCAL");
      }
  }

public void push(Object any)
  {
    System.out.println("push");
    observable.setChanged();
    observable.notifyObservers(any);
  }

public void notifier(Object any)
  {
    push(any);
  }
    
  public static ConnecteurClient getInstance()
  {
    if (connecteur==null) 
      try {
        connecteur = new ConnecteurClient("localhost",9100,"CONNECTEUR");
        return connecteur;
      }catch(Exception ex){return null;}
    else return connecteur;
  }

public static void add(Observer obs)
    {
      ConnecteurClient.getInstance().getObservableClient().addObserver(obs);
    }
  
  public ObservableClient getObservableClient(){
    return observable; }
}

ConnecteurServeur.java

package fr.cnam.connecteur;

import java.util.*;
import java.rmi.*;
import java.rmi.server.*;
import java.rmi.registry.*;

public class ConnecteurServeur extends UnicastRemoteObject implements IConnecteurServeur, INotifier
{
  private ArrayList<IConnecteurClient> clients;

public ConnecteurServeur(String name) throws Exception
  {
    super(9101);
    clients = new ArrayList<IConnecteurClient>();
    try{
      LocateRegistry.createRegistry(9100);
    } catch(Exception ex){};
        
    Naming.rebind("rmi://localhost:9100/"+name,this);
  }

public void connecter(IConnecteurClient client) throws RemoteException
  {
    this.clients.add(client);
  }

public void notifier(Object any)
  {
    try{
      System.out.println("notifier");
      for(IConnecteurClient c:clients) c.push(any);
    }catch(Exception ex){System.out.println(ex);}
  }

public static INotifier creer(ConnecteurClient c)
  {
    if (c==null)
      {
        ConnecteurServeur csv = null;
        try{
          csv = new ConnecteurServeur("CONNECTEUR");
        }catch(Exception ex){System.out.println(ex);};
        return csv;
      }
    else
      {
        return c;
      }
  }

}

               IConnecteurClient.java
               IConnecteurServeur.java
               INotifier.java
               ObservableClient.java
            metier
               FactoryPersonne.java

package fr.cnam.metier;

import java.util.*;
import fr.cnam.connecteur.*;
import fr.cnam.metier.*;

public class FactoryPersonne 
{
    private ArrayList<IPersonne> elements;
    private INotifier notifier;

public FactoryPersonne(INotifier notifier)
    {
        elements = new ArrayList<IPersonne>();
        this.notifier = notifier;
    }

public IPersonne creerPersonne(String nom,String prenom,String adresse)
    {
        IPersonne p = new ProxyPersonne(notifier,
                                        new Personne(nom,prenom,adresse));
        elements.add(p);
        return p;
    }

public IPersonne get(int index)
    {
        return elements.get(index);
    }
    
    public void lister()
    {
        System.out.println("-------------------------------------------");
        int i=0;
        for(IPersonne p:elements)
            System.out.println(String.format("%2d %20s %20s %20s",
                                             i++,
                                             p.getNom(),
                                             p.getPrenom(),
                                             p.getAdresse()));
        System.out.println("-------------------------------------------");
    }

}

               IPersonne.java
               Personne.java
               ProxyPersonne.java
      runAppli.bat
      runClient.bat
      runSeveur.bat

Cours d'Informatique par Jacques LAFORGUE

Retour

Télécharger

Cours d'Informatique
par Jacques LAFORGUE