Cours CNAM par J. Laforgue

ExempleCh05_02b_InterfaceService2

Retour

Télécharger

La seule différence avec l'exemple précédent Ch05_02a, est que les objet créés restent sur le serveur.
Le serveur renvoie au client des stubs de connexion distants à ces objets à la place des objets réels.
La démonstration est aussi de montrer que le code du client est le même que celui précédent.
Cet exemple utilise les classes définies dans ExempleCh05_01 et ExempleCh05_02a par les jar exempleCh05_01.jar et exempleCh05_02a.jar créés par les scripts respectifs faireJar.bat des ExempleCh05_01 et ExempleCh05_02a.

      README.txt
      DVDStub.java
      ExempleCh05_02b.java
      InvokerDVD.java

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

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

public InvokerDVD(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("getNom");
            oos.writeObject(new Integer(hashCode));
            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("getType");
            oos.writeObject(new Integer(hashCode));
            String type = (String)(ois.readObject());
            soc.close();
            return type;
        }
        catch(Exception ex){System.out.println("ERREUR InvokerDVD :"+ex);return null;}
    }

}

InvokerLivre.java

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

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

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

}

LivreStub.java
Server2.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 Server2
{
    static private Service service;
    static private Hashtable<Integer,Media> tableOD;

public static void main(String args[]) throws Exception
        {
            int port = Integer.parseInt(args[0]);
            service = new Service();
            tableOD = new Hashtable<Integer,Media>();

ServerSocket ssoc = new ServerSocket(port);
            while (true)
                {
                    Socket soc = ssoc.accept();
                    OutputStream os=soc.getOutputStream();
                    ObjectOutputStream oos=new ObjectOutputStream(os);
                    InputStream is=soc.getInputStream();
                    ObjectInputStream ois=new ObjectInputStream(is);
                    
                    String methode = (String)(ois.readObject());

if (methode.equals("creerLivre"))
                        {
                            System.out.println("Creation d'un livre");
                            String nom = (String)(ois.readObject());
                            Livre l = (Livre)(service.creerLivre(nom));
                            tableOD.put(new Integer(l.hashCode()),l);

// on retourne un stub 
                            LivreStub lstub = new LivreStub(l,
                                                            InetAddress.getLocalHost().getHostName(),
                                                            port
                                                            );
                            oos.writeObject(lstub);
                        }

if (methode.equals("creerDVD"))
                        {
                            System.out.println("Creation d'un DVD");
                            String nom = (String)(ois.readObject());
                            DVD d = (DVD)(service.creerDVD(nom));
                            tableOD.put(new Integer(d.hashCode()),d);

// on retourne un stub 
                            DVDStub dstub = new DVDStub(d,
                                                        InetAddress.getLocalHost().getHostName(),
                                                        port);
                            oos.writeObject(dstub);
                        }

if (methode.equals("getNom"))
                        {
                            System.out.print("getNom");
                            Integer hashCode = (Integer)(ois.readObject());
                            Media m = tableOD.get(hashCode);
                            System.out.println(" de "+m.hashCode());
                            oos.writeObject(m.getNom());
                        }

if (methode.equals("getType"))
                        {
                            System.out.print("getType");
                            Integer hashCode = (Integer)(ois.readObject());
                            Media m = tableOD.get(hashCode);
                            System.out.println(" de "+m.hashCode());
                            oos.writeObject(m.getType());
                        }
                    soc.close();
                }
        }
}

      compil.bat
      runClient.bat
      runServer.bat

Cours d'Informatique par Jacques LAFORGUE

Retour

Télécharger

Cours d'Informatique
par Jacques LAFORGUE