标签：

1 文章范围

本文将.netcore新出现的与Buffer操作相关的类型进行简单分析与讲解，由于资料有限，一些见解为个人见解，可能不是很准确。这些新类型将包括BinaryPrimitives、Span<>，Memory<>，ArrayPool<>，Memorypool<>

2 BinaryPrimitives

在网络传输中，最小单位是byte，很多场景，我们需要将int long short等类型与byte[]相互转换。比如，将int转换为BigEndian的4个字节，在过去，我们很容易就想到BitConverter，但BitConverter设计得不够好友，BitConverter.GetBytes(int value)得到的byte[]的字节顺序永远与主机的字节顺序一样，我们不得不再根据BitConverter的IsLittleEndian属性判断是否需要对得到byte[]进行转换字节顺序，而BinaryPrimitives的Api设计为严格区分Endian，每个Api都指定了目标Endian。

BitConverter

var intValue = 1; var bytes = BitConverter.GetBytes(intValue); if (BitConverter.IsLittleEndian == true) { Array.Reverse(bytes); }

BinaryPrimitives

var intValue = 1; var bytes = new byte[sizeof(int)]; BinaryPrimitives.WriteInt32BigEndian(bytes, intValue); 3 Span<>

Span是一个高效的连续内存范围操作值类型，我们知道Array是一个连接的内存范围的引用类型，那为什么还需要Span类型呢？可以简单这么认为：Span除了提供更高性能的Array的读写功能之外，还提供了比ArraySegment更易于理解和使用的内存局部视图，也就是说Span功能包含了Array+ArraySegment的功能，我可以使用BenchmarkDotNet对比Span、Array和指针读写一个连接内存的性能比较，测试结果为Span>Pointer>Array：

读写代码

public class DemoContext { private byte[] array = new byte[1024]; [Benchmark] public void ByteArray() { for (var i = 0; i < array.Length; i++) { array[i] = array[i]; } } [Benchmark] public void ByteSpan() { var span = array.AsSpan(); for (var i = 0; i < span.Length; i++) { span[i] = span[i]; } } [Benchmark] unsafe public void BytePointer() { fixed (byte* pointer = &array[0]) { for (var i = 0; i < array.Length; i++) { *(pointer + i) = *(pointer + i); } } } }

Benchmark报告

| Method | Mean | Error | StdDev | |------------ |---------:|--------:|--------:| | ByteArray | 577.4 ns | 9.07 ns | 8.48 ns | | ByteSpan | 323.8 ns | 0.87 ns | 0.81 ns | | BytePointer | 499.4 ns | 4.09 ns | 3.82 ns | Memory<>

如果尝试将Span<>作为全局变量，或在异步方法声明为变量，你会得到编译器的错误，原因不在本文讲解范围内，而Memory<>类型可以满足这些需求，Memory<>提供了用于数据读写的Span属性，这个Span属性是每将获取时都有一些计算，所以我们应该尽量避免多次获取它的Span属性。

合理的获取Span

var span = memory.Span; for (var i = 0; i < span.Length; i++) { span[i] = span[i]; }

不合理的获取Span

for (var i = 0; i < memory.Length; i++) { memory.Span[i] = memory.Span[i]; }

Benchmark报告

| Method | Mean | Error | StdDev | |------------ |-----------:|---------:|---------:| | ByteMemory1 | 325.8 ns | 1.03 ns | 0.97 ns | | ByteMemory2 | 3,344.9 ns | 11.91 ns | 11.14 ns | ArrayPool<>

ArrayPool<>用于解决频繁申请内存和释放内存导致GC压力过大的场景，比如System.Text.Json在序列对象时为utf8的byte[]时，事先是无法计算最终byte[]的长度的，过程中可能要不断申请和调整缓冲区的大小。在没有ArrayPool加持的情况下，高频次的序列化，则会生产高频创建byte[]的过程，随之GC压力也会增大。ArrayPool的设计逻辑是，从pool申请一个指定最小长度的缓冲区，缓冲区在不需要的时候，将其返回到pool里，待以重复利用。

var pool = ArrayPool<byte>.Shared; var buffer = pool.Rent(1024); // 开始利用buffer // ... // 使用结束 pool.Return(buffer);

Rent用于申请，实际上是租赁，Return是归还，返回到池中。我们可以使用IDisposable接口来包装Return功能，使用上更方便一些：

/// <summary> /// 定义数组持有者的接口 /// </summary> /// <typeparam name="T"></typeparam> public interface IArrayOwner<T> : IDisposable { /// <summary> /// 获取持有的数组 /// </summary> T[] Array { get; } /// <summary> /// 获取数组的有效长度 /// </summary> int Count { get; } } /// <summary> /// 表示共享的数组池 /// </summary> public static class ArrayPool { /// <summary> /// 租赁数组 /// </summary> /// <typeparam name="T">元素类型</typeparam> /// <param name="minLength">最小长度</param> /// <returns></returns> public static IArrayOwner<T> Rent<T>(int minLength) { return new ArrayOwner<T>(minLength); } /// <summary> /// 表示数组持有者 /// </summary> /// <typeparam name="T"></typeparam> [DebuggerDisplay("Count = {Count}")] [DebuggerTypeProxy(typeof(ArrayOwnerDebugView<>))] private class ArrayOwner<T> :IDisposable, IArrayOwner<T> { /// <summary> /// 获取持有的数组 /// </summary> public T[] Array { get; } /// <summary> /// 获取数组的有效长度 /// </summary> public int Count { get; } /// <summary> /// 数组持有者 /// </summary> /// <param name="minLength"></param> public ArrayOwner(int minLength) { this.Array = ArrayPool<T>.Shared.Rent(minLength); this.Count = minLength; } /// <summary> /// 归还数组 /// </summary> Public void Dispose() { ArrayPool<T>.Shared.Return(this.Array); } } /// <summary> /// 调试视图 /// </summary> /// <typeparam name="T"></typeparam> private class ArrayOwnerDebugView<T> { [DebuggerBrowsable(DebuggerBrowsableState.RootHidden)] public T[] Items { get; } /// <summary> /// 调试视图 /// </summary> /// <param name="owner"></param> public ArrayOwnerDebugView(IArrayOwner<T> owner) { this.Items = owner.Array.AsSpan(0, owner.Count).ToArray(); } } }

改造之后的使用

using var buffer = ArrayPool.Rent<byte>(1024); // 尽情的使用buffer吧，自动回收 Memorypool<>