Cours CNAM par J. Laforgue

ExempleCh08_04_InterfaceService2

Retour

Télécharger

Cet exemple a le même comportement que l'exemple ExempleCh05_02c_InterfaceService2 mais avec l'utilisation du DynamicProxy pour la création des stubs.
De plus au lieu de simuler un annuaire avec un fichier comme dans l'exemple précédent, ici la gestion d'un annuaire a été codé

      README.txt
      compil.bat
      runClient.bat
      runServer.bat
      src
         DVD.java
         DVDOD.java
         Ecole.java
         ExempleCh08_04.java
         Librairie.java
         Livre.java
         LivreOD.java
         Media.java
         MediaInt.java
         MediaODInt.java
         Organisme.java
         Server.java
         Service.java
         ServiceInt.java
         ServiceOD.java
         ServiceODInt.java
         fr
            cnam
               myrmi
                  MyLocateRegistry.java

package fr.cnam.myrmi;

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

public class MyLocateRegistry implements MyRegistry
{
  private ServerSocket ssoc;
  private Hashtable<String,MyRemote> elements;

public MyLocateRegistry(int port) throws Exception
  {
    elements = new Hashtable<String,MyRemote>();

try{
      ssoc = new ServerSocket(port);

Runnable runnable = new Runnable(){
          public void run(){
            try{
              while (true){
                System.out.println("MyLocateRegistry>Attente accept...");
                Socket soc = ssoc.accept();
                OutputStream os=soc.getOutputStream();
                ObjectOutputStream oos=new ObjectOutputStream(os);
                InputStream is=soc.getInputStream();
                ObjectInputStream ois=new ObjectInputStream(is);

String ope = (String)ois.readObject();
                if (ope.equals("lookup")){
                  System.out.println("MyLocateRegistry>lookup>debut: ");
                  String name = (String)ois.readObject();
                  MyRemote stub = elements.get(name);
                  oos.writeObject(stub);
                  System.out.println("MyLocateRegistry>lookup>fin: "+name);
                }
                if (ope.equals("rebind")){
                  String name = (String)ois.readObject();
                  MyRemote obj = (MyRemote)ois.readObject();
                  elements.put(name,obj);
                  oos.writeObject("OK");
                }
              }
            }catch(Exception ex){ex.printStackTrace();}
                        
                        
                        
          }};
      Thread t = new Thread(runnable);
      t.start();
            
    }catch(Exception ex){throw new Exception(ex.toString());}
  }

public static MyRegistry createRegistry(int port) throws Exception
  {
    return new MyLocateRegistry(port);
  }

public MyRemote lookup(String name)
  {
    System.out.println("lookup: "+name);
    return elements.get(name);
  }

public void rebind(String name, MyRemote obj)
  {
    System.out.println("rebind: "+name);
    elements.put(name,obj);
  }

}

MyNaming.java

package fr.cnam.myrmi;

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

public class MyNaming 
{
  public static MyRemote lookup(String name)
  {
    try{
      String[] splits = name.split("[:]");
      String host = splits[1].substring(2);
      String[] portEtNom = splits[2].split("[/]");
      int port = Integer.parseInt(portEtNom[0]);
      String nom = portEtNom[1];
      Socket soc =null;
      if (host.equals("localhost"))
        soc = new Socket(InetAddress.getLocalHost(),port);
      else
        soc = new Socket(InetAddress.getByName(host),port);

OutputStream os=soc.getOutputStream();
      ObjectOutputStream oos=new ObjectOutputStream(os);
      InputStream is=soc.getInputStream();
      ObjectInputStream ois=new ObjectInputStream(is);

oos.writeObject("lookup");
      oos.writeObject(nom);
      MyObjId objId = (MyObjId)(ois.readObject());
      soc.close();
      return (MyRemoteObject.toStub(objId));
    }catch(Exception ex){ex.printStackTrace();
      return null;}
  }

public static void rebind(String name, MyRemote obj)
  {
    try{
      String[] splits = name.split("[:]");
      String host = splits[1].substring(2);
      String[] portEtNom = splits[2].split("[/]");
      int port = Integer.parseInt(portEtNom[0]);
      String nom = portEtNom[1];

MyUnicastRemoteObject uro = (MyUnicastRemoteObject)(obj);

Socket soc = new Socket(host,port);

oos.writeObject("rebind");
      oos.writeObject(nom);
      oos.writeObject(uro.getObjId());
      String status = (String)(ois.readObject());
      soc.close();
    }catch(Exception ex){ex.printStackTrace();}
  }
}

MyObjId.java
MyRMIServerSocket.java

package fr.cnam.myrmi;

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

public class MyRMIServerSocket 
{
  private static Hashtable<Integer,MyRMIServerSocketThread> ssocs;
  private ArrayList<MyRemoteObject> skeltons;
  private static MyRMIServerSocket myssoc;

static public MyRMIServerSocket getInstance(int port)
  {
    if (myssoc==null)
      {
        myssoc = new MyRMIServerSocket();
        ssocs = new Hashtable<Integer,MyRMIServerSocketThread>();
      }

if (ssocs.get(port)==null)
      {
        MyRMIServerSocketThread s = new MyRMIServerSocketThread(port);
        ssocs.put(port,s);
      }
    
    return myssoc;
  }
  
  private  MyRMIServerSocket()
  {
    skeltons = new ArrayList<MyRemoteObject>();
  }
  
  synchronized public void addRemoteObject(MyRemoteObject sk)
  {
    System.out.println("Ajout d'un skelton: "+sk.getObjId().getHashCode());
    skeltons.add(sk);
  }

ArrayList<MyRemoteObject> getSkeltons()
  {
    return skeltons;
  }

}

class MyRMIServerSocketThread implements Runnable
{
  private ServerSocket ssoc;
  private int port;
    
  public MyRMIServerSocketThread(int port)
  {
    try{
      ssoc = new ServerSocket(port);
    }catch(Exception ex){ex.printStackTrace();}
    Thread t = new Thread(this);
    t.start();
  }
  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());
            
          MyRMIServerSocket server = MyRMIServerSocket.getInstance(port);
          MyRemoteObject skelton = null;
          for(MyRemoteObject sk : server.getSkeltons())
            if (sk.getObjId().getHashCode() == hashCodeRemote.intValue())
              skelton = sk;
                    
          if(skelton!=null)
            {
              System.out.println(">>invoke de "+methode);
                            
              Integer onbarg = (Integer)(ois.readObject());
              int nbarg = onbarg.intValue();
              if (nbarg!=0)
                {
                  Object[] args = (Object[])(ois.readObject());
                  Class<?>[] classes = new Class<?>[args.length];
                  int i=0;
                  for(Object o:args) classes[i++]=o.getClass();
                                    
                  Method m = skelton.getClass().getMethod(methode,classes);
                  Object rep = m.invoke(skelton,args);
                  if (rep==null)
                    oos.writeObject(new Integer(0));
                  else
                    oos.writeObject(rep);
                }
              else
                {
                  Method m = skelton.getClass().getMethod(methode);
                  Object rep = m.invoke(skelton);
                  if (rep==null)
                    oos.writeObject(new Integer(0));
                  else
                    oos.writeObject(rep);
                }
            }
          else
            {
              System.out.println("ERREUR: skelton non trouve: "+hashCodeRemote.intValue());
            }
        }
    }catch(Exception ex)
      {
        System.out.println("Erreur dans MyRMIServerSocketThread : run");
        System.out.println(ex);
        ex.printStackTrace();
      }
  }
}

                  MyRegistry.java
                  MyRemote.java
                  MyRemoteException.java
                  MyRemoteInvokerHandler.java

package fr.cnam.myrmi;

import java.lang.reflect.*;
import java.io.*;
import java.net.*;

public class MyRemoteInvokerHandler implements InvocationHandler, Serializable
{
    private int hashCode;
    private String host;
    private int port;

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

public Object invoke(Object proxy,
                         Method m,
                         Object[] args) throws Throwable
    {
        Socket soc;
        if (host.equals("localhost")) soc = new Socket(InetAddress.getLocalHost(),port);
        else soc = new Socket(InetAddress.getByName(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(m.getName());
        if (args==null) oos.writeObject(new Integer(0));
        else oos.writeObject(new Integer(args.length));
        oos.writeObject(args);

Object rep = ois.readObject();
        soc.close();
        
        return rep;
    }
}

MyRemoteObject.java

package fr.cnam.myrmi;

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

public abstract class MyRemoteObject implements MyRemote
{
  private MyObjId objId;

public MyRemoteObject(int port)
    {
      String host=null;
      try{host = InetAddress.getLocalHost().getHostName();}
      catch(Exception ex){};
      objId = new MyObjId(this.hashCode(),host,port,this.getClass().getInterfaces());
    }

public MyObjId getObjId(){return objId;}
  
  static MyRemote toStub(MyObjId objId)
  {
    return (MyRemote) java.lang.reflect.Proxy.newProxyInstance(objId.getClass().getClassLoader(),
                                                               objId.getInterfaces(),
                                                               new MyRemoteInvokerHandler(objId.getHashCode(),
                                                                                          objId.getHost(),
                                                                                          objId.getPort()) );
  }
}

MyUnicastRemoteObject.java

package fr.cnam.myrmi;

import java.lang.reflect.*;
import java.net.*;

public class MyUnicastRemoteObject extends MyRemoteObject 
{
  private int port;

public MyUnicastRemoteObject(int port)
  {
    super(port);
    this.port=port;
    exportObject();
  }

public MyRemoteObject exportObject()
  {
    MyRMIServerSocket.getInstance(port).addRemoteObject(this);
    return this;
  }

public MyRemote toStub()
  {
    Class<?>[] interfaces = this.getClass().getInterfaces();

Object proxy = java.lang.reflect.Proxy.newProxyInstance(this.getClass().getClassLoader(),
                                                            interfaces,
                                                            new MyRemoteInvokerHandler(getObjId().getHashCode(),
                                                                                       getObjId().getHost(),
                                                                                       getObjId().getPort()) );
    return ((MyRemote)proxy);
  }
}

Cours d'Informatique par Jacques LAFORGUE

Retour

Télécharger

Cours d'Informatique
par Jacques LAFORGUE