C#

try
{
	Thread trStartListening = new Thread(new ThreadStart(ListenThread));
	trStartListening.Name = "Thread_tcp_Listen_" + addTcp.PortNo.ToString();
	trStartListening.IsBackground = true;
	trStartListening.Start();
}
catch(Exception e)
{
	OnSocketError(e.Message);
}

IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Any, addTcp.PortNo);
// Establish the local endpoint for the socket.
TcpListener server = new TcpListener(localEndPoint);
try
{
	server.Start();
	while (!ShuttingDown)
	{		
		TcpClient client = server.AcceptTcpClient();
		// Buffer for reading data
		byte[] bytes = new Byte[256];
		string data = null;
		// Get a stream object for reading and writing
		NetworkStream stream = client.GetStream();
		lock(this)
		{
			int i;
			// Loop to receive all the data sent by the client.
			while((i = stream.Read(bytes, 0, bytes.Length))!=0) 
			{   
				....//relative code
			}
		}
	}

	server.Stop();
}
catch (Exception e)
{
	OnSocketError(e.Message);
}

try 
{
	curXmt = TransmittDir;
 	string Conn = CDS.GetConnectionString(curXmt);
	int port = 13000;
	string Ip = "";
	ParseConnectionString(Conn,ref Ip,ref port);
	Sendingip = Conn;
	TcpClient client = new TcpClient(Ip, port);
	
	string Message = CDS.GetMessage();
	byte[] data = System.Text.Encoding.ASCII.GetBytes(Message);         
	// Get a client stream for reading and writing.	
	NetworkStream stream = client.GetStream();
	
	// Send the message to the connected TcpServer. 
	stream.Write(data, 0, data.Length);
	
	// Close everything.
	client.Close();         
} 
catch (ArgumentNullException e) 
{
	.....	
} 
catch (SocketException e) 
{
	.....
}

public void UnIntialize()
{
	ShuttingDown = true;
}