development:csharp:multithreaded_tcp_listener [Eureka Moment]

This page is read only. You can view the source, but not change it. Ask your administrator if you think this is wrong.

====== Multithreaded TCP listener in C# ======
<code c#>
static TcpListener server;
Int32 port = 8889;
IPAddress localAddr = IPAddress.Parse("0.0.0.0");
server = new TcpListener(localAddr, port);
ThreadPool.QueueUserWorkItem(ConnectionServer, server);

private static void ConnectionServer(object obj)
{
  var server = (TcpListener)obj;
  try
  {
    server.Start();
    while (true)
    {
      TcpClient tcpclient = server.AcceptTcpClient();
      ThreadPool.QueueUserWorkItem(ConnectionProcessor, tcpclient);
    }
  }
  catch (SocketException e)
  {
    Console.WriteLine("SocketException: {0}", e);
  }
  finally
  {
    server.Stop();
  }
}

private static void ConnectionProcessor(object obj)
{
  var server= (TcpClient)obj;
  Byte[] bytes1 = new Byte[132];
  NetworkStream stream = server.GetStream();
  while (stream.Read(bytes1, 0, bytes1.Length) != 0)
  {
    // do something with bytes
    // respond perhaps?
    stream.Write(newBytes, 0, newBytes.Length);
  }
  server.Close();
}   
</code>