C# メモリ ストリームの拡張不可の問題をどのように解決するか

C#では、MemoryStream はデフォルトでは拡張不可であり、大量のデータ書き込み時にメモリ不足が発生する可能性があります。この問題に対処するための1つの方法は、必要に応じてメモリサイズを動的に拡張できるMemoryStreamの拡張子클래스である、ExpandableMemoryStreamを使用することです。

以下に、拡張可能なメモリストリームの簡単なサンプルコードを示します。

public class ExpandableMemoryStream : Stream
{
private byte[] buffer;
private int position;
private int length;
public ExpandableMemoryStream()
{
buffer = new byte[4096]; // 初始大小为4KB
position = 0;
length = 0;
}
public override bool CanRead => true;
public override bool CanSeek => true;
public override bool CanWrite => true;
public override long Length => length;
public override long Position
{
get => position;
set => position = (int)value;
}
public override void Flush()
{
// 无需实现
}
public override int Read(byte[] buffer, int offset, int count)
{
int bytesRead = Math.Min(count, length - position);
Array.Copy(this.buffer, position, buffer, offset, bytesRead);
position += bytesRead;
return bytesRead;
}
public override long Seek(long offset, SeekOrigin origin)
{
switch (origin)
{
case SeekOrigin.Begin:
position = (int)offset;
break;
case SeekOrigin.Current:
position += (int)offset;
break;
case SeekOrigin.End:
position = length - (int)offset;
break;
}
return position;
}
public override void SetLength(long value)
{
if (value <= length)
{
length = (int)value;
if (position > length)
position = length;
}
else
{
int newSize = (int)value;
byte[] newBuffer = new byte[newSize];
Array.Copy(buffer, newBuffer, length);
buffer = newBuffer;
length = newSize;
}
}
public override void Write(byte[] buffer, int offset, int count)
{
int newPosition = position + count;
if (newPosition > this.buffer.Length)
{
int newSize = Math.Max(newPosition, this.buffer.Length * 2);
byte[] newBuffer = new byte[newSize];
Array.Copy(this.buffer, newBuffer, position);
this.buffer = newBuffer;
}
Array.Copy(buffer, offset, this.buffer, position, count);
position = newPosition;
length = Math.Max(position, length);
}
}

拡張可能メモリ ストリームは、メモリ ストリームと同じように読み書きができます。ただし、メモリ不足を気にせずに済みます。拡張可能メモリ ストリームに書き込まれるデータ量が現在のメモリ サイズを超えると、自動的にメモリ サイズが拡張されて、さらに多くのデータが書き込まれるようになります。

ExpandableMemoryStream stream = new ExpandableMemoryStream();
byte[] data = new byte[8192]; // 假设有8KB数据需要写入
stream.Write(data, 0, data.Length);
// 读取数据
byte[] buffer = new byte[4096];
int bytesRead = stream.Read(buffer, 0, buffer.Length);

これにより、C#のメモリ ストリームが拡張不可能なという問題が解決します。