使用 Http Put 请求在 HLS 服务器上发送的某些文件被部分上传

如何解决使用 Http Put 请求在 HLS 服务器上发送的某些文件被部分上传

作为项目的一部分，我必须在 HLS 服务器上连续上传音频块。我可以使用以下代码在 C++ 中使用带有 wininet API 的 HTTP Put 方法成功上传块。

bool CHTTP::HttpPut(char *szFile,int fileType)
{   

    bool bErrorFlag = false;
    if(m_hInternet == NULL)
    {
        int retStatus = OpenHTTPSession();
        if(retStatus < 1)
        {
            return true;
        }
    }

    char szPostURL[256];
    INTERNET_BUFFERS BufferIn = {0};
    DWORD dwBytesRead;
    DWORD dwBytesWritten;
    BYTE pBuffer[350000]; 
    BOOL bRead,bRet;
    static int flag = 1;
    BufferIn.dwStructSize = sizeof( INTERNET_BUFFERS );

    char szLocalFilePath[256];
    if(fileType == AUdio_CHUNK)
        sprintf(szLocalFilePath,"%s/%s",m_strFilePath,szFile);
    else
        strcpy(szLocalFilePath,szFile);

    int iFileSize = 0;

    if(fileType == AUdio_CHUNK)
    {
        strcpy(szPostURL,m_strPostPath);
        strcat(szPostURL,"/");
        strcat(szPostURL,szFile);
    }
    else if(fileType == M3U8)
        strcpy(szPostURL,m_szM3U8FiletoPost);
    else if(fileType == AUTO_M3U8)
        strcpy(szPostURL,m_szM3U8Autopost);

    DWORD dwFlags = 
        INTERNET_FLAG_KEEP_CONNECTION |
        INTERNET_FLAG_NO_COOKIES |
        INTERNET_FLAG_NO_CACHE_WRITE |
        INTERNET_FLAG_NO_UI |
        INTERNET_FLAG_RELOAD |INTERNET_FLAG_SECURE;

    m_hRequest = HttpOpenRequest(m_hHttpSession,(const char*)"PUT",szPostURL,"HTTP/1.1",NULL,(const char**)"*/*\0",dwFlags,1);

    if(m_hRequest==NULL) 
    {
        bErrorFlag = true;
        CloseHTTPSession();
        return bErrorFlag;
    }
    else
    {
        bErrorFlag = false;
    }

    int num_of_try = 0;
    while(num_of_try < 3)
    {
        char logDump[1000];
        num_of_try++;
        HANDLE hFile = CreateFile (szLocalFilePath,GENERIC_READ,FILE_SHARE_READ,OPEN_EXISTING,FILE_ATTRIBUTE_norMAL,NULL);
        if (hFile == INVALID_HANDLE_VALUE)
        {
            bErrorFlag = true;
            break;
        }
        else if(!m_bLogFlagCreateErr)
        {
            m_bLogFlagCreateErr = true;
            sprintf(logDump,"CreateFile success %s",szFile);
            WriteLog(mLogFile,logDump);
            bErrorFlag = false;
        }

        BufferIn.dwBufferTotal = GetFileSize (hFile,NULL);
        iFileSize = BufferIn.dwBufferTotal;
        if(!HttpSendRequestEx( m_hRequest,&BufferIn,HSR_INITIATE,0))
        {
            bErrorFlag = true;
            m_bLogFlagSend = false;
            sprintf(logDump,"Error on HttpSendRequestEx %lu %s",GetLastError(),logDump);

            break;
        }
        else
        {
            bErrorFlag = false;
            sprintf(logDump,"HttpSendRequest success %s",logDump);
        }
        DWORD sum = 0;
        int size = 0;
        do
        {
            bRead = ReadFile (hFile,pBuffer,iFileSize,&dwBytesRead,NULL);

            if(dwBytesRead != iFileSize)
            {
                sprintf(logDump,"dwBytesRead %d iFileSize %d %s",dwBytesRead,szFile);
                WriteLog(mLogFile,logDump);
            }

            if(dwBytesRead > 0)
            {
                bRet=InternetWriteFile( m_hRequest,&dwBytesWritten);

                while(dwBytesRead < dwBytesWritten && bRet)
                {
                    sprintf(logDump,"dwBytesRead %d dwBytesWritten %d %s",dwBytesWritten,szFile);
                    WriteLog(mLogFile,logDump);
                    bRet=InternetWriteFile( m_hRequest,pBuffer+dwBytesWritten,dwBytesRead - dwBytesWritten,&dwBytesWritten);
                }
                if(!bRet)
                {
                    int error = GetLastError();
                    sprintf(logDump,"InternetWriteFile %lu %s",error,logDump);
                    bErrorFlag = true;
                    break;
                }
                else 
                {
                    sprintf(logDump,"InternetWriteFile buffer success %s",logDump);
                    bErrorFlag = false;

                }
            }
        }
        while (dwBytesRead == iFileSize);
        CloseHandle (hFile);

        if(!HttpEndRequest(m_hRequest,0))
        {
            int error = GetLastError();
            if(error != 12032)
            {
                sprintf(logDump,"HttpEndRequest %lu %s",logDump)
                bErrorFlag = true;
                break;
            }
            else 
            {
                bErrorFlag = true;
                continue;
            }
        }
        else
        {

            sprintf(logDump,"HttpEndRequest success %s",logDump);

            DWORD dwCode,dwCodeSize; 
            dwCodeSize = sizeof(DWORD);
            if(!HttpQueryInfo(m_hRequest,HTTP_QUERY_STATUS_CODE | HTTP_QUERY_FLAG_NUMBER,&dwCode,&dwCodeSize,NULL))
            {
                int error = GetLastError();
                char tmp[256];
                sprintf(tmp,"HttpQueryfails %d %s",tmp);

            }
            else
            {
                if(dwCode != 201 && dwCode != 204)
                {
                    char tmp[256];
                    sprintf(tmp,"dwcode %d is not 201 or 204 %s",dwCode,tmp);
                    bErrorFlag = true;
                    break;
                }

            }
            bErrorFlag = false;
            break;
        }
    }
    CloseHTTPSession();
    return bErrorFlag;
}

大多数情况下上传的块都是完整大小。如下图所示，随机上传到服务器的块不是完整大小。

sample image

在这种情况下，我没有收到任何错误消息，即使是 InternetWriteFile 函数返回的 dwBytesWritten 也是正确的。我无法理解我该怎么做才能解决它。感谢您在这方面的任何帮助。