package test;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class server {
	public static void main(String[] a)
	{
		
		try {
			ServerSocket srv=new ServerSocket(5555);
			while(true)
			{
				Socket s=srv.accept();
				new SRVSocket(s);
				
			}
			
			
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		
	}

}



package test;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.net.Socket;

public class SRVSocket extends Thread {
	
	BufferedInputStream bin;
	BufferedOutputStream bout;
	Socket sc;
	public SRVSocket(Socket sc)
	{
		this.sc=sc;
		try {
			this.bin=new BufferedInputStream(sc.getInputStream());
			this.bout=new BufferedOutputStream(sc.getOutputStream());
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		this.start();
	}
  public void run()
  {
	  try{
	  while(true)
	  {
		 // System.out.println(" "+this.sc.isConnected());
		  
		  if(bin.available()>0)
		  {
			  byte[] f=new byte[bin.available()];
			  bin.read(f);
			  System.out.println(new String(f)+" "+this.sc.isConnected());
			  bout.write(f);
			  bout.flush();
		  }
		   
		  
	  }
	  }catch(Exception ex){System.out.println(ex.toString());}
	  
	  
  }
}