---

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.SessionIdentifier;
import org.objectweb.jonathan.apis.resources.Job;
import org.objectweb.jonathan.apis.protocols.ip.TcpIpConnectionMgr;
import org.objectweb.jonathan.libs.resources.JScheduler;
import org.objectweb.jonathan.libs.resources.JChunkFactory;
import org.objectweb.jonathan.libs.resources.JChunkFactoryFactory;
import org.objectweb.jonathan.libs.resources.JSchedulerFactory;
import org.objectweb.jonathan.libs.resources.tcpip.JConnectionMgr;
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 SharedServerSession implements Session_Low {

    SharedServerSession() {
    }

    static MarshallerFactory marshaller_factory;
    private int counter; // internal state of session
    private Object lock = new Object();

    public void send(JonathanException e,Session_High session) {
         System.out.println("Exception received.");
         e.printStackTrace();
    }
        
    public void send(UnMarshaller unmarshaller, Session_High sender) {
         try {
            String theOutput = null;
            String theInput = unmarshaller.readString8();
            synchronized (lock) {
                   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();
         }
    }
}

public class Server {
    public static void main (String[] args) {
         try {
            int port = 0;
            if (args.length != 0) {
                port = Integer.parseInt(args [0]);
            }
            Context context =  Kernel.newConfiguration(Server.class);
            JScheduler scheduler = 
                (JScheduler) context.getValue("/jonathan/JScheduler/instance",'/');
            JChunkFactory cf = 
                (JChunkFactory) context.getValue("/jonathan/JChunkFactory/instance",'/');
            MarshallerFactory marshaller_factory =
                        new CDRMarshallerFactory(cf);
            SharedServerSession.marshaller_factory = marshaller_factory;
            TcpIpConnectionMgr connection_mgr = 
                (TcpIpConnectionMgr) context.getValue("/jonathan/JConnectionMgr/instance",'/');
            TcpIpProtocol protocol = 
                        new TcpIpProtocol(context, connection_mgr, scheduler,cf,marshaller_factory);
          
            // creating and exporting new session
            SessionIdentifier session_id = 
                        protocol.newProtocolGraph(port).export(new SharedServerSession());

            // waiting for client connection
            System.out.println("Server ready");
            Object lock = new Object();
            synchronized (lock) {
                lock.wait();
            }
         } catch (Exception e) {
            e.printStackTrace();
         }
    }
}

---