如何将一个流的内容复制到另一个流

本文关键字：复制 另一个 一个 | 更新日期: 2023-09-27 17:47:22

将一个流的内容复制到另一个流的最佳方法是什么？是否有标准的实用程序方法？

如何将一个流的内容复制到另一个流

从 .NET 4.5 开始，有Stream.CopyToAsync方法 

input.CopyToAsync(output);

这将返回一个完成后可以继续的Task，如下所示：

await input.CopyToAsync(output)
// Code from here on will be run in a continuation.

请注意，根据调用CopyToAsync的位置，后面的代码可能会也可能不会在调用它的同一线程上继续。

调用await时捕获的SynchronizationContext将确定将在哪个线程上执行延续。

此外，此调用（这是可能会更改的实现细节）仍然对读取和写入进行序列（它只是不会在 I/O 完成时浪费线程阻塞）。

从 .NET 4.0 开始，他们的方法是Stream.CopyTo的方法

input.CopyTo(output);

适用于 .NET 3.5 及更早版本

框架中没有任何内容可以帮助解决这个问题;你必须手动复制内容，如下所示：

public static void CopyStream(Stream input, Stream output)
{
    byte[] buffer = new byte[32768];
    int read;
    while ((read = input.Read(buffer, 0, buffer.Length)) > 0)
    {
        output.Write (buffer, 0, read);
    }
}

注意1：此方法将允许您报告进度（到目前为止已读取的x字节...
注2：为什么使用固定缓冲区大小而不是input.Length？因为那个长度可能不可用！从文档中：

如果从 Stream 派生的类不支持查找，则对 Length、SetLength、Position 和 Seek 的调用将引发 NotSupportedException。

MemoryStream .WriteTo(outstream);

并且 .NET 4.0 在普通流对象上具有.CopyTo。

.NET 4.0：

instream.CopyTo(outstream);

我使用以下扩展方法。它们优化了当一个流是内存流时的重载。

    public static void CopyTo(this Stream src, Stream dest)
    {
        int size = (src.CanSeek) ? Math.Min((int)(src.Length - src.Position), 0x2000) : 0x2000;
        byte[] buffer = new byte[size];
        int n;
        do
        {
            n = src.Read(buffer, 0, buffer.Length);
            dest.Write(buffer, 0, n);
        } while (n != 0);           
    }
    public static void CopyTo(this MemoryStream src, Stream dest)
    {
        dest.Write(src.GetBuffer(), (int)src.Position, (int)(src.Length - src.Position));
    }
    public static void CopyTo(this Stream src, MemoryStream dest)
    {
        if (src.CanSeek)
        {
            int pos = (int)dest.Position;
            int length = (int)(src.Length - src.Position) + pos;
            dest.SetLength(length); 
            while(pos < length)                
                pos += src.Read(dest.GetBuffer(), pos, length - pos);
        }
        else
            src.CopyTo((Stream)dest);
    }
.

NET Framework 4 引入了 System.IO 命名空间的 Stream Class 的新"CopyTo"方法。使用这种方法，我们可以将一个流复制到另一个不同流类的流。

这是这方面的示例。

    FileStream objFileStream = File.Open(Server.MapPath("TextFile.txt"), FileMode.Open);
    Response.Write(string.Format("FileStream Content length: {0}", objFileStream.Length.ToString()));
    MemoryStream objMemoryStream = new MemoryStream();
    // Copy File Stream to Memory Stream using CopyTo method
    objFileStream.CopyTo(objMemoryStream);
    Response.Write("<br/><br/>");
    Response.Write(string.Format("MemoryStream Content length: {0}", objMemoryStream.Length.ToString()));
    Response.Write("<br/><br/>");

实际上，有一种不那么繁重的流复制方法。但是请注意，这意味着您可以将整个文件存储在内存中。如果您正在处理数百兆字节或更多的文件，请不要尝试使用它，而不会小心。

public static void CopySmallTextStream(Stream input, Stream output)
{
  using (StreamReader reader = new StreamReader(input))
  using (StreamWriter writer = new StreamWriter(output))
  {
    writer.Write(reader.ReadToEnd());
  }
}

注意：还可能存在一些有关二进制数据和字符编码的问题。

区分"CopyStream"实现的基本问题是：

  • 读取缓冲区的大小
  • 写入的大小
  • 我们可以使用多个线程（在阅读时写入）吗？

这些问题的答案会导致 CopyStream 的实现大不相同，并且取决于您拥有的流类型以及您尝试优化的内容。 "最佳"实现甚至需要知道流正在读取和写入哪些特定硬件。

不幸的是，没有真正简单的解决方案。你可以尝试这样的事情：

Stream s1, s2;
byte[] buffer = new byte[4096];
int bytesRead = 0;
while (bytesRead = s1.Read(buffer, 0, buffer.Length) > 0) s2.Write(buffer, 0, bytesRead);
s1.Close(); s2.Close();

但是问题在于，如果没有什么可读取的，则 Stream 类的不同实现可能会有不同的行为。从本地硬盘驱动器读取文件的流可能会阻塞，直到读取操作从磁盘读取足够的数据来填充缓冲区，并且仅在到达文件末尾时才返回较少的数据。另一方面，从网络读取的流可能会返回更少的数据，即使还有更多的数据需要接收。

在使用通用解决方案之前，请始终检查正在使用的特定流类的文档。

可能有一种方法可以更有效地执行此操作，具体取决于您正在使用的流类型。 如果可以将一个或两个流转换为内存流，则可以使用 GetBuffer 方法直接处理表示数据的字节数组。 这允许您使用像Array.CopyTo这样的方法，这些方法抽象出fryguybob提出的所有问题。 你可以相信 .NET 知道复制数据的最佳方式。

如果您希望将流复制到其他流，Nick 发布的流很好，但它缺少位置重置，它应该是

public static void CopyStream(Stream input, Stream output)
{
    byte[] buffer = new byte[32768];
    long TempPos = input.Position;
    while (true)    
    {
        int read = input.Read (buffer, 0, buffer.Length);
        if (read <= 0)
            return;
        output.Write (buffer, 0, read);
    }
    input.Position = TempPos;// or you make Position = 0 to set it at the start
}

但是，如果它在运行时不使用您使用内存流的过程

Stream output = new MemoryStream();
byte[] buffer = new byte[32768]; // or you specify the size you want of your buffer
long TempPos = input.Position;
while (true)    
{
    int read = input.Read (buffer, 0, buffer.Length);
    if (read <= 0)
        return;
    output.Write (buffer, 0, read);
 }
    input.Position = TempPos;// or you make Position = 0 to set it at the start

由于没有一个答案涵盖从一个流复制到另一个流的异步方式，因此这是我在端口转发应用程序中成功使用的一种模式，将数据从一个网络流复制到另一个网络流。它缺少异常处理来强调模式。

const int BUFFER_SIZE = 4096;
static byte[] bufferForRead = new byte[BUFFER_SIZE];
static byte[] bufferForWrite = new byte[BUFFER_SIZE];
static Stream sourceStream = new MemoryStream();
static Stream destinationStream = new MemoryStream();
static void Main(string[] args)
{
    // Initial read from source stream
    sourceStream.BeginRead(bufferForRead, 0, BUFFER_SIZE, BeginReadCallback, null);
}
private static void BeginReadCallback(IAsyncResult asyncRes)
{
    // Finish reading from source stream
    int bytesRead = sourceStream.EndRead(asyncRes);
    // Make a copy of the buffer as we'll start another read immediately
    Array.Copy(bufferForRead, 0, bufferForWrite, 0, bytesRead);
    // Write copied buffer to destination stream
    destinationStream.BeginWrite(bufferForWrite, 0, bytesRead, BeginWriteCallback, null);
    // Start the next read (looks like async recursion I guess)
    sourceStream.BeginRead(bufferForRead, 0, BUFFER_SIZE, BeginReadCallback, null);
}
private static void BeginWriteCallback(IAsyncResult asyncRes)
{
    // Finish writing to destination stream
    destinationStream.EndWrite(asyncRes);
}

对于 .NET 3.5 及之前的版本，请尝试：

MemoryStream1.WriteTo(MemoryStream2);

简单安全 - 从原始源制作新流：

    MemoryStream source = new MemoryStream(byteArray);
    MemoryStream copy = new MemoryStream(byteArray);

以下代码来解决此问题，请使用 CopyTo 将流复制到内存流

Stream stream = new MemoryStream();

任何函数都需要输入流。在我的情况下将PDF文件另存为流公文。保存（流）;

MemoryStream newMs = (MemoryStream)stream;
byte[] getByte = newMs.ToArray();

注意 - 请将流丢弃在 finally 块中而不是内部使用块，因为它会抛出错误"流关闭时访问被拒绝"

相关文章：