C＃异步网络IO和OutOfMemoryException

我正在C＃中的客户端/服务器应用程序，我需要得到异步套接字工作，所以我可以一次处理多个连接。从技术上讲，它现在是这样运作的，但是在跑步3分钟后我得到了OutOfMemoryException。 MSDN说使用WaitHandler做WaitOne()后socket.BeginAccept()，但它实际上并没有让我这样做。当我试图在代码中这样做时，它说WaitHandler是一个抽象类或接口，我不能实例化它。我想也许我试试一个静态参考，但它没有WaitOne()方法，只是WaitAll()和WaitAny()。主要的问题是在文档中没有提供完整的代码片段，所以你实际上看不到他们的“等待处理程序”来自哪里。它只是一个名为allDone的变量，它在代码片段中也有Reset()方法，这是一个等待处理程序不具备的方法。C＃异步网络IO和OutOfMemoryException

在他们的文档中进行了深入研究之后，我发现Threading名称空间中的AutoResetEvent有一些相关的事情。它有一个WaitOne()和Reset()方法。所以我尝试了while(true) { ... socket.BeginAccept(...); ... }。不幸的是，这使得它一次只能连接一个连接。所以我不确定要去哪里。这里是我的代码：

class ServerRunner 
    { 
     private Byte[] data = new Byte[2048]; 
     private int size = 2048; 
     private Socket server; 
     static AutoResetEvent allDone = new AutoResetEvent(false); 

     public ServerRunner() 
     { 
      server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 
      IPEndPoint iep = new IPEndPoint(IPAddress.Any, 33333); 
      server.Bind(iep); 
      Console.WriteLine("Server initialized.."); 
     } 

     public void Run() 
     { 

      server.Listen(100); 
      Console.WriteLine("Listening..."); 
      while (true) 
      { 
       //allDone.Reset(); 
       server.BeginAccept(new AsyncCallback(AcceptCon), server); 
       //allDone.WaitOne(); 
      } 
     } 

     void AcceptCon(IAsyncResult iar) 
     { 
      Socket oldserver = (Socket)iar.AsyncState; 
      Socket client = oldserver.EndAccept(iar); 
      Console.WriteLine(client.RemoteEndPoint.ToString() + " connected"); 
      byte[] message = Encoding.ASCII.GetBytes("Welcome"); 
      client.BeginSend(message, 0, message.Length, SocketFlags.None, new AsyncCallback(SendData), client); 
     } 

     void SendData(IAsyncResult iar) 
     { 
      Socket client = (Socket)iar.AsyncState; 
      int sent = client.EndSend(iar); 
      client.BeginReceive(data, 0, size, SocketFlags.None, new AsyncCallback(ReceiveData), client); 
     } 

     void ReceiveData(IAsyncResult iar) 
     { 
      Socket client = (Socket)iar.AsyncState; 
      int recv = client.EndReceive(iar); 
      if (recv == 0) 
      { 
       client.Close(); 
       server.BeginAccept(new AsyncCallback(AcceptCon), server); 
       return; 
      } 
      string receivedData = Encoding.ASCII.GetString(data, 0, recv); 
      //process received data here 
      byte[] message2 = Encoding.ASCII.GetBytes("reply"); 
      client.BeginSend(message2, 0, message2.Length, SocketFlags.None, new AsyncCallback(SendData), client); 
     } 
    }

来源

2010-04-25 The.Anti.9

C＃异步网络IO和OutOfMemoryException

回答

相关问题