通常,要从字节流中读取字符,您可以使用StreamReader。在此示例中,我正在从无限流中读取以'\r'分隔的记录。
using(var reader = new StreamReader(stream, Encoding.UTF8))
{
var messageBuilder = new StringBuilder();
var nextChar = 'x';
while (reader.Peek() >= 0)
{
nextChar = (char)reader.Read()
messageBuilder.Append(nextChar);
if (nextChar == '\r')
{
ProcessBuffer(messageBuilder.ToString());
messageBuilder.Clear();
}
}
}
问题在于StreamReader有一个很小的内部缓冲区,因此,如果代码等待“记录结束”分隔符(在本例中是'\r'),则必须等到StreamReader的内部缓冲区被刷新(通常是因为更多字节已经到达)。
这种替代实现适用于单字节UTF-8字符,但对于多字节字符将失败。
int byteAsInt = 0;
var messageBuilder = new StringBuilder();
while ((byteAsInt = stream.ReadByte()) != -1)
{
var nextChar = Encoding.UTF8.GetChars(new[]{(byte) byteAsInt});
Console.Write(nextChar[0]);
messageBuilder.Append(nextChar);
if (nextChar[0] == '\r')
{
ProcessBuffer(messageBuilder.ToString());
messageBuilder.Clear();
}
}
如何修改这段代码,使其适用于多字节字符?