RiverRat  - An MIT iCampus project

http://web.mit.edu/riverrat/

Server.java

package riverrat;

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

public class Server {
        protected static int port = 8080;

        protected static int numthreads = 5;
        
        protected static Vector threads;
        
        protected static ServerSocket serverSocket;
        
        public static void printAvailableServerTypes() {
                String[] servers = new String[5];
                servers[0] = "riverrat.LiveServer";
                servers[1] = "riverrat.PlaybackServer";
                servers[2] = "riverrat.testing.XMLFakeServer";
                servers[3] = "riverrat.testing.NMEAFakeServer";
                
                for (int i = 0; i < servers.length; i++) {
                        if(servers[i] != null) {
                                try {
                                        Class testclass = Class.forName(servers[i]);
                                        System.out.println(servers[i]+" is available.");
                                } catch(ClassNotFoundException e) {
                                }
                        }
                }
        }
        
        public static void printUsage() {
                System.out.println("`Server' is a server for the RiverRat project.");
                System.out.println("usage: java riverrat.Server [OPTIONS] SERVERTYPE [OPTIONS]");
                System.out.println("");
                System.out.println("Options:");
                System.out.println("  -h, --help\t\t\tPrint this message and exit.");
                System.out.println("  -p, --port PORT\t\tUse server port PORT.");
                System.out.println("");
                System.out.println("Available server types are: ");
                printAvailableServerTypes();
                System.out.println("");
                System.out.println("Author: Scott Torborg 2004");
                System.out.println("RiverRat Project http://mit.edu/riverrat");
                System.exit(1);
        }
                
        public static void main(String args[]) {
                int n = args.length;
                String serverType = null;
                Class serverclass = null;
                
                if(n == 0) printUsage();
                
                int serverPort = 8080;
                for(int i = 0; i < n; i++) {
                        String s = args[i].toLowerCase();
                        if (s.equals("--help") || s.equals("-h")) {
                                printUsage();
                        } else if(s.equals("--port") || s.equals("-p")) {
                                if(i+1 >= n) printUsage();
                                i++;
                                try {
                                        port = Integer.parseInt(args[i]);
                                } catch(NumberFormatException e) {
                                        System.err.println("Bad TCP port number.");
                                        System.exit(1);
                                }
                                if(i+1 >= n) printUsage();
                                i++;
                        }
                        try {
                                serverclass = Class.forName(args[i]);
                        } catch(ClassNotFoundException e) {
                                System.err.println("Bad server class.");
                                System.exit(1);
                        }
                }
                
                try {
                        BasicServer server = (BasicServer) serverclass.newInstance();
                } catch(IllegalAccessException e) {
                        System.err.println("Server class could not be accessed.");
                        System.exit(1);
                } catch(InstantiationException e) {
                        System.err.println("Server class could not be instantiated.");
                        System.exit(1);
                } catch(ClassCastException e) {
                        System.err.println("Server class must be a BasicServer subclass.");
                        System.exit(1);
                }
                
                threads = new Vector();
                try {
                        serverSocket = new ServerSocket(port);
                        System.out.println("Listening on port "+port);
                } catch(IOException e) {
                        System.err.println("Could not listen on: "+port);
                        System.exit(1);
                }
                
                while(true) {
                        try {
                                Socket s = serverSocket.accept();
                                BasicServer bs = null;
                                try {
                                        bs = (BasicServer) serverclass.newInstance();
                                } catch(IllegalAccessException e) {
                                        System.err.println("Could not access server class.");
                                        System.exit(1);
                                } catch(InstantiationException e) {
                                        System.err.println("Could not instantiate server class.");
                                        System.exit(1);
                                }
                                bs.setSocket(s);
                                (new Thread(bs)).start();
                                threads.addElement(bs);
                        } catch(IOException e) {
                                System.err.println("Error accepting socket.");
                        }
                        if (threads.size() > 5) {
                                System.err.println("Too many threads, not opening any more.");
                                break;
                        }
                }
        }
}

 

Brought to you by the RiverRat team.