C#

private void BeginConnectToServersThread()<br />
{<br />
	String strIP;<br />
	for(int nServer=0; nServer < listServers.Items.Count; nServer++)<br />
	{<br />
		strIP = listServers.Items[nServer].SubItems[1].Text;<br />
		if(strIP != "")<br />
		{<br />
			try<br />
			{<br />
				m_socClient = new Socket (AddressFamily.InterNetwork,SocketType.Stream ,ProtocolType.Tcp );<br />
				// get the remote IP address...<br />
				IPAddress ip = IPAddress.Parse(strIP);<br />
				int iPortNo = 8221;<br />
				//create the end point<br />
				IPEndPoint ipEnd = new IPEndPoint(ip.Address,iPortNo);<br />
				//connect to the remote host...<br />
				m_socClient.Connect( ipEnd );<br />
				//watch for data ( asynchronously )...<br />
				WaitForData();<br />
			}<br />
			catch(ObjectDisposedException)<br />
			{<br />
				System.Diagnostics.Debugger.Log(0,"1","\n OnClientConnection: Socket has been closed\n");<br />
			}<br />
			catch(SocketException se)<br />
			{<br />
				MessageBox.Show ( se.Message );<br />
			} <br />
		}<br />
	}<br />
}<br />
<br />
public void WaitForData()<br />
{<br />
	if ( pfnCallBack == null )<br />
		pfnCallBack = new AsyncCallback (OnDataReceived);<br />
	// now start to listen for any data...<br />
	m_asynResult = <br />
		m_socClient.BeginReceive (m_DataBuffer,0,m_DataBuffer.Length,SocketFlags.None, pfnCallBack,null);<br />
}<br />
<br />
public void OnDataReceived(IAsyncResult asyn)<br />
{<br />
	//end receive...<br />
	int iRx = 0 ;<br />
	iRx = m_socClient.EndReceive (asyn);<br />
	char[] chars = new char[iRx + 1];<br />
	System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder();<br />
	int charLen = d.GetChars(m_DataBuffer, 0, iRx, chars, 0);<br />
	System.String szData = new System.String(chars);<br />
	ProcessIncommingMessage(szData);<br />
	WaitForData();<br />
}