如何编写.Net UDP可伸缩服务器

我发现最小化丢弃的数据包的方法是,像您提到的那样,从套接字异步读取数据,但是要将读取的字节放入线程安全队列中,然后让另一个线程从队列中读取并处理字节。如果您使用的是.Net 4.0,则可以使用ConcurrentQueue:

public class SomeClass {
    ConcurrentQueue<IList<Byte>> _Queue;
    Byte[] _Buffer;
    ManualResetEvent _StopEvent;
    AutoResetEvent _QueueEvent;
    private void ReceiveCallback(IAsyncResult ar) {
        Socket socket = ar.AsyncState as Socket;
        Int32 bytesRead = socket.EndReceive(ar);
        List<Byte> bufferCopy = new List<byte>(_Buffer);
        _Queue.Enqueue(bufferCopy);
        _QueueEvent.Set();
        if(!_StopEvent.WaitOne(0)) socket.BeginReceive(...);
        return;
    }
    private void ReadReceiveQueue() {
        WaitHandle[] handles = new WaitHandle[] { _StopEvent, _QueueEvent };
        Boolean loop = true;
        while (loop) {
            Int32 index = WaitHandle.WaitAny(handles);
            switch (index) {
                case 0:
                    loop = false;
                    break;
                case 1:
                    // Dequeue logic here
                    break;
                default:
                    break;
            }
        }
    }
}

注意:StopEvent是一个ManualResetEvent,因此ReceiveCallback和ReadReceiveQueue方法都可以使用同一个事件来完全关闭。

如果只有一个套接字,并且可以独立处理UDP数据包,那么最好的方法实际上是使用一个线程池,其中每个线程调用一个阻塞接收。操作系统将负责唤醒一个等待的线程来接收/处理数据包。这样可以避免异步I/O例程带来的任何开销。