具有多个用户的 C# UDP 服务器

Question

考虑代码：

class UPDServer {

    //start listener
    public void start() {
        UdpClient listener = new UdpClient(this._porta);
        IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Any, 10000);

        State s = new State();
        s.listener = listener;
        s.ipEndPoint = ipEndPoint;

        // begin to listen again
        listener.BeginReceive(new AsyncCallback(ReceiveCallback), s);

   }

 //receive data
   public void ReceiveCallback(IAsyncResult ar)
   {
      // we got data
      State s = (State)(ar.AsyncState);

      Byte[] received = e.escuta.EndReceive(ar, ref e.ipEndPoint);
      string text = ""; = Encoding.ASCII.GetString(received);
      // ... do somenthing with text

      // begin to listen again
      s.listener.BeginReceive(new AsyncCallback(ReceiveCallback), e);
   }
}

在上面的代码中，EndReceive 和下一个没有人在听的 BeginReceive 之间有一个时间跨度，我认为如果在这个时间跨度内有消息，它将丢失。

好吧，我猜有某种缓冲区，但即便如此，如果缓冲区在没有人监听消息的时间跨度内填满，消息也会丢失。

我记得有人说这可以通过在同一个端点上多次调用 BeginReceive 来解决非常简单，所以我尝试了这个：

   for( int x = 0; x < 5;x++) {
      escuta.BeginReceive(new AsyncCallback(ReceiveCallback), e);
   }

奇怪的是，在同一个套接字上调用 begin receive 不会抛出错误，但是每次收到一条消息时，所有五个 beginReceive 都会触发，并且所有五个都收到相同的消息。

有没有办法改进代码？

Answer 1

首先，使用 UDP 时不能保证您会获得所有数据，因此无论如何您都必须使您的代码/协议具有容错能力。

除非您的处理非常密集并且您期望大量数据涌入，否则您可能不需要采取不同的做法。只需添加一些错误检测代码，这样您就可以知道您的代码是否无法应对。

但是，如果您需要保持接收循环快速，则当您接收数据时，请将其复制到队列中以供另一个线程处理，以便您可以快速再次开始读取。或者在某些情况下，您可以编写最终接收器，以便在多个数据包连续进入时它可以处理重新进入。