Cours CNAM par J. Laforgue

Exemple41_Clientserveur

Retour

Télécharger

Exemple d'un programme client-serveur

      compil.bat
      runClient.bat
      runServeur.bat
      src
         fr
            cnam
               ihm
               projet
                  IHMClient.java

package fr.cnam.projet;

import java.util.*;
import java.io.*;
import java.net.*;
import java.text.*;
import fr.cnam.ihm.*;

// Classe de definition et de creation d'un client qui se connecte
//   au modele. Ce client se connecte en connaissant le host de la
//   machine sur laquelle le modele s'execute.
//
public class IHMClient implements FormulaireInt
{
    private String     host;       // host de la machine distante
    private int        port;       // port du serveur de socket

private Formulaire form;      // Le formulaire de l'ihm

public static void main(String... args)
    {
        int port = Integer.parseInt(args[1]);
        IHMClient ihm = new IHMClient(args[0],port);
    }

// ------------------------------------------
    // Constructeur
    //    host : host de la machine
    //    port : port du serveur de socket
    // ------------------------------------------
    //
    public IHMClient(String host,int port)
    {
        this.host=host;
        this.port=port;

// Creation du formulaire
        form = new Formulaire("CLIENT",this,400,200);
        
        //  Creation des elements de l'IHM
        //
        form.addText("CHAINE","Chaine",true,"");
        form.addButton("LISTER","Lister");
        form.addLabel("");

form.setPosition(200,0);
        form.addZoneText("RESULTATS","Resultats",
                            true,
                            "",
                            150,150);

// Affichage du formulaire
        form.afficher();
    }

// ------------------------------------------
    // Methode appellee quand on clique dans un bouton
    // ------------------------------------------
    //
    public void submit(Formulaire form,String nomSubmit)
    {
        try{
            // Lister
            //
            if (nomSubmit.equals("LISTER"))
                {
                    String chaine = form.getValeurChamp("CHAINE");
                    String res = requeteLister(chaine);
                    form.setValeurChamp("RESULTATS",res);
                }

}catch(Exception ex){form.setValeurChamp("RESULTATS","ERREUR : "+ex.getMessage());}

}

// --------------------------------------------------------------
    // REQUETE : LISTER_ELEMENTS
    //
    // Requete qui demande les elements du modele
    //
    // Retourne le resultat (chaine)
    //
    //   envoi   : LISTER_ELEMENTS (String UTF)
    //           : chaine (String UTF)
    //   recu    : resultat (String UTF)
    // ------------------------------------------
    //
    public String requeteLister(String chaine) throws Exception
    {
        Socket soc = new Socket(host,port);
        InputStream is = soc.getInputStream();
        OutputStream os = soc.getOutputStream();
        DataOutputStream dos = new DataOutputStream(os);
        DataInputStream dis = new DataInputStream(is);
        
        // Ecriture de la requete
        //
        dos.writeUTF("LISTER_ELEMENTS");
        dos.writeUTF(chaine);
        
        // Lecture de la reponse
        //
        String resultat = dis.readUTF();
        
        soc.close(); // C'est le client qui ferme le socket
        
        return resultat;
    }

}

IHMModele.java

package fr.cnam.projet;

import java.util.*;

import fr.cnam.ihm.*;

// Classe de definition de l'ihm du modele
//
public class IHMModele implements FormulaireInt
{
    private Modele     modele; // Le modele
    private Formulaire form;   // Le formulaire

// Constructeur
    //
    public IHMModele(Modele modele)
    {
        this.modele = modele;

// Creation du formulaire
        form = new Formulaire("Exemple",this,400,200);
        
        //  Creation des elements de l'IHM
        //
        form.addText("ELEMENT","Element",true,"");
        form.addButton("AJOUTER","Ajouter");
        form.addLabel("");
        form.addText("INFO","Info",false,"");

// Creation de la zone de resultat
        //
        form.setPosition(200,0);
        form.addZoneText("RESULTATS","Resultats",
                            true,
                            "",
                            150,150);

// Affichage de l'IHM
        //
        form.afficher();
    }

// Methode appellee quand on clique dans un bouton
    //
    public void submit(Formulaire form,String nomSubmit)
    {
        // Ajouter une chaine dans la liste des elements du modele
        //
        if (nomSubmit.equals("AJOUTER"))
            {
                modele.ajouter(form.getValeurChamp("ELEMENT"));
                form.setValeurChamp("RESULTATS",modele.lister());
            }
    }

// Methode qui met a jour l'ihm en fonction d'un message
    //  d'information provenant du client
    //
    public void setInfo(String chaine)
    {
        System.out.println("INFO: "+chaine);
        form.setValeurChamp("INFO",chaine);
    }
}

Modele.java

package fr.cnam.projet;

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

import fr.cnam.util.*;

// Classe de definition du modele
//
public class Modele
{
    private ArrayList<String> elements; // Une liste de chaine
    private String info;                // Un texte d'information
    private IHMModele ihm;              // L'IHM du modele

// Contructeur
    //
    public Modele()
    {
        // Creation de la liste
        elements = new ArrayList<String>();
        info = "";
    }

// Ajoute une chaine dans la liste
    //
    public void ajouter(String valeur)
    {
        elements.add(valeur);
    }

// Liste les elements
    //
    public String lister()
    {
        String res="";
        for(String e:elements)
            res=res+e+"\n";

return res;
    }

// Mise a jour de l'ihm du modele en fonction
    //  d'une chaine envoye par le client
    //
    public void setInfo(String chaine)
    {
        ihm.setInfo(chaine);
    }

// Pour faire connaitre l'IHM du modele au modele
    //
    public void setIhm(IHMModele ihm)
    {
        this.ihm=ihm;
    }

}

Projet.java
RequeteThread.java

package fr.cnam.projet;

import java.io.*;

// Classe de definition d'un thread qui prend en charge le traitement
//  d'une requete cliente.
//  
public class RequeteThread extends Thread
{
    String requete;
    DataInputStream dis;
    DataOutputStream dos;
    Modele modele;

// Constructeur
    //
    public RequeteThread(String requete,DataInputStream dis,DataOutputStream dos,
                         Modele modele)
    {
        this.requete=requete;
        this.dis=dis;
        this.dos=dos;
        this.modele=modele;
    }
    
    // Traitement de la requete en parralele des autres requetes clientes
    //
    public void run()
    {
        try{
            // --------------------------------------------------------------
            // REQUETE : LISTER_ELEMENTS
            //
            // Requete qui liste les elements su serveur
            //
            //
            //   recu   : (String UTF) chaine à afficher sur le serveur
            //
            //   envoye : (String UTF) les elements
            //
            if (requete.equals("LISTER_ELEMENTS"))
                {
                    String chaine = dis.readUTF();
                    System.out.println("CHAINE: "+chaine);
                    String resultat = modele.lister();
                    modele.setInfo(chaine);

dos.writeUTF(resultat);
                }
        }
        catch(Exception ex)
            {
                System.out.println("ERREUR REQUETE : "+requete);
                ex.printStackTrace();
            }
    }
}

ServeurSocketModele.java

package fr.cnam.projet;

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

// Classe de definition du serveur de socket qui prend
//  en entree le modele.
// Son role :
//    - recevoir des requetes
//    - en fonction de la requete appelle une methode du modele
//    - retourner le resultat
//
// Les syntaxes des requetes acceptees sont decrites ci-dessous.
//
public class ServeurSocketModele
{
    // Contructeur
    //   Le serveur de socket est execute dans le constructeur
    //   Il prend en entree le port de communication
    //   Il prend en entree le compte
    //
    public ServeurSocketModele(int port,Modele modele)
    {
        try{
            // Creation du serveur de socket
            //
            ServerSocket ssoc;
            ssoc = new ServerSocket(port);
            
            // Boucle sur l'acceptation d'un socket
            //
            while(true)
                {
                    // Attente d'acceptation d'un socket
                    //
                    System.out.println("En attente...");
                    Socket soc = ssoc.accept();
                    // Un socket a etabli une communication
                    System.out.println("Socket accepte");
                    
                    // Recuperation des flots de lecture et d'ecriture du socket
                    //
                    InputStream is = soc.getInputStream();
                    OutputStream os = soc.getOutputStream();
                    DataInputStream dis = new DataInputStream(is);
                    DataOutputStream dos = new DataOutputStream(os);
                    
                    // Lecture de l'entete de la requete
                    //
                    System.out.println("Lecture du socket");
                    String requete = (String)(dis.readUTF());
                    System.out.println("REQUETE: "+requete);

// Lancement d'un thread de traitement de la requete
                    // Ceci permet de traiter en parallele plusieurs requetes
                    //  provenant de clients differents
                    //
                    RequeteThread rt = new RequeteThread(requete,dis,dos,modele);
                    
                    rt.start();

}
        }catch(Exception ex){};
        
      }
}

tore
util

Cours d'Informatique par Jacques LAFORGUE

Retour

Télécharger

Cours d'Informatique
par Jacques LAFORGUE