Как скопировать содержимое одного потока в другой?

Начиная с .NET 4.5, есть Stream.CopyToAsync метод

input.CopyToAsync(output);

Это вернет Task, который можно продолжить после завершения, например:

await input.CopyToAsync(output)

// Code from here on will be run in a continuation.

Обратите внимание, что в зависимости от того, где выполняется вызов CopyToAsync, следующий код может продолжаться или не продолжаться в том же потоке, который его вызвал.

SynchronizationContext, который был захвачен при вызове await, будет определять, в каком потоке будет выполняться продолжение.

Кроме того, этот вызов (и это деталь реализации, которая может быть изменена) по-прежнему выполняет последовательность операций чтения и записи (он просто не тратит впустую потоки, блокирующие завершение ввода-вывода).

Начиная с .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? Потому что эта длина может быть недоступна! Из документы:

If a class derived from Stream does not support seeking, calls to Length, SetLength, Position, and Seek throw a NotSupportedException.

К сожалению, действительно простого решения не существует. Вы можете попробовать что-то вроде этого:

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 может вести себя по-разному, если читать нечего. Поток, читающий файл с локального жесткого диска, вероятно, будет заблокирован до тех пор, пока операция чтения не прочитает достаточно данных с диска, чтобы заполнить буфер, и вернет меньше данных, только если он достигнет конца файла. С другой стороны, поток, считываемый из сети, может возвращать меньше данных, даже если для получения осталось больше данных.

Всегда проверяйте документацию конкретного класса потока, который вы используете, прежде чем использовать универсальное решение.

Основные вопросы, которые отличают реализации CopyStream:

• размер буфера чтения
• размер записей
• Можем ли мы использовать более одного потока (запись, пока мы читаем).

Ответы на эти вопросы приводят к совершенно разным реализациям CopyStream и зависят от того, какие потоки у вас есть и что вы пытаетесь оптимизировать. «Лучшая» реализация даже должна знать, на каком конкретном оборудовании потоки читают и записывают.

Возможно, есть способ сделать это более эффективно, в зависимости от того, с каким потоком вы работаете. Если вы можете преобразовать один или оба своих потока в MemoryStream, вы можете использовать метод GetBuffer для работы непосредственно с массивом байтов, представляющим ваши данные. Это позволяет вам использовать такие методы, как Array.CopyTo, которые абстрагируют все проблемы, поднятые fryguybob. Вы можете просто доверять .NET, чтобы знать оптимальный способ копирования данных.

если вы хотите, чтобы процедура скопировала поток в другой, тот, который опубликовал ник, в порядке, но в нем отсутствует сброс позиции, он должен быть

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

На самом деле существует менее жесткий способ копирования потока. Однако обратите внимание, что это означает, что вы можете хранить весь файл в памяти. Не пытайтесь использовать это, если вы работаете с файлами, размер которых превышает сотни мегабайт, без осторожности.

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

ПРИМЕЧАНИЕ. Также могут возникнуть проблемы с двоичными данными и кодировками символов.

Я использую следующие методы расширения. Они оптимизировали перегрузки для случаев, когда одним потоком является MemoryStream.

    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);
    }

MemoryStream имеет .WriteTo(outstream);

а .NET 4.0 имеет .CopyTo в обычном потоковом объекте.

.NET 4.0:

instream.CopyTo(outstream);

Поскольку ни один из ответов не охватывал асинхронный способ копирования из одного потока в другой, вот шаблон, который я успешно использовал в приложении переадресации портов для копирования данных из одного сетевого потока в другой. В нем отсутствует обработка исключений, чтобы подчеркнуть шаблон.

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 Framework 4 представляет новый метод CopyTo класса Stream пространства имен System.IO. Используя этот метод, мы можем скопировать один поток в другой поток другого класса.

Вот пример для этого.

    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/>");

Для .NET 3.5 и до этого попробуйте:

MemoryStream1.WriteTo(MemoryStream2);

Легко и безопасно - создайте новый поток из первоисточника:

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

Следующий код для решения проблемы скопируйте Stream в MemoryStream с помощью CopyTo

Stream stream = new MemoryStream();

// любая функция требует ввода потока. В моем случае, чтобы сохранить файл PDF как поток document.Save (поток);

MemoryStream newMs = (MemoryStream)stream;

byte[] getByte = newMs.ToArray();

// Примечание - разместите поток в блоке finally, а не в блоке using, так как он выдаст ошибку «Доступ запрещен, поскольку поток закрыт»