botlistprojects/botspider/spider/lib/java/spider_remote/src/org/spirit/loadtest/LoadTestServer.java

   1 /*
   2  * Created on Jul 18, 2007
   3  */
   4 package org.spirit.loadtest;
   5
   6 import java.io.IOException;
   7 import java.net.ServerSocket;
   8 import java.net.Socket;
   9
  10 /**
  11  * Simple Test Server
  12  */
  13 public class LoadTestServer {
  14         public static final int DEFAULT_PORT = 9999;
  15
  16         private int port = 9999;
  17         private ServerSocket server;
  18
  19         public LoadTestServer(int port) {
  20                 this.port = port;
  21         }
  22         public void runServer() {
  23                 try {
  24                         server = new ServerSocket(this.port);
  25                         System.out.println("server bound to port=" + this.port);
  26                 } catch (IOException e) {
  27                         System.out.println("Could not listen on port=" + this.port);
  28                         System.exit(-1);
  29                 }
  30                 try {
  31                         while (true) {
  32                                 LoadTestServerThread clientThread;
  33                                 try {
  34                                         // server.accept returns a client connection
  35                                         System.out.println("waiting for client connection...");
  36                                         Socket clientSocket = server.accept();
  37                                         if  (clientSocket == null) {
  38                                                 System.out.println("ERROR: invalid socket connection, closing.");
  39                                                 return;
  40                                         } else {
  41                                                 System.out.println("connection made=" + clientSocket);
  42                                         }
  43                                         clientThread = new LoadTestServerThread(clientSocket);
  44                                         Thread t = new Thread(clientThread);
  45                                         t.start();
  46                                 } catch (IOException e) {
  47                                         System.out.println("Accept failed: " + this.port);
  48                                         System.exit(-1);
  49                                 }
  50                         } // End of While
  51                 } finally {
  52                         try {
  53                                 System.out.println("Closing server connection");
  54                                 server.close();
  55                         } catch (IOException e1) { }
  56                 }
  57         }
  58
  59         public static void main(String[] args) {
  60                 System.out.println("-- Running Server");
  61                 LoadTestServer server = new LoadTestServer(DEFAULT_PORT);
  62                 server.runServer();
  63                 System.out.println("-- Done");
  64
  65         }
  66
  67 }
  68 //End of File