C# 服务器 - 套接字未连接和内存不足异常

Question

我正在尝试实现一个简单的 TCP 服务器，我基本上复制了示例 on MSDN 没有几行，并试图使其工作。我有一个外部客户端已经在尝试连接。 这是我的代码：

IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());
 IPEndPoint localEP = new IPEndPoint(ipHostInfo.AddressList[0], 4001);

 Socket listener = new Socket(localEP.Address.AddressFamily,
     SocketType.Stream, ProtocolType.Tcp);

 try
 {
     listener.Bind(localEP);
     listener.Listen(1000);

    while (true)
     {

         listener.BeginAccept(new AsyncCallback(AcceptCnxCallback), listener);
     }
 }
 catch (Exception e)
 {
   //Log here
 }

这是我的回调：

private void AcceptCnxCallback(IAsyncResult iar)
{

    MensajeRecibido msj = new MensajeRecibido();

    Socket server = (Socket)iar.AsyncState;
    msj.workSocket = server.EndAccept(iar);

}

这是其中一个传入包的信息：

TCP:[SynReTransmit #1727889]Flags=......S., SrcPort=57411, DstPort=4001, PayloadLen=0, Seq=673438964, Ack=0, Win=5840 ( Negotiating scale factor 0x4 ) = 5840  

来源：10.0.19.65 目的地：10.0.19.59

我基本上有两个问题：

1. 如果我使用 while 循环，我会得到 OutOfMemoryException

2. 我从来没有设法连接到客户端

关于这两个问题中的任何一个的任何提示？先感谢您！

Answer 1

您的问题是，您一直在使用异步调用。没有等待机制或类似机制，因此通常您只是在无限循环中创建新的异步回调。

对于基本 TCP，我建议使用简单方法并使用同步方法。 Accept() 是阻塞的，所以程序流将停止，直到有传入连接。

while (true)
{
    Socket s = listener.Accept();

    buffer = new byte[BUFFER_SIZE];
    s.Receive(buffer);
    //Do something
    s.Send(...);

}

不，这只是一个基本示例。如果您想保持连接，您可以考虑为每个接受的 Socket 创建一个新线程，以继续接收和发送数据。

Answer 2

第一个问题 您正在使用无限循环来调用异步方法。

试试这样：

listener.BeginAccept(new AsyncCallback(AcceptCnxCallback), listener);

//add your code here (this part will be executed wile the listner is waiting for a connection.
while (true)
     {


         Thread.Sleep(100);

     } 

并将回调方法更改为：

private void AcceptCnxCallback(IAsyncResult iar)
{

    MensajeRecibido msj = new MensajeRecibido();

    Socket server = (Socket)iar.AsyncState;
    msj.workSocket = server.EndAccept(iar);

//call again the listener after you get a message
listener.BeginAccept(new AsyncCallback(AcceptCnxCallback), listener);
}