C＃的StreamReader“的ReadLine”对于自定义分隔符

Question

什么是有StreamReader.ReadLine()方法的功能的最佳方式，而是使用自定义（字符串）分隔符？

我想这样做：

String text; 
while((text = myStreamReader.ReadUntil("my_delim")) != null) 
{ 
    Console.WriteLine(text); 
} 

我试图用Peek()和StringBuilder，使我自己的，但它的效率太低。我正在寻找建议或可能是一个开源解决方案。

谢谢。

编辑

我应该澄清这...前面我已经看到this answer，不过，我不希望将整个文件读入内存中。

Answer 1

我想我会发表我自己的解决方案。它似乎工作得很好，代码相对简单。随意发表评论。

public static String ReadUntil(this StreamReader sr, String delim) 
{ 
    StringBuilder sb = new StringBuilder(); 
    bool found = false; 

    while (!found && !sr.EndOfStream) 
    { 
     for (int i = 0; i < delim.Length; i++) 
     { 
      Char c = (char)sr.Read(); 
      sb.Append(c); 

      if (c != delim[i]) 
       break; 

      if (i == delim.Length - 1) 
      { 
       sb.Remove(sb.Length - delim.Length, delim.Length); 
       found = true; 
      } 
     } 
    } 

    return sb.ToString(); 
} 

Answer 2

此代码应该适用于任何字符串分隔符。

public static IEnumerable<string> ReadChunks(this TextReader reader, string chunkSep) 
{ 
    var sb = new StringBuilder(); 

    var sepbuffer = new Queue<char>(chunkSep.Length); 
    var sepArray = chunkSep.ToCharArray(); 

    while (reader.Peek() >= 0) 
    { 
     var nextChar = (char)reader.Read(); 
     if (nextChar == chunkSep[sepbuffer.Count]) 
     { 
      sepbuffer.Enqueue(nextChar); 
      if (sepbuffer.Count == chunkSep.Length) 
      { 
       yield return sb.ToString(); 
       sb.Length = 0; 
       sepbuffer.Clear(); 
      } 
     } 
     else 
     { 
      sepbuffer.Enqueue(nextChar); 
      while (sepbuffer.Count > 0) 
      { 
       sb.Append(sepbuffer.Dequeue()); 
       if (sepbuffer.SequenceEqual(chunkSep.Take(sepbuffer.Count))) 
        break; 
      } 
     } 
    } 
    yield return sb.ToString() + new string(sepbuffer.ToArray()); 
} 

免责声明：

我做了一个小测试就这个，实际上是慢ReadLine方法，但我怀疑这是由于入队/出队/ sequenceEqual称，在ReadLine方法可以应避免（因为分隔符总是\r\n）。

再一次，我做了很少的测试，它应该可以工作，但不要把它当成完美的，随时纠正它。 ;）

Answer 3

下面是我用一个简单的解析器在需要的地方（通常，如果流不是最重要的，仅读和.Split做这项工作），没有太多优化，但应该很好地工作：
（它更像一个斯普利特方法 - 并在下面更笔记）

public static IEnumerable<string> Split(this Stream stream, string delimiter, StringSplitOptions options) 
    { 
     var buffer = new char[_bufffer_len]; 
     StringBuilder output = new StringBuilder(); 
     int read; 
     using (var reader = new StreamReader(stream)) 
     { 
      do 
      { 
       read = reader.ReadBlock(buffer, 0, buffer.Length); 
       output.Append(buffer, 0, read); 

       var text = output.ToString(); 
       int id = 0, total = 0; 
       while ((id = text.IndexOf(delimiter, id)) >= 0) 
       { 
        var line = text.Substring(total, id - total); 
        id += delimiter.Length; 
        if (options != StringSplitOptions.RemoveEmptyEntries || line != string.Empty) 
         yield return line; 
        total = id; 
       } 
       output.Remove(0, total); 
      } 
      while (read == buffer.Length); 
     } 

     if (options != StringSplitOptions.RemoveEmptyEntries || output.Length > 0) 
      yield return output.ToString(); 
    } 

...你可以简单地切换到char分隔符如果需要的话只需更换

while ((id = text.IndexOf(delimiter, id)) >= 0) 

...与

while ((id = text.IndexOfAny(delimiters, id)) >= 0) 

（和id++而不是id+=和签名this Stream stream, StringSplitOptions options, params char[] delimiters）

...还删除空等
希望它有助于

Answer 4

public static String ReadUntil(this StreamReader streamReader, String delimiter) 
    { 
     StringBuilder stringBuilder = new StringBuilder(); 

     while (!streamReader.EndOfStream) 
     { 
      stringBuilder.Append(value: (Char) streamReader.Read()); 

      if (stringBuilder.ToString().EndsWith(value: delimiter)) 
      { 
       stringBuilder.Remove(stringBuilder.Length - delimiter.Length, delimiter.Length); 
       break; 
      } 
     } 

     return stringBuilder.ToString(); 
    }