---

Server.java

Go to the documentation of this file.

import java.util.*;

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.TcpIpConnectionMgr;
import org.objectweb.jonathan.apis.resources.Scheduler;
import org.objectweb.jonathan.apis.resources.ChunkFactory;

import org.objectweb.jonathan.libs.resources.JSchedulerFactory;
import org.objectweb.jonathan.libs.resources.JChunkFactoryFactory;
import org.objectweb.jonathan.libs.resources.tcpip.JConnectionMgrFactory;
import org.objectweb.jonathan.libs.protocols.tcpip.TcpIpProtocol;

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

class OwnSession {
   private int counter = 0;
   SrvProtocol protocol;
   static MarshallerFactory marshaller_factory;
   
   OwnSession(SrvProtocol protocol) {
      this.protocol = protocol;
   }
   
   synchronized void send(UnMarshaller unmarshaller, Session_High sender) {
         try {
            String theOutput = null;
            String theInput = unmarshaller.readString8();
            counter++;
            if (theInput.equalsIgnoreCase("quit")) {
                System.out.println("client closing session");
                sender.close ();
                return;
            } else {
                theOutput = counter + ": " + theInput;
            }
            unmarshaller.close();
            Marshaller marshaller = marshaller_factory.newMarshaller();
            sender.prepare(marshaller);
            marshaller.writeString8(theOutput);
            sender.send(marshaller);
         } catch (JonathanException e) {
                System.out.println("EXCEPTION");
                e.printStackTrace();
         }
    }  
}

class SrvProtocol implements Session_Low {
   Hashtable own_sessions;
   
   SrvProtocol() {
      own_sessions = new Hashtable();
   }

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

   public void send(UnMarshaller message, Session_High sender) {
      OwnSession session = null;
      synchronized (this) {
         session = (OwnSession) own_sessions.get(sender);
         if (session == null) { // new client, unknown up to now
                                // create session for this client
             session = new OwnSession(this); 
             own_sessions.put(sender,session);
         }
      }
      // forward the message to the session associated with client
      session.send(message,sender);
   }

   void unregister(Session_High sender) {
      own_sessions.remove(sender);
   }
}


public class Server {
   public static void main (String[] args) {
      try {
         Context kernel_context = Kernel.newConfiguration(Server.class);
         ChunkFactory cf = (ChunkFactory)
            kernel_context.getValue("/jonathan/JChunkFactory/instance",'/');
         Scheduler scheduler = (Scheduler) 
             kernel_context.getValue("/jonathan/JScheduler/instance",'/');
         MarshallerFactory marshaller_factory =
            new CDRMarshallerFactory(cf);
         OwnSession.marshaller_factory = marshaller_factory;
         TcpIpConnectionMgr connection_mgr = (TcpIpConnectionMgr)
            kernel_context.getValue("/jonathan/JConnectionMgr/instance",'/');
         TcpIpProtocol protocol =
            new TcpIpProtocol(kernel_context,connection_mgr,
                              scheduler,cf,marshaller_factory);
         protocol.newProtocolGraph().export(new SrvProtocol());
         Object lock = new Object();
         synchronized (lock) {
            lock.wait();
         }
      } catch (Exception e) {
         e.printStackTrace();
      }
   }
}

---