udp丢帧率高怎么解决

Question

visual studio 的udp接收改写到qt上使用：首先我用QUdpsocket绑定 设置buffer大小然后connect，然后
readDatagram。于是发现读的速度非常慢，无法满足75ms读1048帧的要求。于是又改win的方法，
win的Createthread 没办法直接使用，于是用了qthread，run函数代码如下：

WSADATA wsaData;
    int errorCode = WSAStartup(MAKEWORD(2, 2), &wsaData);
    qDebug()<<errorCode;
    sockServer = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    if (sockServer <0) {
        m_recvThreadError = true;
     //   qDebug()<<"sockServer error";
        return;
    }

    int recv_buf = 7 * 1024 * 1024;
    int sets =setsockopt(sockServer, SOL_SOCKET, SO_SNDBUF, (char*)&recv_buf, sizeof(int));
    if (0 != sets) {
        m_recvThreadError = true;
      //  qDebug()<<"setsockopt  SO_SNDBUF error"<<sets;
        return;
    };
    if (0 != setsockopt(sockServer, SOL_SOCKET, SO_RCVBUF, (char*)&recv_buf, sizeof(int))) {
        m_recvThreadError = true;
     //   qDebug()<<"setsockopt  SO_RCVBUF error";
        return;
    };
    struct sockaddr_in addr_Server;
    addr_Server.sin_family = AF_INET;
    addr_Server.sin_port = htons(m_port);
    addr_Server.sin_addr.s_addr=inet_addr(m_ipAddr);
    //qDebug()<<__FUNCTION__<<__LINE__<<Log::getTime()<<m_recvFlag;

    while(m_recvFlag)
    {

        mutex.lock();
        if (bind(sockServer, (struct sockaddr*)&addr_Server, sizeof(addr_Server)))
        {
           // qDebug()<<"eth bind error";
            mutex.unlock();
            usleep(100000);
            continue;
        }

        in_addr addr_clt;
        bool first = true;
        uint32_t prev_sequence_number = 0;
        int fromlen = sizeof(sockaddr);
        uint32_t lost_frame = 0;
        bool frame_head_flag = false;
        int packetIdx = 0;
        int packetIdxPrev = 0;
        uint64_t lastRecvTime = GetCurTimeSec();
        uint64_t lastMagicMatchtime = GetCurTimeSec();
        mutex.unlock();
        while(m_recvFlag)
        {

           // mutex.lock();
            int last =recvfrom(sockServer, (char*)&gRecvDataBuff, sizeof(gRecvDataBuff), 0, (sockaddr*)&addr_clt, &fromlen);
           // qDebug()<<__FUNCTION__<<__LINE__<<Log::getTime()<<last;
            if (last == -1)
            {
               // qDebug()<<"recv from is -1";
                if(1000<=(GetCurTimeSec()-lastRecvTime)&&2000>=(GetCurTimeSec()-lastRecvTime))
                    qDebug()<<"no receive data for 1000ms";
              //  mutex.unlock();
               // usleep(2);
                break;
            }
           // mutex.unlock();
            if (last == UDP_PACKET_SIZE)
            {
              //  qDebug()<<__FUNCTION__<<__LINE__<<Log::getTime()<<gRecvDataBuff.data.SIG.magicWord[0]<<gRecvDataBuff.data.SIG.magicWord[1]<<gRecvDataBuff.data.SIG.magicWord[2]<<gRecvDataBuff.data.SIG.magicWord[3];
                if (gRecvDataBuff.data.SIG.magicWord[0] == 0x0102 && gRecvDataBuff.data.SIG.magicWord[1] == 0x0304 && gRecvDataBuff.data.SIG.magicWord[2] == 0x0506&& gRecvDataBuff.data.SIG.magicWord[3] == 0x0708)
                {
                   // mutex.lock();
                    gRecvFrame = pPackage(new ETH_Package_t());
                    gRecvFrame->fCapTime = EthRecv::GetCurTimeSec();
                    gRecvFrame->nMinPackageNo = gRecvDataBuff.sequence_number;
                    gRecvFrame->nFrameID = gRecvDataBuff.data.SIG.frameID;
                    gRecvFrame->nMemLen = gRecvDataBuff.data.SIG.totalPacketLen;
                    gRecvFrame->nPackageTotal = gRecvDataBuff.data.SIG.totalPacketLen/1456;
                    gRecvFrame->nRadarIndex = gRecvDataBuff.data.SIG.radarID;
                    gRecvFrame->Cache= new char[gRecvFrame->nMemLen];
                    memcpy(gRecvFrame->Cache, (char*)&gRecvDataBuff.data, sizeof(CAP_FIRST_FRAME));
                    memset(icheckdata, 0, sizeof(icheckdata));
                    if (frame_head_flag)
                    {
                        //delete gRecvFrame;
                        gRecvFrame = NULL;
                        m_lostFrame++;
                    }
                    frame_head_flag = true;
                    icheckdata[0] = 1;
                   // qDebug()<<__FUNCTION__<<__LINE__<<Log::getTime()<<frame_head_flag;
                   // mutex.unlock();
                }
                else
                {                    
                    if (frame_head_flag)
                    {
                        mutex.lock();
                        packetIdx = gRecvDataBuff.sequence_number - gRecvFrame->nMinPackageNo;
                        if (packetIdx < gRecvFrame->nPackageTotal) {
                            memcpy((char*)(gRecvFrame->Cache+ packetIdx*1456), (char*)&gRecvDataBuff.data, sizeof(CAP_FIRST_FRAME));
                            icheckdata[packetIdx] = 1;
                        }
                        else {
                           // delete gRecvFrame;
                            gRecvFrame = NULL;
                            frame_head_flag = false;
                            mutex.unlock();
                            continue;
                        }

                        if (gRecvFrame==NULL)
                        {
                            mutex.unlock();
                            continue;
                        }
                        mutex.unlock();

                      //  qDebug()<<__FUNCTION__<<__LINE__<<Log::getTime()<<packetIdx<<gRecvFrame->nPackageTotal<< gRecvFrame->nMemLen;
                        if (packetIdx == gRecvFrame->nPackageTotal - 1)
                        {
                            mutex.lock();
                            int recvCount = 0;
                            for (int i = 0;i < gRecvFrame->nPackageTotal;i++)
                                recvCount += icheckdata[i];
                            if (recvCount == gRecvFrame->nPackageTotal)
                            {
                                qDebug()<<__FUNCTION__<<__LINE__<<Log::getTime()<<frame_head_flag;
                                gRecvFrame->nMaxPackageNo = gRecvDataBuff.sequence_number;

                                if (buffer.AddFrame(gRecvFrame) == -1) {
                                    qDebug()<<"lost";
                                   // delete gRecvFrame ;
                                    gRecvFrame = NULL;
                                }
                            }
                            frame_head_flag = false;
                            mutex.unlock();
                            usleep(2);
                        }
                       // LD()<<sizeof (gRecvFrame);


                    }
                }
            }
        }
    }

由于qt多线程访问会有冲突，我加了锁，VS中没有锁的。现在的问题是丢帧率特别高。问下怎么解决？

Answer 1

丢包的一个很可能原因是：如果发包速度太快，而收包的速度较慢，导致缓冲区内新包将旧包覆盖，因为接收缓冲区大小是有限的。

多线程只要不同时访问一个socket、同一块资源就没有冲突，就不需要加锁。频繁加锁解锁很耗时间，如果必须加锁，尽量减少加锁的代码块。

建议：
简化接收线程代码，先把逻辑代码注释掉，只保留接收语句，统计接收的个数并打印，查看收包个数跟发包个数是否一致。如果个数一致，那就是你代码需要修改逻辑，把接收后的数据处理从当前线程中拿出来放到别的地方（可以把所有的报文放在一个队列中，再开线程从队列中处理数据）。
如果上面的方法仍然丢包，尝试修改接收缓冲区的大小。参考如下：

socket_udp = new QUdpSocket;

socket_udp->setReadBufferSize(16*1024*1024);

用setSocketOption()函数也可以。