restarting and stopping serversocket running on port

[Ponnusamy Gov]

Dear All,

I have a client server methodology in which I am using java ServerSocket connection to act as a server which will always looking for client request. This server will be running in a specified port like 4444, 4445,etc..,. I don't know how to stop that server because I am unable to take the ServerSocket instance running on port. So to achieve server stopping, I used to kill the process abruptly but this is not a proper way of stopping the server the server since my server is handling N number client requests concurrently and middle of the process if I kill this, tasks which is being handled by all the threads will go off. I am using ArrayBlockingQueue for queuing up the client requests. currently I am having 100 of Max thread pool size. Can any one help me out regarding this?

Sample piece of code:

to start the server :

public static void main(String[] args) {
		String command=args[0];
		if("start".equals(command)){
		ThreadPooledServer server = new ThreadPooledServer(4444);
		new Thread(server).start();
		}
		
		try {
		    Thread.sleep(20 * 1000);
		    Runtime runtime = Runtime.getRuntime();
		    int nrOfProcessors = runtime.availableProcessors();
		    System.out.println("nrOfProcessors  " + nrOfProcessors);
		} catch (InterruptedException e) {
		    e.printStackTrace();
		}
		

	}

Server code:

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;




public class ThreadPooledServer implements Runnable{

	RejectedExecutionHandler executionHandler = new MyRejectedExecutionHandelerImpl(); 
    protected int          serverPort ;
    protected ServerSocket serverSocket = null;
    protected Thread       runningThread= null;
  
protected ApplicationContextLoader applicationContext=null;
     ThreadPoolExecutor threadPool = null;
    
    final ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(
            5);
 
    public ThreadPooledServer(int port)
    {
    	this.serverPort = port;
        threadPool = new ThreadPoolExecutor(4, 100,
                10, TimeUnit.SECONDS, queue,executionHandler);
 
    }
   public void run(){
        synchronized(this){
            this.runningThread = Thread.currentThread();
        }
        openServerSocket();

        while(! isStopped()){
            Socket clientSocket = null;
            try {
                clientSocket = this.serverSocket.accept();
            } catch (IOException e) {
                if(isStopped()) {
                    System.out.println("Server Stopped.") ;
                    return;
                }
                throw new RuntimeException(
                    "Error accepting client connection", e);
            }
            this.threadPool.execute(//executing the business classes here
               );
         
        }
       
    }
   


    private void openServerSocket() {
        try {
            this.serverSocket = new ServerSocket(this.serverPort);
        } catch (IOException e) {
            throw new RuntimeException("Cannot open port "+this.serverPort, e);
        }
    }
    
 

Please help me to stop the server by giving running port number. My applicaiton is running in sun solaris server.

Thanks in advance,

Pons.