c#大数据量的代码优化

Question

我正在通过 TCP 获取大量数据。数据中有 2 种类型的 XML 数据包。我需要尽快处理它。

<?xml version="1.0" encoding="UTF-8"?><xsi:Event> .... [dynamic length data] .... </xsi:Event>

和

<?xml version="1.0" encoding="UTF-8"?><ChannelHeartBeat xmlns="http://schema.broadsoft.com/xsi"/>

有时数据包没有 xml 声明。

这是旧代码。

 char c = (char)streamReader.Read();
 sb.Append(c);

 if(sb.ToString().EndsWith("</xsi:Event>",StringComparison.OrdinalIgnoreCase))
 { 
     ....
     sb.Clear();
 }

 if(sb.ToString().EndsWith("<ChannelHeartBeat xmlns=\"http://schema.broadsoft.com/xsi\"/>", StringComparison.OrdinalIgnoreCase))
 {
   ....
   sb.Clear();

 }

ToString() 在上述代码中占用了 26% 的 CPU 时间。

以下是优化后的代码。性能提升了 30%

  char c = (char)streamReader.Read();
  sb.Append(c);
  n++;
  if (n > 60)
  {
      if (c == '>')
      {          
          if (n < 105)
          {
              string temp = sb.ToString();
              if (temp.EndsWith("<ChannelHeartBeat xmlns=\"http://schema.broadsoft.com/xsi\"/>", StringComparison.OrdinalIgnoreCase))
              {
               sb.Clear();
               n = 0;
              }
          }
          if (n > 700)
          {
              string temp = sb.ToString();
              if (temp.EndsWith("</xsi:Event>", StringComparison.OrdinalIgnoreCase))
              {
                 sb.Clear();
                 n = 0;
              }
          }  
      }
  }
}

ToString() 现在占用了 8% 的 CPU 时间。

我想进一步优化代码。欢迎提出任何建议。

提前致谢。

Answer 1

您可以尝试使用循环和索引器检查字符串生成器是否以给定字符串结尾，看看这是否会提高性能。例如：

public static class Extensions {
    public static bool EndsWith(this StringBuilder sb, string target, bool caseInsensetive = false) {
        // if sb length is less than target string
        // it cannot end with it
        if (sb.Length < target.Length)
            return false;
        var offset = sb.Length - target.Length;            
        for (int i = sb.Length - 1; i >= offset; i--) {
            var left = sb[i];
            var right = target[i - offset];
            // conver to upper-case for insensetive comparision
            // if necessary
            if (caseInsensetive) {
                left = Char.ToUpper(left, CultureInfo.InvariantCulture);
                right = Char.ToUpper(right, CultureInfo.InvariantCulture);
            }
            // fail fast
            if (left != right)
                return false;
        }
        return true;
    }
}

用法：

const string HeartBeatEnding = "<ChannelHeartBeat xmlns=\"http://schema.broadsoft.com/xsi\"/>";
const string EventEnding = "</xsi:Event>";

char c = (char)streamReader.Read();
sb.Append(c);
if (sb.EndsWith(EventEnding)) {
    // do stuff
}
else if (sb.EndsWith(HeartBeatEnding)) {
    // do stuff
}