TcpClient BottleNeck

Question

我试图创建一个自包含的类，它维护到服务器的TCP连接。

我使用下列类变量：

TcpClient tcpClient; 
NetworkStream networkStream; 
BinaryReader mReader; 
BinaryWriter mWriter; 

并使用下面的代码初始化它们：

tcpClient = new TcpClient(host, 443); 
networkStream = tcpClient.GetStream(); 
mReader = new BinaryReader(networkStream); 
mWriter = new BinaryWriter(networkStream); 

receiveMessage = new Thread(new ThreadStart(ReceiveMessages)); 
receiveMessage.Start(); 

我使用读阻塞调用。每个来自服务器的数据包都以4个字节（一个int）作为前缀，用于定义确切的数据包大小。我使用的是一个名为ByteBuffer的类，它有一个List（Byte）来存储字节。类有一些函数，它们使用ReadInt（），ReadString （）等，根据服务器协议。

这里是接收器线程：

private void ReceiveMessages() 
{ 
    while (tcpClient.Connected) 
    { 
     if (tcpClient.Available >= 4) 
     { 
      try 
      { 
       ByteBuffer message = new ByteBuffer(); 
       message.AddBytes(mReader.ReadBytes(4)); 
       int mSize = message.ReadInt(); 
       message.AddBytes(mReader.ReadBytes(mSize - 4)); 
       MessageProcessor.Process(message); 
      } 
      catch (Exception ex) 
      { 
       Print(ex.Message); 
      } 
     } 
     Thread.Sleep(1); 
    } 
    Print("Receiver thread terminated."); 
    Reconnect(); 
} 

作为参考，MessageProcessor的是一个静态类看起来在分组信息并响应服务器适当。

我的问题是，当连接上的流量开始变得非常高时，响应开始显着延迟。我想知道，就tcp连接而言，我是否做了错误的操作？我应该尝试写一个类的异步版本吗？ C＃List对象是否太慢而无法经常使用（在ByteBuffer中）？

这实际上是我第一次尝试网络编程，所以任何建议都会非常有帮助。

谢谢。

Answer 1

改为切换到异步处理。使用线程和Thread.Sleep是邪恶的。

看Socket.BeginReceive或在您的情况NetworkStream.BeginRead

你也可以用我的新库：http://blog.gauffin.org/2012/05/griffin-networking-a-somewhat-performant-networking-library-for-net/

Answer 2

我会重写你ReceiveMessages方法，像这样 删除了Thread.Sleep这是坏的。使用更快的字节数组。

像@ jgauffin说异步网络代码好多了，但它更容易搞砸了。如果您刚刚开始使用网络编程，请将其保持简单。

我希望这对你更好。

注意的消息是没有4字节的包头

private void ReceiveMessages() 
    { 

     while (tcpClient.Connected) { 
      try { 

       var networkstream = tcpClient.GetStream(); 
       var header = new byte[4]; 
       networkstream.Read(header, 0, 4); 

       int len = 0; 
       // calculate length from header 
       // Do reverse for BigEndian, for little endian remove 
       Array.Reverse(header); 
       len = BitConverter.ToInt32(header, 0); 

       var message = new byte[len]; 
       networkstream.Read(message, 0, message.Length); 

       // Process message 

      } 
      catch (Exception ex) 
      { 
       Print(ex.Message); 
       // Exit loop something went wrong 
       break; 
      } 
     } 

     Print("Receiver thread terminated."); 
     Reconnect(); 

    }