Source code: com/telefonicasoluciones/search/server/HLServer.java

   package com.telefonicasoluciones.search.server;
   
   
   
   import java.io.*;
   
   import java.net.*;
   
   
  
  public class HLServer {
  
    private HLThreadFIFO idleWorkers;
  
          private static final int DEFAULT_PORT = 8421;
  
    private HLWorker[] workers;
  
    private ServerSocket ss;
  
          private static File config;
  
    private Thread internalThread;
  
    private volatile boolean noStopRequested;
  
  
  
    public HLServer(int port, int numberOfWorkers) throws IOException {
  
      if (port == 0) port = DEFAULT_PORT;
  
                  HLHandler hlh = null;
  
                  try {
  
                      hlh = new HLHandler(new HLConfig(config.getCanonicalPath()));
  
                  } catch(IOException _ex) {
  
                      System.out.println("Config file not found ("+config.getAbsolutePath()+")");
  
                      System.exit(1);
  
                  } catch(HLConfigException _ex) {
  
                      System.out.println("Config file not found ("+config.getAbsolutePath()+")");
  
                      System.exit(1);
  
                  } catch(Exception _ex) {
  
                      System.out.println("Config file not found ("+config.getAbsolutePath()+")");
  
                      System.exit(1);
  
                  }
  
                  /* Permite un máximo de 10 sockets 
  
                   * en cola.
  
                   */
  
      ss = new ServerSocket(port, 10); 
  
      numberOfWorkers = Math.max(1, numberOfWorkers);
  
      idleWorkers = new HLThreadFIFO(numberOfWorkers);
  
      workers = new HLWorker[numberOfWorkers];
  
      for (int i=numberOfWorkers; --i>=0; ) {
  
                      /* 
  
                       * Cada worker tiene una referencia a FIFO
  
                       * podrá añadirse a sí mismo cuando esté listo 
  
                       * para gestionar una petición.
  
                       */
  
                      workers[i] = new HLWorker(idleWorkers, hlh);
  
      }
  
      noStopRequested = true;
  
      Runnable r = new Runnable() {
  
                      public void run() {
  
                          try {
  
                              runWork();
  
                          } catch (Exception _ex) {
 
                             _ex.printStackTrace(); 
 
                         }
 
                     }
 
                 };
 
     internalThread = new Thread(r);
 
     internalThread.start();
 
   }
 
 
 
   private void runWork() {
 
             System.out.println("\r\nARTLIGHT 1.4 Server\r\n");
 
             try {
 
                 System.out.println("Config file: "+config.getCanonicalPath());
 
             } catch(IOException _ex) {}
 
             System.out.println("Total Memory: "+Runtime.getRuntime().totalMemory());
 
             System.out.println("Free Memory: "+Runtime.getRuntime().freeMemory());
 
             while (noStopRequested) {
 
                 try {
 
                     Socket s = ss.accept();
 
                     if (idleWorkers.isEmpty()) {
 
                         BufferedWriter writer = 
 
                                 new BufferedWriter(
 
                                         new OutputStreamWriter(
 
                                                 s.getOutputStream()));
 
                         writer.write("Artlight1.4 server is too busy\r\n");
 
                         writer.flush();
 
                         writer.close();
 
                         writer = null;
 
                     } else {
 
                         HLWorker worker = (HLWorker) idleWorkers.remove();
 
                         worker.processRequest(s);
 
                     }
 
                 } catch (IOException _ex) {
 
                     if (noStopRequested) {
 
                         _ex.printStackTrace();
 
                     }
 
                 } catch (InterruptedException _ex) {
 
                     Thread.currentThread().interrupt(); 
 
                 }
 
             }
 
             if(ss!=null) {
 
                 try { ss.close(); } catch (IOException _ex) {}
 
                 ss = null;
 
             }
 
         }
 
   public void stopRequest() {
 
             noStopRequested = false;
 
             internalThread.interrupt();
 
             for(int i=workers.length; --i>=0; ) {
 
                 workers[i].stopRequest();
 
             }
 
   }
 
   public boolean isAlive() {
 
             return internalThread.isAlive();
 
   }
 
   public static void main(String[] args) {
 
             int port = 0;  
 
             int workers = 10;
 
             for(int i=0; i<args.length; i++) {
 
                 if(args[i].indexOf("port")!=-1) {
 
                     try { 
 
                         port = Integer.parseInt(args[i].substring(args[i].indexOf("=")+1,args[i].length())); 
 
                     } catch (NumberFormatException e) {}
 
                 } else if(args[i].indexOf("config-file")!=-1) {
 
                     config = new File(args[i].substring(args[i].indexOf("=")+1,args[i].length()));
 
                     if(!config.exists()) { 
 
                         System.out.println("\r\nConfiguration file not found ("+config.getAbsolutePath()+")");
 
                         break;
 
                     }
 
                 } else if(args[i].indexOf("workers")!=-1) {
 
                     try { 
 
                         workers = Integer.parseInt(args[i].substring(args[i].indexOf("=")+1,args[i].length())); 
 
                     } catch (NumberFormatException _ex) {}
 
                 } else if(args[i].equals("start")) {
 
                     try {
 
                         new HLServer(port,workers);
 
                     } catch (IOException _ex) {
 
                         _ex.printStackTrace(System.out);
 
                     }
 
                 } else if(args[i].equals("stop")) {
 
                     // nothing yet
 
                 }
 
             }
 
   }
 
 }