Cours CNAM par J. Laforgue

ExempleCh05_02a_InterfaceService2

Retour

Télécharger

Par rapport Ã l'exemple précéden, Ch05_01, l'exemple Ch05_02a est un client qui se connecte Ã un Server distant via un proxy qui assure la conversion d'un appel de methode en une communication par socket et en utiilisant la serialisation native du langage JAVA.
Cet exemple utilise les classes définies dans l'exemple Ch05_01 par le jar exempleCh05_01.jar créé par le script faireJar.bat.

      README.txt
      Connexion.java
      ConnexionProxy.java
      ExempleCh05_02a.java

// Par rapport Ã  l'exemple précéden, Ch05_01, l'exemple Ch05_02a est un client qui se connecte Ã  un Server distant via un proxy qui assure la conversion d'un appel de methode en une communication par socket et en utiilisant la serialisation native du langage JAVA.
// Cet exemple utilise les classes définies dans l'exemple Ch05_01 par le jar exempleCh05_01.jar créé par le script faireJar.bat.

import java.util.*;

// ===================================
public class ExempleCh05_02a
{
    static private ServiceInt serv;
    static private Librairie  lib;
    static private Ecole      eco;

public static void main(String... args)
    {
        System.out.println("Execution de Exemple06");
        
        // Au lieu de la creation du service, on se connecte au service
        //
        serv = Connexion.getService("localhost",9101);

// Le reste du code est le meme que celui de l'exemple 05
        Librairie lib = new Librairie(serv);
        Ecole     eco = new Ecole(serv);

lib.initialisationMedias();
        eco.initialisationMedias();

System.out.println("Librairie: "+lib);
        System.out.println("Ecole: "+eco);
    }
}

InvokerService.java

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

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

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

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("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("creerDVD");
            oos.writeObject(nom);
            MediaInt m = (MediaInt)(ois.readObject());
            soc.close();
            return m;
        }catch(Exception ex){System.out.println("ERREUR InvokerService :"+ex);return null;}
    }
}

Server.java

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

// ===================================
public class Server
{
    static private Service service;

public static void main(String args[]) throws Exception
        {
            service = new Service();

ServerSocket ssoc = new ServerSocket(Integer.parseInt(args[0]));
            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));
                            oos.writeObject(l);
                        }
                    if (methode.equals("creerDVD"))
                        {
                            System.out.println("Creation d'un DVD");
                            String nom = (String)(ois.readObject());
                            DVD d = (DVD)(service.creerDVD(nom));
                            oos.writeObject(d);
                        }
                    soc.close();
                }
        }
}

Terminal.java

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

/** La classe Terminal permet de réaliser ses premiers programmes Java en permettant d'afficher dans la console d'exécution des données de type différents, et en permettant de saisir au clavier des données de type différents.<BR>
    Elle permet aussi de lire et écrire un fichier texte
    Cette classe contient que des méthodes statiques. */
public class Terminal{

// Le buffer standard  de lecture = le clavier
    private static BufferedReader in =
        new BufferedReader(new InputStreamReader(System.in));

/** Cette méthode lit un fichier texte et retourne le contenu du fichier sous la forme d'un  tableau de String dont chaque element est une ligne du fichier.
        @param nomFichier le nom du fichier qui doit être dans le répertoire courant.
        @return String[] le contenu du fichier. 
        @exception TerminalException (de type RuntimeException) si erreur d'écriture<BR>
        Rappel : Une exception de type RuntimeException n'a pas l'obligation d'être capturée.
*/
    public static String[] lireFichierTexte(String nomFichier)
    {
        try{
            File fichier = new File(nomFichier);
            FileInputStream fis = new FileInputStream(new File(nomFichier));
            
            byte[] buffer = new byte[(int)fichier.length()];
            fis.read(buffer);
            fis.close();
            String str = new String(buffer);

// On enleve le caractère '\r' code 13 qui est ajouté en Windows
            // Les fins de ligne dans un fichier texte créé sous Windows
            //  se termine par \r\n.
            // Il faut enlever le \r car il a des effets perturbant sur
            //  la méthode System.out.print et est pris comme un caractère de plus
            //  qu'il faut éliminer
            //  
            String texte = str.replaceAll(""+(char)(13),"");
            
            // Les lignes du fichier sont mises dans un tableau
            //
            String[] mots = texte.split("\n");

return(mots);
        }
        catch(Exception ex)
            {
                exceptionHandler(ex);
            }
        return null;
    }

/** Cette méthode permet de créer un fichier texte à partir du contenu d'un StringBuffer.
        @param nomFichier Le nom du fichier qui est créé dans le répertoire courant
        @param strbuf Le StringBuffer contenant le texte à écrire. 
        @exception TerminalException (de type RuntimeException) si erreur d'écriture
    */
    public static void ecrireFichier(String nomFichier,
                                     StringBuffer strbuf)
    {
        try{
            File fichier = new File(nomFichier);
            FileOutputStream fos = new FileOutputStream(new File(nomFichier));
            
            byte[] buffer = strbuf.toString().getBytes();
            fos.write(buffer);
            fos.close();
        }
        catch(Exception ex)
            {
                exceptionHandler(ex);
            }
    }

/** Cette méthode lit une chaîne de caractère
        @return String la chaîne saisie dans la console d'exécution
       @exception TerminalException (de type RuntimeException) si erreur de lecture
    */
    public static String lireString() // Lire un String
    {
        String tmp="";
        char C='\0';
        try {
            tmp = in.readLine();
        }
        catch (IOException e)
            {
                exceptionHandler(e);
            }
        return tmp;
    }

/** Cette méthode lit un entier
        @return int L'entier saisi dans la console d'exécution
       @exception TerminalException (de type RuntimeException) si la saisie n'est pas un entier ou erreur de lecture
    */
    public static int lireInt()  // Lire un entier
    {
        int x=0;
        try {
            x=Integer.parseInt(lireString());
        }
        catch (NumberFormatException e) {
            exceptionHandler(e);
        }    
        return x ;
    }

/** Cette méthode lit un boolean (false ou true)
        @return boolean Le boolean saisi dans la console d'exécution
       @exception TerminalException (de type RuntimeException) si erreur de lecture. <BR>
       Tout autre valeur que TRUE, FALSE, true ou false, retourne la valeur false
    */
    public static boolean lireBoolean()  // Lire un entier
    {
        boolean b = true;
        try {
            b = Boolean.valueOf(lireString()).booleanValue();
        }
        catch (NumberFormatException e) {
            exceptionHandler(e);
        }    
        return b;
    }

/** Cette méthode lit un double
        @return double Le double saisi dans la console d'exécution
       @exception TerminalException (de type RuntimeException) si la valeur saisie n'est pas un double ou ereur de lecture.
    */
    public  static double lireDouble()  // Lire un double
    {
        double x=0.0;
        try {
            x=Double.valueOf(lireString()).doubleValue();
        }
        catch (NumberFormatException e) {
            exceptionHandler(e);
        }    
        return x ;
    }

/** Cette méthode lit un caractère.
       @exception TerminalException (de type RuntimeException) si erreur de lecture.<BR>
       Si on saisit plus d'1 caractère alors le caractère retourné est le premier.
    */
    public  static char lireChar()  // Lire un caractere
    {
        String tmp=lireString();
        if (tmp.length()==0)
            return '\n';
        else 
            {
                return tmp.charAt(0);
            }
    }

/** Cette méthode écrit une chaine et ne revient pas à la ligne.
        @param s la chaine à écrire
    */
    public static void ecrireString(String s){ // Afficher un String
        System.out.print(s);
    }

/** Cette méthode écrit une chaine et revient à la ligne.
        @param s la chaine à écrire
    */
    public static void ecrireStringln(String s) // Afficher un String
    {
        ecrireString(s);
        sautDeLigne();
    }

/** Cette méthode écrit un entier et ne revient pas à la ligne.
        @param i l'entier à écrire
    */
    public static void ecrireInt(int i)  // Afficher un entier
    {
        ecrireString(""+i);
    }

/** Cette méthode écrit un entier et revient à la ligne.
        @param i l'entier à écrire
    */
    public static void ecrireIntln(int i)  // Afficher un entier
    {
        ecrireString(""+i);
        sautDeLigne();
    }

/** Cette méthode écrit un booléan et ne revient pas à la ligne.
        @param b le booléen à écrire
    */
    public static void ecrireBoolean(boolean b){
        ecrireString(""+b);
    }

/** Cette méthode écrit un booléan et revient à la line.
        @param b le booléen à écrire
    */
    public static void ecrireBooleanln(boolean b){
        ecrireString(""+b);
        sautDeLigne();
    }

/** Cette méthode écrit un double et ne revient pas à la ligne.
        @param d le double à écrire
    */
    public  static void ecrireDouble(double d)  // Afficher un double
    {
        ecrireString(""+d);
    }

/** Cette méthode écrit un double et revient à la ligne.
        @param d le double à écrire
    */
    public  static void ecrireDoubleln(double d)  // Afficher un double
    {
        ecrireDouble(d);
        sautDeLigne();
    }

/** Cette méthode écrit un caractère et ne revient pas à la ligne.
        @param c le caractère à écrire
    */
    public  static void ecrireChar(char c)  // Afficher un caractere
    {
        ecrireString(""+c);
    }

/** Cette méthode écrit un caractère et revient à la ligne.
        @param c le caractère à écrire
    */
    public  static void ecrireCharln(char c)  // Afficher un caractere
    {
        ecrireChar(c);
        sautDeLigne();
    }

/** Cette méthode revient à la ligne.
    */
    public static void sautDeLigne(){
        try{
            System.out.println();
        }catch(Exception ex){
            exceptionHandler(ex);
        }
    }

/** Cette méthode retourne l'exception TerminalException
    */
    protected static void exceptionHandler(Exception ex){
        TerminalException err = new TerminalException(ex);
        throw err;
    }

/** Cette méthode écrit une exception avec la pile dans la console
        @param ex l'exception à écrire
    */
    public static void ecrireException(Throwable ex){
        ecrireString(ex.toString());
        ex.printStackTrace(System.out);
    }
}

/** Classe de définition de l'exception TerminalException qui peut être retournée dans l'usage des méthodes de la classe Terminal. */
class TerminalException extends RuntimeException{
    Exception ex;
    TerminalException(Exception e){
        ex = e;
    }
}

      compil.bat
      faireJar.bat
      runClient.bat
      runServer.bat

Cours d'Informatique par Jacques LAFORGUE

Retour

Télécharger

Cours d'Informatique
par Jacques LAFORGUE