2020-08-20

【Net】StreamWriter.Write 的一点注意事项

今天在维护一个旧项目的时候,看到一个方法把string 转换为 byte[] 用的是写入内存流的,然后ToArray(),因为平常都是用System.Text.Encoding.UTF8.GetBytes(string) ,刚好这里遇到一个安全的问题,就想把它重构了。由于这个是已经找不到原来开发的人员,所以也无从问当时为什么要这么做,我想就算找到应该他也不知道当时为什么要这么做。由于这个是线上跑了很久的项目,所以需要做一下测试,万一真里面真的是有历史原因呢!于是就有了这篇文章。

背景

今天在维护一个旧项目的时候,看到一个方法把string 转换为 byte[] 用的是写入内存流的,然后ToArray(),因为平常都是用System.Text.Encoding.UTF8.GetBytes(string) ,刚好这里遇到一个安全的问题,就想把它重构了。

由于这个是已经找不到原来开发的人员,所以也无从问当时为什么要这么做,我想就算找到应该他也不知道当时为什么要这么做。

由于这个是线上跑了很久的项目,所以需要做一下测试,万一真里面真的是有历史原因呢!于是就有了这篇文章。

重构过程

  1. 需要一个比较byte数组的函数(确保重构前后一致),没找到有系统自带,所以写了一个
  2. 重构方法(使用Encoding)
  3. 单元测试
  4. 基准测试(或许之前是为了性能考虑,因为这个方法调用次数也不少)

字节数组比较方法:BytesEquals

比较字节数组是否完全相等,方法比较简单,就不做介绍

public static bool BytesEquals(byte[] array1, byte[] array2){ if (array1 == null && array2 == null) return true; if (Array.ReferenceEquals(array1, array2)) return true; if (array1?.Length != array2?.Length) return false; for (int i = 0; i < array1.Length; i++) {  if (array1[i] != array2[i]) return false; } return true;}

重构方法

原始方法(使用StreamWriter)

public static byte[] StringToBytes(string value){ if (value == null) throw new ArgumentNullException(nameof(value)); using (var ms = new System.IO.MemoryStream()) using (var streamWriter = new System.IO.StreamWriter(ms, System.Text.Encoding.UTF8)) {  streamWriter.Write(value);  streamWriter.Flush();  return ms.ToArray(); }}

重构(使用Encoidng)

public static byte[] StringToBytes(string value){ if (value == null) throw new ArgumentNullException(nameof(value)); return System.Text.Encoding.UTF8.GetBytes(value);}

单元测试

  • BytesEquals 单元测试
  1. 新建单元测试项目
dotnet new xunit -n 'Demo.StreamWriter.UnitTests' 
  1. 编写单元测试
[Fact]public void BytesEqualsTest_Equals_ReturnTrue(){ ...}[Fact]public void BytesEqualsTest_NotEquals_ReturnFalse(){ ...}[Fact]public void StringToBytes_Equals_ReturnTrue(){ ...}
  1. 执行单元测试
dotnet test
  1. StringToBytes_Equals_ReturnTrue 未能通过单元测试

这个未能通过,重构后的生成的字节数组与原始不一致

排查过程

  1. 调试StringToBytes_Equals_ReturnTrue , 发现bytesWithStreambytesWithEncoding 在数组头多了三个字节(很多人都能猜到这个是UTF8的BOM)
+ bytesWithStream[0] = 239+ bytesWithStream[1] = 187+ bytesWithStream[2] = 191bytesWithStream[3] = 72bytesWithStream[4] = 101bytesWithEncoding[0] = 72bytesWithEncoding[0] = 101

不了解BOM,可以看看这篇文章Byte order mark

从文章可以明确多出来字节就是UTF8-BOM,问题来了,为什么StreamWriter会多出来BOM,而Encoding.UTF8 没有,都是用同一个编码

查看源码

StreamWriter

public StreamWriter(Stream stream) : this(stream, UTF8NoBOM, 1024, leaveOpen: false){}public StreamWriter(Stream stream, Encoding encoding) : this(stream, encoding, 1024, leaveOpen: false){}
private static Encoding UTF8NoBOM => EncodingCache.UTF8NoBOM;internal static readonly Encoding UTF8NoBOM = new UTF8Encoding(encoderShouldEmitUTF8Identifier: false, throwOnInvalidBytes: true);

可以看到StreamWriter, 默认是使用UTF8NoBOM , 但是在这里指定了System.Text.Encoding.UTF8,根据encoderShouldEmitUTF8Identifier这个参数决定是否写入BOM,最终是在Flush写入

private void Flush(bool flushStream, bool flushEncoder){ ... if (!_haveWrittenPreamble) {  _haveWrittenPreamble = true;  ReadOnlySpan<byte> preamble = _encoding.Preamble;  if (preamble.Length > 0)  {   _stream.Write(preamble);  } } int bytes = _encoder.GetBytes(_charBuffer, 0, _charPos, _byteBuffer, 0, flushEncoder); _charPos = 0; if (bytes > 0) {  _stream.Write(_byteBuffer, 0, bytes); } ...}

Flush最终也是使用_encoder.GetBytes获取字节数组写入流中,而System.Text.Encoding.UTF8.GetBytes()最终也是使用这个方法。

System.Text.Encoding.UTF8.GetBytes

public virtual byte[] GetBytes(string s){ if (s == null) {  throw new ArgumentNullException("s", SR.ArgumentNull_String); } int byteCount = GetByteCount(s); byte[] array = new byte[byteCount]; int bytes = GetBytes(s, 0, s.Length, array, 0); return array; }

如果要达到和原来一样的效果,只需要在最终返回结果加上UTF8.Preamble, 修改如下

public static byte[] StringToBytes(string value){ if (value == null) throw new ArgumentNullException(nameof(value));- return System.Text.Encoding.UTF8.GetBytes(value);+ var bytes = System.Text.Encoding.UTF8.GetBytes(value);+ var result = new byte[bytes.Length + 3];+ Array.Copy(Encoding.UTF8.GetPreamble(), result, 3);+ Array.Copy(bytes, 0, result, 3, bytes.Length);+ return result;}

但是对于这样修改感觉是没必要,因为这个最终是传给一个对外接口,所以只能对那个接口做测试,最终结果也是不需要这个BOM

基准测试

排除了StreamWriter没有做特殊处理,可以用System.Text.Encoding.UTF8.GetBytes()重构。还有就是效率问题,虽然直观上看到使用StreamWriter 最终都是使用Encoder.GetBytes 方法,而且还多了两次资源对申请和释放。但是还是用基准测试才能直观看出其中差别。
基准测试使用BenchmarkDotNet,BenchmarkDotNet这里之前有介绍过

  1. 创建BenchmarksTests目录并创建基准项目
mkdir BenchmarksTests && cd BenchmarksTests && dotnet new benchmark -b StreamVsEncoding
  1. 添加引用
dotnet add reference ../../src/Demo.StreamWriter.csproj

注意:Demo.StreamWriter需要Release编译

  1. 编写基准测试
[SimpleJob(launchCount: 10)][MemoryDiagnoser]public class StreamVsEncoding{ [Params("Hello Wilson!", "使用【BenchmarkDotNet】基准测试,Encoding vs Stream")] public string _stringValue; [Benchmark] public void Encoding() => StringToBytesWithEncoding.StringToBytes(_stringValue); [Benchmark] public void Stream() => StringToBytesWithStream.StringToBytes(_stringValue);}
  1. 编译 && 运行基准测试
dotnet build && sudo dotnet benchmark bin/Release/netstandard2.0/BenchmarksTests.dll --filter 'StreamVsEncoding'

注意:macos 需要sudo权限

  1. 查看结果
Method_stringValueMeanErrorStdDevMedianGen 0Gen 1Gen 2Allocated
EncodingHello Wilson!107.4 ns0.61 ns2.32 ns106.9 ns0.0355--112 B
StreamHello Wilson!565.1 ns4.12 ns18.40 ns562.3 ns1.8196--5728 B
Encoding使用【Be(...)tream [42]166.3 ns1.00 ns3.64 ns165.4 ns0.0660--208 B
Stream使用【Be(...)tream [42]584.6 ns3.65 ns13.22 ns580.8 ns1.8349--5776 B

执行时间相差了4~5倍, 内存使用率相差 20 ~ 50倍,差距还比较大。

总结

  1. StreamWriter 默认是没有BOM,若指定System.Text.Encoding.UTF8,会在Flush字节数组开头添加BOM
  2. 字符串转换字节数组使用System.Text.Encoding.UTF8.GetBytes 要高效
  3. System.Text.Encoding.UTF8.GetBytes 是不会自己添加BOM,提供Encoding.UTF8.GetPreamble()获取BOM
  4. UTF8 已经不推荐推荐在前面加BOM

转发请标明出处:https://www.cnblogs.com/WilsonPan/p/13524885.html
示例代码

【Net】StreamWriter.Write 的一点注意事项铭宣亚马逊政策剖析及欧洲VAT税务最新解读FBA实战疫情之下!日亚卖家如何应对客户对商品安全性的质疑亚马逊运营QA集锦(764-773)海外大卖总结在eBay上进行国际销售的7个关键技巧,快来Get!2017五一放假几号到几号?如何安排?预防H7N9禽流感,饮食应注意哪些事项?H7N9蔓延,五一出游应该注意什么?

No comments:

Post a Comment