C#

 //Server
private void AnaForm_Load(object sender, EventArgs e)
        {
            thdListener = new Thread(new ThreadStart(listenerThread));
            thdListener.Start();
          }

 public void listenerThread()
 {
     try
     {
         string ipAdress = GetIP();
         IPAddress IPadres = IPAddress.Parse(ipAdress);
         IPEndPoint ipEndPoint = new IPEndPoint(IPadres, 8000);
         TcpListener tcpListener = new TcpListener(ipEndPoint);
         tcpListener.Start();
         while (true)
         {
             listenerSocket = tcpListener.AcceptSocket();
             ntrStream = new NetworkStream(listenerSocket);

            if (listenerSocket.Connected)
            {
                if (ntrStream.CanRead)
                {
                    byte[] byt = new byte[500];
                    ntrStream.Read(byt, 0, byt.Length);
                    MemoryStream ms = new MemoryStream(byt);
                    BinaryFormatter bf = new BinaryFormatter();
                    hashTableInfo.Clear();
                    hashTableInfo = (Hashtable)bf.Deserialize(ms); 
                }
                if (msc.Name.Remove(0, 4) == hashTableInfo["MasaNo"].ToString())
                {
                    thdHandler = new Thread(new ThreadStart(handlerThread));
                    thdHandler.Start();
                }
            }
		}
	}
    catch (Exception)
    {
    }
}
public void handlerThread()
{
    ntrStream = new NetworkStream(listenerSocket);
    try
    {
         //Send Time info
         if (ntrStream.CanWrite)
         {
             MemoryStream msTime = new MemoryStream();
             msTime = new MemoryStream();
             BinaryFormatter bfTime = new BinaryFormatter();
             bfTime.Serialize(msTime, hashTimes);
             byte[] bellekSure = new byte[msTime.Length];
             bellekSure = msTime.ToArray();
             ntrStream.Write(bellekSure, 0, bellekSure.Length); 
         }

          //Send Table of Drinks
        if (ntrStream.CanWrite)
        {
            MemoryStream msDrinks = new MemoryStream();
            BinaryFormatter bfDrinks = new BinaryFormatter();
            bfDrinks.Serialize(msDrinks, hashDrinks);
            byte[] bellekKafe = new byte[msDrinks.Length];
            bellekKafe = msDrinks.ToArray();
            ntrStream.Write(bellekKafe, 0, bellekKafe.Length);
            urunlerGuncellendi = false;  
        }
    }
    catch (Exception)
    {
        
    }
}

 private void Client_Load(object sender, EventArgs e)
        {
            backgroundWorker1.RunWorkerAsync();
        }
		
 private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e) //servera bağlan ve istemciyi güncelle
 {
    
while(true)
{
try
    {
        tcpClient = new TcpClient("serverName", 8000);
        if (tcpClient.Connected)
        {
            ntrStream = tcpClient.GetStream();

            // Send Table info to server
            MemoryStream msSip = new MemoryStream();
            BinaryFormatter bf = new BinaryFormatter();
            bf.Serialize(msSip, htTableInfo);
            byte[] byt = new byte[msSip.Length];
            byt = msSip.ToArray();
            if (ntrStream.CanWrite) ntrStream.Write(byt, 0, byt.Length);

            //Get Time info of the table from server
            if (ntrStream.CanRead)
            {
                byte[] bytTimes = new byte[500]; ///How can I determin the size according to incoming stream?
                ntrStream.Read(bytTimes, 0, bytTimes.Length);
                MemoryStream msTimes = new MemoryStream(bytTimes);
                BinaryFormatter bfSure = new BinaryFormatter();
                hashTimes.Clear(); 
                hashTimes = (Hashtable)bfSure.Deserialize(msTimes);
                if (InvokeRequired)  this.Invoke(new dlgApplyTimes(applyTimes));
                else applyTimes();
            }

            //Get table of drinks from server
            if (ntrStream.DataAvailable)
            {
                byte[] bellekKafe = new byte[500];
                ntrStream.Read(bellekKafe, 0, bellekKafe.Length);
                MemoryStream msKafe = new MemoryStream(bellekKafe);
                BinaryFormatter bfKafe = new BinaryFormatter();
                hashDrinks.Clear(); 
                hashDrinks = (Hashtable)bfKafe.Deserialize(msKafe);
                if (InvokeRequired) this.Invoke(new dlgApplyDrinks(applyDrinks));
                else appyDrinks();
            }
            ntrStream.Close();
            tcpClient.Close();
            tcpClient = null;
        }
    }
    catch (Exception) 
    {
    }
    Thread.Sleep(3000); 
} 
 }