public   class  SocketReceiver  extends  Thread{
//после создания этого класса, нужно не забыть вызвать метод start
//наследуемый от класса Thread
     private  ServerSocket ss;
   
    
    /** Creates a new instance of SocketReceiver */
     public  SocketReceiver() {
         super ("SocketReceiver");
       
        port= somePort;
         try {
            ss= new  ServerSocket(port);
        } catch (Exception e){
            logger.fatal("Can't create socket.",e);
            System.exit(- 1 );
        }
    }
    
     public   void  run(){
         while (true){
             try {
                Socket clientSocket=ss.accept();
                Receiver reisiver= new  Receiver(clientSocket);
                reisiver.start();
            } catch (Exception e){
                logger.fatal("",e);
            }
        }
    }
    
}


 public   class  Receiver  extends  Thread{
    
     private  Logger logger = LogManager.getLogger ( this .getClass ());

     private  Socket sock;
    
    /** Creates a new instance of Reisiver */
     public  Receiver(Socket sock) {
         this .sock = sock
    }
    
     public   void  run(){
       
        logger.debug("Waiting data ...");
         try {
            //this.sock.setSoTimeout(5000);
            PrintWriter out= new  PrintWriter(
                     new  OutputStreamWriter(sock.getOutputStream(),encodingResponse));
            BufferedReader in= new  BufferedReader(
                     new  InputStreamReader(sock.getInputStream(),encodingReceive));
        
           //вот тут собственно мы и оказываемся, когда приходят данные из сокета.
           //далее может быть два варианта, либо ты вызываешь например метод drawGraph, 
           //который рисует крафмки, либо записываешь данные в какой нить общий буфер,
           //но тогда, должен быть запущен еще один поток, который читает через определенное 
           //время буфер и вызывает все тот же метод drawGraph.
            
            logger.debug("Closing connection with coupling module...");
//            in.close();
//            out.close();
//            sock.close();
            logger.debug("Connection closed.");
        } catch (Exception e){
            logger.error(e);
        }
        
    }
    
    
    
   
}