5

考虑代码：

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 都会触发并且所有五个都收到相同的消息。

有没有办法改进代码？

4

1 回答 1

2

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

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

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

于 2012-05-10T19:17:15.790 回答