Public class TCP_Concurrent_Server
{
ServerSocket masterSock;
Int port = 1024+7;
Socket slave;
Boolean first;
Public static void main(String[] args)
{
Try
{
	MasterSock = new ServerSocket(port);
	While(true)
	{
		Slave = masterSock.acccept();
		Thread slaveT = new SlaveProcess(slave);
		slaveT.start();
	}
}
Catch(Exception e)
{
	System.out.println(“Error: “ + e);
}
}
Public SlaveProcess extends Threads
{
	Socket slaveS;
	Public SlaveProcess(Socket islaveS)
	{
		Super();
		slaveS = islaveS;
	}
}
Public void run
{
	Try
	{
		Char databuffer[] = new char[100];
		InputStreamReader isr = new InputStreamReader(slaveS.GetInputStream());
		PrintStream outs = new PrintStream(slaveS.GetOutputStream());
		While(!slaveS.isClosed())
		{
			Int len = isr.read(databuffer, 0, databuffer.length);
			String message = new String(databuffer);
			String recvcode = message;
			System.out.println(recvcode);
		}
	}
	Catch(Exception e)
	{
		System.out,.println(“Error: “ + e);
	}
}
}

MultiService
Try
{
	ServSock = new Socket(“1047”);
	While(true)
	{
		CliSock  = ServSock.accept();
		BufferedInputStream inps = new BufferedInputStream(CliSock.GetInputStream());
		InputStreamReader isr = new InputStreamReader(inps, “US-ASCII”));
		Char c = (char)isr.read();
		Int loop = 0;
		While(c!=(char)13);
		{
			If(c == “=”)
			{
				String number = “”;
				While (c!= “,”)
				{
					If(c==””)
					{}
					Else
					{
						Number = number + c;
					}
					Data[loop][1] = number;
					Loop++;
				}
			}
		}
	BufferedOutputStream outs= new BufferedOutputStream(CliSock.GetOutputStream());
		OutputStreamWriter osw = new OutputStreamWriter(outs, “US-ASCII”);
		Osw.write(updated, 0, 7);

}
}
Public class TCP_Client
{
	Public Static void main(String[] args)
	{
	Try
	{
	InetAddress address = InetAddress.GetByName(“127.0.0.1”);
	Socket CliSock = new Socket(address);
	PrintStream outs = new PrintStream(CliSock.GetOutputStream());
	BufferedInputStream inps = new BufferedInputStream(CliSock.GetInputStream());
	Outs.print(“message”);
	Inps.write(“received code”);
	}
	Catch (Exception e)
	{
	 System.out.println(“Error:” + e);
	}
	}
}

Public class TCP_Server
{
Public static void main(String[] args)
{
	String data_array[][] = new String [6][2];
	Socket ServSock = null;
	Try
	{
	ServSock = new Socket (“1045”);
	      While(true)
	      {
	   Socket CliSock = ServSock.accept();
	    BufferedInputStream inps = new BufferedInputStream(CliSock.getInputStream());
	    InputStreamReader isr = new InputStreamReader(inps, “US-ASCII”);
	    //decode by country with isr.read();
	    BufferedOutputStream outs = new BufferedOuputStream(CliSock.getOutputStream());
	    OuputStreamWriter osw = new OutputStreamWriter(outs, “US-ASCII”);
	     Osw.write(result, 0, result.length);
	      }
	}
	Catch(Exception e)
	{
		System.out.println(“Error: “ + e);
	}
}
}