使用 StreamReader 读取 HttpContent 流直到字符限制
Read HttpContent stream until a character limit using StreamReader
我正在尝试将以下读取 HttpContent 的完整字符串响应的代码转换为字符串,以仅读取特定的最大字符数。现有代码:
private static async Task<string> GetContentStringAsync(HttpContent content)
{
string responseContent = await content.ReadAsStringAsync().ConfigureAwait(false);
return responseContent;
}
我现在拥有的代码:
private static async Task<string> GetContentStringAsync(HttpContent content, int ResponseContentMaxLength)
{
string responseContent;
Stream responseStream = await content.ReadAsStreamAsync().ConfigureAwait(false);
using (StreamReader streamReader = new StreamReader(responseStream))
{
// responseContent = Data from streamReader until ResponseContentMaxLength
}
return responseContent;
}
我是 StreamReader 和 HttpContent 操作的新手。有没有办法做到这一点?
有多种方法可以做到这一点。但是,恕我直言,最简单的方法之一是创建一个 MemoryStream
并在其中读取所需的确切字节数,然后从该流而不是原始流中读取 StreamReader
对象。
例如:
private static async Task<string> GetContentStringAsync(HttpContent content, int ResponseContentMaxLength)
{
string responseContent;
Stream responseStream = await content.ReadAsStreamAsync().ConfigureAwait(false);
int totalBytesRead = 0;
byte[] buffer = new byte[ResponseContentMaxLength];
while (totalBytesRead < buffer.Length)
{
int bytesRead = await responseStream
.ReadAsync(buffer, totalBytesRead, buffer.Length - totalBytesRead);
if (bytesRead == 0)
{
// end-of-stream...can't read any more
break;
}
totalBytesRead += bytesRead;
}
MemoryStream tempStream = new MemoryStream(buffer, 0, totalBytesRead);
using (StreamReader streamReader = new StreamReader(tempStream))
{
// responseContent = Data from streamReader until ResponseContentMaxLength
}
return responseContent;
}
上面当然假设ResponseContentMaxLength
的值足够小,分配一个足够大的byte[]
来临时存储那么多字节是合理的。由于返回的内容将具有相当的规模,这似乎是一个合理的假设。
但是如果您不想维护那个额外的缓冲区,另一种方法是编写一个 Stream
class 来从底层流对象中读取您指定的字节数,然后将其实例(使用 ResponseContentMaxLength
值初始化)传递给 StreamReader
对象。与上述相比,这是相当多的额外工作。 (不过,我想因为这是一个非常有用的对象,可能已经有一个公开可用的实现......我知道我自己至少写过几次类似的东西,我只是碰巧手边没有代码那一刻)。
@Peter Duniho:感谢您的回复。我最终使用了稍微简单的代码:
using(StreamReader streamReader = new StreamReader(responseStream))
{
char[] responseContentChars = new char[ResponseContentMaxLength];
streamReader.Read(responseContentChars, 0, ResponseContentMaxLength);
string responseContentString = new string(responseContentChars);
responseContent = responseContentString.Replace("[=10=]", string.Empty);
}
但是如果在此处读取流后被其他人使用,以上代码可能会导致错误。选择的答案将照顾其他人阅读原始流,因为新流是从旧流构建的,其内容长度为 ResponseContentMaxLength。
我正在尝试将以下读取 HttpContent 的完整字符串响应的代码转换为字符串,以仅读取特定的最大字符数。现有代码:
private static async Task<string> GetContentStringAsync(HttpContent content)
{
string responseContent = await content.ReadAsStringAsync().ConfigureAwait(false);
return responseContent;
}
我现在拥有的代码:
private static async Task<string> GetContentStringAsync(HttpContent content, int ResponseContentMaxLength)
{
string responseContent;
Stream responseStream = await content.ReadAsStreamAsync().ConfigureAwait(false);
using (StreamReader streamReader = new StreamReader(responseStream))
{
// responseContent = Data from streamReader until ResponseContentMaxLength
}
return responseContent;
}
我是 StreamReader 和 HttpContent 操作的新手。有没有办法做到这一点?
有多种方法可以做到这一点。但是,恕我直言,最简单的方法之一是创建一个 MemoryStream
并在其中读取所需的确切字节数,然后从该流而不是原始流中读取 StreamReader
对象。
例如:
private static async Task<string> GetContentStringAsync(HttpContent content, int ResponseContentMaxLength)
{
string responseContent;
Stream responseStream = await content.ReadAsStreamAsync().ConfigureAwait(false);
int totalBytesRead = 0;
byte[] buffer = new byte[ResponseContentMaxLength];
while (totalBytesRead < buffer.Length)
{
int bytesRead = await responseStream
.ReadAsync(buffer, totalBytesRead, buffer.Length - totalBytesRead);
if (bytesRead == 0)
{
// end-of-stream...can't read any more
break;
}
totalBytesRead += bytesRead;
}
MemoryStream tempStream = new MemoryStream(buffer, 0, totalBytesRead);
using (StreamReader streamReader = new StreamReader(tempStream))
{
// responseContent = Data from streamReader until ResponseContentMaxLength
}
return responseContent;
}
上面当然假设ResponseContentMaxLength
的值足够小,分配一个足够大的byte[]
来临时存储那么多字节是合理的。由于返回的内容将具有相当的规模,这似乎是一个合理的假设。
但是如果您不想维护那个额外的缓冲区,另一种方法是编写一个 Stream
class 来从底层流对象中读取您指定的字节数,然后将其实例(使用 ResponseContentMaxLength
值初始化)传递给 StreamReader
对象。与上述相比,这是相当多的额外工作。 (不过,我想因为这是一个非常有用的对象,可能已经有一个公开可用的实现......我知道我自己至少写过几次类似的东西,我只是碰巧手边没有代码那一刻)。
@Peter Duniho:感谢您的回复。我最终使用了稍微简单的代码:
using(StreamReader streamReader = new StreamReader(responseStream))
{
char[] responseContentChars = new char[ResponseContentMaxLength];
streamReader.Read(responseContentChars, 0, ResponseContentMaxLength);
string responseContentString = new string(responseContentChars);
responseContent = responseContentString.Replace("[=10=]", string.Empty);
}
但是如果在此处读取流后被其他人使用,以上代码可能会导致错误。选择的答案将照顾其他人阅读原始流,因为新流是从旧流构建的,其内容长度为 ResponseContentMaxLength。