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

提问者：小点点

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

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

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

在收到大约10K个数据包后，我开始在这里和那里丢弃数据包。

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成为一个结构，我尝试过将数据存储在datatable中，我尝试过将secDef添加到列表和队列中。所有人都有同样的问题。

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

编辑:为了澄清一些事情--安全定义来自循环中的服务器。大约有1,000,000个定义。一旦它们全部被发送，它们就会被再次发送，一遍又一遍地发送。当我的程序启动时，我需要初始化所有的定义。一旦我得到一个重复，我知道我做完了，可以关闭这个连接。但是，如果我收到序列号为1的数据包，而下一个数据包是序列号为3的，我知道我丢失了数据包2，并且没有办法恢复它。

共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);
}