while(true){ 
         // accept a client's request for connecting to the Server 
         try{ 
            client_socket = server_socket.accept(); 
         }catch(IOException e){ 
            System.out.println("Accept failed: " +  ", " + e); 
            System.exit(1); 
         } 
         System.out.println("Connection established at : "  + client_socket.getInetAddress());         
     
         // create one thread for client request and  store it for interacting with the clients 
         id = clients.size(); 
         clients.insertElementAt(new MuDispatcher(client_socket, clients, id), id); 
         System.out.println(" id=" + id); 
      } 
   } 

       try {  
               socket = new Socket(HOST, Protocol.PORT); 
               in = new DataInputStream(socket.getInputStream()); 
               out = new DataOutputStream(socket.getOutputStream()); 
               id = in.readInt(); 
 
               // create a thread to wait for data from server 
               new Receiver(in, this);  
               connected = true; 
            } catch (UnknownHostException e) { 
               b.setDescription("Unknown host: " + HOST); 
               return; 
            } catch (Exception e) { 
               b.setDeDescription("Connection error"); 
               return; 
            }  

Dynamics of Collaboration

1) Session Communication : Send message to all Clients in a specific Session.
2) Peer : Send message to a specific Client in a certain Session.
3) List Client : List all the Clients who have registered interest in a certain Channel.
4) List Consumers : List all the Consumers on a certain Channel.

    Script {

     url "Java filename.class " 
     EVENTIN eventType eventName 
     EVENTOUT eventType eventName 
   } 

     try {
           /* Create a session, and publish it. */
 
            VRSession = new SharedData.socket.socketSession(sessionName);
	    Naming.rebind(url, VRSession);

         /* Get a client-side handle to the session and create a channel called
          *"VRChannel". The clients would be using the VRChannel handles to
          * pass information to various clients.. */

            VRSession = SessionFactory.createSession(url);
            VRSession.createChannel("VRChannel", true);
            System.out.println("Setup and bound VR server.");
        } catch (SharedDataException e) {
            System.out.println("VRServer: main: shared data exception: " + e);
	    }
        }

      for (int i=0; i < AVATARS; i++){ 
         try { 
            avatar = (Node)((SFNode)getField("avatar" + i)).getValue(); 
            avatarPosition[i] = (SFVec3f)avatar.getExposedField("translation"); 
            avatarRotation[i] = (SFRotation)avatar.getExposedField("rotation"); 
         } catch (Exception e) { 
            b.setDescription("can not get avatar"); 
            return; 
         } 
      } 

    public synchronized void
    dataReceived(Data data) {
        String  message;
        int     position   = 0;
	int     priority   = data.getPriority();
	String  senderName = data.getSenderName();
        Channel channel    = data.getChannel();
        byte[]  theData    = data.getData();

        message = new String(theData, 0);
        vrUser.commandLine = message;
        vrUser.performUpdate();

    }

        String sessionType = "socket";

	try {
	    String sessionName = "VRSession";

            /* Create a VR client. */

            client = new VRClient(name);

            /* Resolve the VR session. */

	    try {
                String url = "coll://" + hostname + ":" + hostport +
			     "/" + sessionType + "/Session/" + sessionName;

		session = SessionFactory.createSession(url);

           /*  Join the session,channel set the channels data consumer. */


		session.join(client);
		channel = Channel.join(session, "VRChannel", client); 
		VRConsumer = new VRConsumer(client.getName(), this);
		channel.setConsumer(client, VRConsumer);
            } catch (Exception e) {
		    return(false);
            }
        } catch (Throwable th) {
	 return(true);
     }

 
   public void updatePosition(int id, float x, float y, float z){  
      System.out.println("Avatar" + id +"on the move ....");
      avatarPosition[id].setValue(x, y, z); 
   } 
 
   public void updateOrientation(int id, float x, float y, float z, float r){ 
      avatarRotation[id].setValue(x, y, z, r); 
   } 

   public void performUpdate() {
     StringTokenizer tok;
     
            if(MuProtocol.MOVE == command){
	      updatePosition(idOfMove, x, y, z); // update position 
	    }else{
	       r = Float.valueOf(tok.nextToken()).floatValue();
	      updateOrientation(id, x, y, z, r); // update orientation
	    }
       }
    }

Conclusions

References
[1] . Towards Web/Java based High Performance Distributed Computing - an Evolving Virtual Machine by Geoffrey Fox and Wojtek Furmanski, HPDC-5 Invited Talk, August '96.
[2]. Comparison Of Collaboration Environments by Shrideep Pallickara, Vishal Mehra, Wojtek Furmanski, Geoffrey Fox.