0

我正在TIdHTTPServer使用该功能向客户提供文件ResponseInfo->ServeFile。这适用于“静态”文件：不是由其他进程写入的。据我从代码中可以看出，ServeFile 函数在内部使用 a TIdReadFileExclusiveStream，这使我无法读取正在写入的文件，但我还需要能够发送正在由其他进程写入的文件。

因此，我自己创建了一个 FileStream 并使用该ContentStream属性将其返回给客户端，但是我在客户端中得到一个 0 字节的文件（对于任何文件，无论是否写入），我看不到我的内容我错过或做错了。这是我在OnCommandGet事件处理程序上使用的代码：

AResponseInfo->ContentStream = new TFileStream(path, fmOpenRead | fmShareDenyNone);
AResponseInfo->ContentStream->Position = 0;
AResponseInfo->ContentLength = AResponseInfo->ContentStream->Size;
AResponseInfo->ResponseNo = 200;
AResponseInfo->WriteHeader();
AResponseInfo->WriteContent();

此时的 ContentLength 属性具有有效值（即调用 ContentStream->Size 时的文件大小），这就是我想发送给客户端的值，即使文件在两者之间发生变化。

我试过删除 WriteContent() 函数，即 WriteHeader()，但结果是一样的。我搜索了一些示例，但我发现的几个与此代码或多或少相同，所以我不知道出了什么问题。大多数示例不包括 WriteContent() 调用，这就是我尝试删除它们的原因，但似乎没有任何区别。

附带说明：正在写入的文件需要 24 小时才能完成写入，但这是客户端所期望的：我只需要在请求时已经写入的字节（甚至更少是有效的）。这些文件永远不会被删除：它们只会越来越大。

有任何想法吗？

更新

使用 Fiddler，我收到了一些与协议违规有关的警告，这与此有关。例如，我得到：

Content-Length mismatch: Response Header indicated 111,628,288 bytes, but server sent 41 bytes

内容长度是正确的，它是文件大小，但我不知道我做错了什么使得应用程序只发送了 41 个字节。

4

2 回答 2

2

WriteHeader()并WriteContent()期望在ContentStream调用它们时是完整且不变的。 如果属性为 -1（您实际上是自己设置值），则使用当前值WriteHeader()创建一个标头，并且只发送当前值所说的字节数。因此，您的客户端正在接收 0 个字节，因为在您调用时文件仍然为 0并且.Content-LengthContentStream->SizeAResponseInfo->ContentLengthWriteContent()ContentStream->SizeSizeWriteHeader()WriteContent()

既不ServeFile()也不ContentStream适合您的需求。由于文件是实时写入的，因此在创建 HTTP 标头并将其发送到客户端时，您不知道最终文件的大小。所以你必须使用 HTTP 1.1 的chunked传输编码来发送文件数据。这将允许您在写入文件时以块的形式发送文件数据，然后在文件完成时向客户端发出信号。

但是，TIdHTTPServer它本身不支持发送chunked响应，因此您必须手动实现它，例如：

TFileStream *fs = new TFileStream(path, fmOpenRead | fmShareDenyNone);
try
{
    AResponseInfo->ResponseNo = 200;
    AResponseInfo->TransferEncoding = "chunked";
    AResponseInfo->WriteHeader();

    TIdBytes buffer;
    buffer.Length = 1024;

    do
    {
        int NumRead = fs->Read(&buffer[0], 1024);
        if (NumRead == -1) RaiseLastOSError();
        if (NumRead == 0)
        {
            // check for EOF, unless you have another way to detect it...
            Sleep(1000);
            NumRead = fs->Read(&buffer[0], 1024);
            if (NumRead <= 0) break;
        }

        // send the current chunk
        AContext->Connection->IOHandler->WriteLn(IntToHex(NumRead));
        AContext->Connection->IOHandler->Write(buffer, NumRead);
        AContext->Connection->IOHandler->WriteLn();
    }
    while (true);

    // send the last chunk to signal EOF
    AContext->Connection->IOHandler->WriteLn("0");

    // send any trailer headers you need, if any...

    // finish the transfer encoding
    AContext->Connection->IOHandler->WriteLn();
}
__finally
{
    delete fs;
}
于 2015-02-09T20:42:07.640 回答
0

最终的工作代码是：

    std::unique_ptr< TFileStream >fs(new TFileStream(path, fmOpenRead | fmShareDenyNone));

    fs->Position = 0;
    __int64 size = fs->Size;

    AResponseInfo->ContentLength = size;
    AResponseInfo->ResponseNo    = 200;

    AResponseInfo->WriteHeader();

    AContext->Connection->IOHandler->Write(fs.get(), size);

这允许客户端最多接收size原始文件的字节，即使该文件正在同时被写入。

由于某种原因，传递 ContentStream 并没有向客户端返回任何内容，但是IOHandler->Write直接执行（这是 ServeFile 在内部结束的操作）可以正常工作。

于 2015-02-10T17:30:42.683 回答