import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.ArrayList;

import java.util.concurrent.atomic.AtomicInteger;

/*

* Main server class. This class includes main(), and is the class that listens

* for incoming connections and starts ServerThreads to handle those connections

*

*/

public class Server {

/**

* @param args

*/

public static void main(String[] args) {

AtomicInteger numThreads = new AtomicInteger(0);

// the list of threads is kept in a linked list

ArrayList<Thread> list = new ArrayList<Thread>();

try {

// listen for incoming connections on port 15432

ServerSocket socket = new ServerSocket(15432);

System.out.println("Server listening on port 15432");

// loop (forever) until program is stopped

while(true) {

// accept a new connection

Socket client = socket.accept();

// start a new ServerThread to handle the connection and send

// output to the client

Thread thrd = new Thread(new ServerThread(client));

list.add(thrd);

thrd.start();

numThreads.incrementAndGet();

System.out.println("Thread " + numThreads.get() + " started.");

}

}

catch (IOException ioe){

ioe.printStackTrace();

}

}

}