Cours CNAM par J. Laforgue

ExempleCh05_02c_InterfaceService2

Retour

Télécharger

Cet exemple a le même comportement que l'exemple précédent.
Tout est implémenté en simulant ce que fait le prôtocole RMI.
Cela permet de comprendre comment RMI fonctionne

      README.txt
      Annuaire.bin
      Connexion.java
      DVD.java
      DVDInvoker.java

import java.io.*;
import java.net.*;

//  La communication se fait par socket et serialisation des donnees
//
public class DVDInvoker implements MediaInt, Serializable
{
    private String host;
    private int    port;
    private int    hashCode;

public DVDInvoker(int hashCode,String host,int port)
    {
        this.hashCode = hashCode;
        this.host = host;
        this.port = port;
    }

public String getNom()
    {
        try{
            Socket soc;
            if (host.equals("localhost"))
                soc = new Socket(InetAddress.getLocalHost(),port);
            else soc = new Socket(host,port);
            OutputStream os=soc.getOutputStream();
            ObjectOutputStream oos=new ObjectOutputStream(os);
            InputStream is=soc.getInputStream();
            ObjectInputStream ois=new ObjectInputStream(is);
            
            oos.writeObject(new Integer(hashCode));
            oos.writeObject("getNom");
            String nom = (String)(ois.readObject());
            soc.close();
            return nom;
        }
        catch(Exception ex){System.out.println("ERREUR InvokerDVD :"+ex);return null;}
    }

public String getType()
    {
        try{
            Socket soc;
            if (host.equals("localhost"))
                soc = new Socket(InetAddress.getLocalHost(),port);
            else soc = new Socket(host,port);
            OutputStream os=soc.getOutputStream();
            ObjectOutputStream oos=new ObjectOutputStream(os);
            InputStream is=soc.getInputStream();
            ObjectInputStream ois=new ObjectInputStream(is);
            
            oos.writeObject(new Integer(hashCode));
            oos.writeObject("getType");
            String type = (String)(ois.readObject());
            soc.close();
            return type;
        }
        catch(Exception ex){System.out.println("ERREUR InvokerDVD :"+ex);return null;}
    }

}

DVDOD.java
DVDODSkelton.java

import java.util.*;
import java.io.*;
import java.net.*;

public class DVDODSkelton extends MyRemoteObjectInvocation
{
    private DVDOD serviceOD;

public DVDODSkelton(DVDOD serviceOD)
    {
        super(serviceOD.getPort(),serviceOD);
        this.serviceOD = serviceOD;
    }

public void invoke(String methode,
                       ObjectOutputStream oos,
                       ObjectInputStream ois) throws MyRemoteException
    {
        try{
            if (methode.equals("getNom"))
                {
                    String nom = serviceOD.getNom();
                    oos.writeObject(nom);
                }
            
            if (methode.equals("getType"))
                {
                    String type = serviceOD.getType();
                    oos.writeObject(type);
                }
        }catch(Exception ex)
            {
                System.out.println("Erreur dans LivreSkelton : invoke");
                System.out.println(ex);
                ex.printStackTrace();
                throw new MyRemoteException(ex);
            }
    }
}

      DVDStub.java
      Ecole.java
      ExempleCh05_02c.java
      Librairie.java
      Livre.java
      LivreInvoker.java

import java.io.*;
import java.net.*;

//  La communication se fait par socket et serialisation des donnees
//
public class LivreInvoker implements MediaInt, Serializable
{
    private String host;
    private int    port;
    private int    hashCode;

public LivreInvoker(int hashCode,String host,int port)
    {
        this.hashCode = hashCode;
        this.host = host;
        this.port = port;
    }

public String getNom()
    {
        try{
            Socket soc;
            if (host.equals("localhost"))
                soc = new Socket(InetAddress.getLocalHost(),port);
            else soc = new Socket(host,port);
            OutputStream os=soc.getOutputStream();
            ObjectOutputStream oos=new ObjectOutputStream(os);
            InputStream is=soc.getInputStream();
            ObjectInputStream ois=new ObjectInputStream(is);
            
            System.out.println("stub: getNom : "+hashCode);
            oos.writeObject(new Integer(hashCode));
            oos.writeObject("getNom");
            String nom = (String)(ois.readObject());
            soc.close();
            return nom;
        }
        catch(Exception ex){System.out.println("ERREUR InvokerLivre :"+ex);return null;}
    }

public String getType()
    {
        try{
            Socket soc;
            if (host.equals("localhost"))
                soc = new Socket(InetAddress.getLocalHost(),port);
            else soc = new Socket(host,port);
            OutputStream os=soc.getOutputStream();
            ObjectOutputStream oos=new ObjectOutputStream(os);
            InputStream is=soc.getInputStream();
            ObjectInputStream ois=new ObjectInputStream(is);
            
            System.out.println("stub: getType : "+hashCode);
            oos.writeObject(new Integer(hashCode));
            oos.writeObject("getType");
            String type = (String)(ois.readObject());
            soc.close();
            return type;
        }
        catch(Exception ex){System.out.println("ERREUR InvokerLivre :"+ex);return null;}
    }

}

LivreOD.java
LivreODSkelton.java

import java.util.*;
import java.io.*;
import java.net.*;

public class LivreODSkelton extends MyRemoteObjectInvocation
{
    private LivreOD serviceOD;

public LivreODSkelton(LivreOD serviceOD)
    {
        super(serviceOD.getPort(),serviceOD);
        this.serviceOD = serviceOD;
    }

public void invoke(String methode,
                       ObjectOutputStream oos,
                       ObjectInputStream ois) throws MyRemoteException
    {
        try{
            if (methode.equals("getNom"))
                {
                    System.out.println(">>invoke: getNom");
                    String nom = serviceOD.getNom();
                    oos.writeObject(nom);
                }
            
            if (methode.equals("getType"))
                {
                    System.out.println(">>invoke: getType");
                    String type = serviceOD.getType();
                    oos.writeObject(type);
                }
        }catch(Exception ex)
            {
                System.out.println("Erreur dans LivreSkelton : invoke");
                System.out.println(ex);
                ex.printStackTrace();
                throw new MyRemoteException(ex);
            }
    }
}

      LivreStub.java
      Media.java
      MediaInt.java
      MediaODInt.java
      MyRMIServerSocket.java

import java.util.*;
import java.io.*;
import java.net.*;

public class MyRMIServerSocket implements Runnable
{
    private ArrayList<MyRemoteObjectInvocation> skeltons;
    private ServerSocket ssoc;
    private static MyRMIServerSocket myssoc = null;

static public MyRMIServerSocket getInstance(int port)
    {
        if (myssoc==null)
            {
                myssoc = new MyRMIServerSocket(port);
                return myssoc;
            }
        else
            return myssoc;
    }

private  MyRMIServerSocket(int port)
    {
        try{
            skeltons = new ArrayList<MyRemoteObjectInvocation>();
            ssoc     = new ServerSocket(port);
            Thread t = new Thread(this);
            t.start();
        }catch(Exception ex)
            {
                System.out.println("Erreur dans MyRMIServerSocket");
                System.out.println(ex);
                ex.printStackTrace();
            }
    }

synchronized public void addRemoteObject(MyRemoteObjectInvocation sk)
    {
        System.out.println("Ajout d'un skelton: "+sk.getHashCode());
        skeltons.add(sk);
    }

public void run()
    {
        try{
            while (true)
                {
                    Socket soc = ssoc.accept();
                    OutputStream os=soc.getOutputStream();
                    ObjectOutputStream oos=new ObjectOutputStream(os);
                    InputStream is=soc.getInputStream();
                    ObjectInputStream ois=new ObjectInputStream(is);

Integer hashCodeRemote = (Integer)(ois.readObject());
                    String methode = (String)(ois.readObject());

MyRemoteObjectInvocation skelton = null;
                    for(MyRemoteObjectInvocation sk : skeltons)
                        if (sk.getHashCode() == hashCodeRemote.intValue())
                            skelton = sk;
                    
                    if(skelton!=null)
                        {
                            System.out.println(">>invoke de "+methode);
                            skelton.invoke(methode,oos,ois);
                        }
                    else
                        {
                            System.out.println("ERREUR: skelton non trouve: "+hashCodeRemote.intValue());
                        }
                }
        }catch(Exception ex)
            {
                System.out.println("Erreur dans MyRMIServerSocket : run");
                System.out.println(ex);
                ex.printStackTrace();
            }
    }
}

      MyRemote.java
      MyRemoteException.java
      MyRemoteObject.java
      MyRemoteObjectInvocation.java
      MyUnicastRemoteObject.java
      Organisme.java
      Server.java

// Server.java
// Le serveur stocke les objets créés dansune table de hashing.
// La clef de hashage des objets sont utilisés comme clef de recherche.
//
// Le serveur gère l'appel de toutes les méthodes distantes.
//
import java.util.*;
import java.io.*;
import java.net.*;

// ===================================
public class Server
{
    public static void main(String args[]) throws Exception
        {
            int port = Integer.parseInt(args[0]);

ServiceOD sod = new ServiceOD(port);

MyRemoteObject sk = sod.exportObject();
            MyRemote stub = sod.toStub();

File fic = new File("..","Annuaire.bin");
            FileOutputStream fin = new FileOutputStream(fic);
            ObjectOutputStream fich = new ObjectOutputStream(fin);

fich.writeObject(stub);
            /*
            System.out.println("hash code du service: "+sk.getHashCode());
            Terminal.ecrireFichier("../Annuaire.txt",
                                   new StringBuffer(""+sk.getHashCode()));
            */
        }
}

      Service.java
      ServiceInt.java
      ServiceInvoker.java

import java.io.*;
import java.net.*;

//  La communication se fait par socket et serialisation des donnees
//
public class ServiceInvoker implements ServiceInt, Serializable
{
    private String host;
    private int    port;
    private int    hashCode;

public ServiceInvoker(int hashCode,String host,int port)
    {
        this.host = host;
        this.port = port;
        this.hashCode = hashCode;
    }

public MediaInt creerLivre(String nom)
    {
        try{
            Socket soc;
            if (host.equals("localhost"))
                soc = new Socket(InetAddress.getLocalHost(),port);
            else soc = new Socket(host,port);
            OutputStream os=soc.getOutputStream();
            ObjectOutputStream oos=new ObjectOutputStream(os);
            InputStream is=soc.getInputStream();
            ObjectInputStream ois=new ObjectInputStream(is);
            
            oos.writeObject(new Integer(hashCode));
            oos.writeObject("creerLivre");
            oos.writeObject(nom);
            MediaInt m = (MediaInt)(ois.readObject());
            soc.close();
            return m;
        }
        catch(Exception ex){System.out.println("ERREUR InvokerService :"+ex);return null;}
    }

public MediaInt creerDVD(String nom)
    {
        try{
            Socket soc;
            if (host.equals("localhost"))
                soc = new Socket(InetAddress.getLocalHost(),port);
            else soc = new Socket(host,port);
            OutputStream os=soc.getOutputStream();
            ObjectOutputStream oos=new ObjectOutputStream(os);
            InputStream is=soc.getInputStream();
            ObjectInputStream ois=new ObjectInputStream(is);
                        
            oos.writeObject(new Integer(hashCode));
            oos.writeObject("creerDVD");
            oos.writeObject(nom);
            MediaInt m = (MediaInt)(ois.readObject());
            soc.close();
            return m;
        }catch(Exception ex){System.out.println("ERREUR InvokerService :"+ex);return null;}
    }
}

ServiceOD.java

import java.io.*;

public class ServiceOD extends MyUnicastRemoteObject implements ServiceODInt
{
    private ServiceInt service;
    private int port;

public ServiceOD(int port)
    {
        super(port);
        service = new Service();
        this.port = port;
    }

public MediaInt creerLivre(String nom) throws MyRemoteException
    {
        System.out.println("ServiceOD : Creer livre");

MediaInt m = service.creerLivre(nom);
        LivreOD lod = new LivreOD(port,(Livre)m);
        lod.exportObject();
        MyRemote stub = lod.toStub();
        return (MediaInt)stub;
    }

public MediaInt creerDVD(String nom) throws MyRemoteException
    {
        System.out.println("ServiceOD : Creer DVD");
       
        MediaInt m = service.creerDVD(nom);
        DVDOD dod = new DVDOD(port,(DVD)m);
        dod.exportObject();
        MyRemote stub = dod.toStub();
        return (MediaInt)stub;
    }

public MyRemote toStub()
    {
        return new ServiceStub(getHashCode(),
                               getHost(),
                               getPort());
    }
}

ServiceODInt.java
ServiceODSkelton.java

import java.util.*;
import java.io.*;
import java.net.*;

public class ServiceODSkelton extends MyRemoteObjectInvocation
{
    private ServiceOD serviceOD;

public ServiceODSkelton(ServiceOD serviceOD)
    {
        super(serviceOD.getPort(),serviceOD);
        this.serviceOD = serviceOD;
    }

public void invoke(String methode,
                       ObjectOutputStream oos,
                       ObjectInputStream ois) throws MyRemoteException
    {
        try{
            if (methode.equals("creerLivre"))
                {
                    System.out.println("Creation d'un livre");
                    String nom = (String)(ois.readObject());
                    MediaInt m = serviceOD.creerLivre(nom);
                    oos.writeObject(m);
                }
            
            if (methode.equals("creerDVD"))
                {
                    System.out.println("Creation d'un DVD");
                    String nom = (String)(ois.readObject());
                    MediaInt m = serviceOD.creerDVD(nom);
                    oos.writeObject(m);
                }
        }catch(Exception ex)
            {
                System.out.println("Erreur dans SkeltonService : invoke");
                System.out.println(ex);
                ex.printStackTrace();
                throw new MyRemoteException(ex);
            }
    }
}

      ServiceStub.java
      compil.bat
      runClient.bat
      runServer.bat

Cours d'Informatique par Jacques LAFORGUE

Retour

Télécharger

Cours d'Informatique
par Jacques LAFORGUE