---

Client.java

Go to the documentation of this file.

import java.io.*;

import org.objectweb.jonathan.apis.kernel.Kernel;
import org.objectweb.jonathan.apis.kernel.Context;
import org.objectweb.jonathan.apis.kernel.JonathanException;
import org.objectweb.jonathan.apis.presentation.Marshaller;
import org.objectweb.jonathan.apis.presentation.UnMarshaller;
import org.objectweb.jonathan.apis.presentation.MarshallerFactory;
import org.objectweb.jonathan.apis.protocols.Session_High;
import org.objectweb.jonathan.apis.protocols.Session_Low;
import org.objectweb.jonathan.apis.protocols.ip.IpSessionIdentifier;
import org.objectweb.jonathan.apis.protocols.ip.TcpIpConnectionMgr;

import org.objectweb.jonathan.libs.resources.JScheduler;
import org.objectweb.jonathan.libs.resources.JSchedulerFactory;
import org.objectweb.jonathan.libs.resources.JChunkFactory;
import org.objectweb.jonathan.libs.resources.JChunkFactoryFactory;
import org.objectweb.jonathan.libs.resources.tcpip.JConnectionMgr;
import org.objectweb.jonathan.libs.protocols.tcpip.TcpIpProtocol;

import org.objectweb.david.libs.presentation.portable.CDRMarshallerFactory;

/*
 * This class implements the program of a client of the Echo service.
 * The client sends an input string and gets that string back, together
 * with the value of a counter maintained by the server and incremented
 * at each call. The value of this counter is shared between the clients.
 */
 
class ClientSession implements Session_Low {
   static MarshallerFactory marshaller_factory;
   
   BufferedReader reader;
   
   ClientSession(BufferedReader reader) {
      this.reader = reader;
   }

   public void send(JonathanException e,Session_High session) {
      System.out.println("Exception received.");
      e.printStackTrace();
   }

   public  void send(UnMarshaller unmarshaller,Session_High session) {
      try {
         String fromServer,input;

         System.out.print("Client: ");
         System.out.flush();
         input = reader.readLine();
         Marshaller marshaller = marshaller_factory.newMarshaller();
         session.prepare(marshaller);
         marshaller.writeString8(input);
         session.send(marshaller);
         if (input.equalsIgnoreCase("quit")) {
             session.close();
             System.exit(0);
         }
         fromServer = unmarshaller.readString8();
         unmarshaller.close();
         System.out.println("Server: " + fromServer);
      } catch (Exception e) {
         e.printStackTrace();
         session.close();
      }
   }
}

public class Client {
   public static void main (String[] args) {
      try {
         BufferedReader reader =
            new BufferedReader(new InputStreamReader(System.in),1);
         System.out.print("Host ? ");
         System.out.flush();
         String host = reader.readLine(); 
         if (host.equals("")) {
             host = "localhost"; // defaults to local host
         }
         System.out.print("Port number ? ");
         System.out.flush();
         int port = Integer.parseInt(reader.readLine());

     // Initializing factories
         Context context = Kernel.newConfiguration(Client.class);
         JScheduler scheduler = 
             (JScheduler) context.getValue("/jonathan/JScheduler/instance",'/');
         JChunkFactory cf = 
             (JChunkFactory) context.getValue("/jonathan/JChunkFactory/instance",'/');
         CDRMarshallerFactory marshaller_factory =
            new CDRMarshallerFactory(cf);
         ClientSession.marshaller_factory = marshaller_factory;
        
     // Initializing TCP/IP protocol
     TcpIpConnectionMgr connection_mgr = (TcpIpConnectionMgr)
            context.getValue("/jonathan/JConnectionMgr/instance",'/');
         TcpIpProtocol protocol =
             new TcpIpProtocol(context, connection_mgr,
                               scheduler,cf,marshaller_factory);

         // preparing parameters for server connection
         IpSessionIdentifier participant = 
             protocol.newSessionIdentifier(host,port);

         // creating client-side session and connecting to server
         Session_High session = participant.bind(new ClientSession(reader));

         Object lock = new Object();
         synchronized (lock) {
            lock.wait();
         }
      } catch (Exception e) {
         e.printStackTrace();
      }
   }
}

---