C#多播UDP数据包在存储对象时丢弃

Question

我当前正在订阅一个多播UDP。它在一个最大1000字节的数据包中传输多条消息，每条消息大约80字节。当数据包进入时，我将它们解析为对象，然后将它们存储在字典中。

我收到的每个数据包都有一个序列号，这样我就知道我是否丢弃了任何数据包。

收到大约1万个数据包后，我开始到处丢弃数据包。

securityDefinition xyz = new securityDefinition(p1,p2,p3,p4,p5...etc);
if (!secDefs.ContainsKey(securityID))
{
secDefs.Add(securityID, xyz); //THIS WILL CAUSE DROPS EVENTUALLY
secDefs.Add(securityID, null); //THIS WORKS JUST FINE
}
else
{
//A repeat definition is received and assuming all 
//sequence numbers in the packet line up sequentially, I know i am done
//However if there is a drop somewhere (gap in sequence number),
//I know I am missing something
}

securityDefinition是一个包含大约15个整数、10个小数和5个字符串(每个<10个字符)的类。

有没有一种更快的方法可以实时存储这些对象，从而跟上快速的UDP馈送？我尝试过将securityDefinition作为一个结构，尝试过将数据存储在数据表中，尝试过向列表和队列添加secDef。所有人都有同样的问题。

似乎唯一的瓶颈是将对象放入字典。创建对象并检查字典以查看它是否已经存在似乎很好。

编辑：为了澄清一些事情——安全定义来自循环中的服务器。大约有1000000个定义。一旦它们都被发送了，它们就会被一次又一次地发送。当我的程序启动时，我需要初始化所有的定义。一旦我得到一个重复，我知道我已经结束了，可以关闭这种联系。然而，如果我在序列号1收到一个数据包，而下一个数据包包是序列号3，我知道我已经丢弃了数据包2，无法恢复它

Answer 1

ConcurrentQueue<byte[]> pkts = new ConcurrentQueue<byte[]>();

//IN THE RECEIVER THREAD...
void ProductDefinitionReceiver()
{
while (!secDefsComplete)
{
byte[] data = new byte[1000];
s.Receive(data);
pkts.Enqueue(data);
}
}
//IN A SEPARATE THREAD:
public void processPacketQueue()
{
int dumped = 0;
byte[] pkt;
while (!secDefsComplete)
{
while (pkts.TryDequeue(out pkt))
{
if (!secDefsComplete)
{
//processPkt includes the parsing and inserting the secDef object into the dictionary.
processPkt(pkt);
}
else
{
dumped++;
}
}
}
Console.WriteLine("Dumped: " + dumped);
}