Как дописать к сжатому файлу дополнительную информацию

Question

Есть метод, этот метод на вход получает массив данных определенного размера, сжимает его и возвращает массив уже сжатых данных. Вот код:

 public byte[] Compres(byte[] dataBytes)// метод для сжатия
        {
            using (var CompresStream=new MemoryStream())// создаем поток мемористрим
            {
                using (var gzStream=new GZipStream(CompresStream,CompressionMode.Compress))
                {
                    gzStream.Write(dataBytes,0,dataBytes.Length);
                    gzStream.Close();
                    return CompresStream.ToArray();
                }
            }
        }

Мне нужно, чтобы на выходе из метода была структура данных такая [номер блока=4байта][размер сжатых данных=4 байта][сами сжатые данные] Подскажите пожалуйста как правильно это сделать, я новичек, умом понимаю как но как реализовать пока не очень хорошо понимаю.

Answer 1

Я решал эту задачу так:

• создавал две очереди, в которых хранил пары значений (номер_блока, байты_данных_этого_блока) Queue<KeyValuePair<int, byte[]>>;
• в первую очередь я читал файл поблочно, потом брал оттуда блоки для компрессии/декомпрессии и помещах их во вторую очередь;
• а уже из второй очереди писал их в файл.

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

Queue<KeyValuePair<int, byte[]>> - из такой структуры мне было просто получить номер блока, узнать его размер и записать последовательно все данные в файл.

Answer 2

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

Никакого задела на будущую многопоточность тут не предусмотрено.

using System;
using System.IO;
using System.IO.Compression;

namespace ConApp1
{
    class Program
    {
        static void Main(string[] args)
        {
            try
            {
                using (var inFileStream = new FileStream("input.dat", FileMode.Open))
                using (var outFileStream = new FileStream("output.dat", FileMode.Create))
                using (var binaryWriter = new BinaryWriter(outFileStream))
                {
                    var uncompressed = new byte[100000];
                    int blockNumber = 0;

                    while (true)
                    {
                        int length = inFileStream.Read(uncompressed, 0, uncompressed.Length);
                        if (length == 0)
                            break;

                        var compressed = Compres(uncompressed, length);

                        binaryWriter.Write(blockNumber);
                        binaryWriter.Write(compressed.Length);
                        binaryWriter.Write(compressed);

                        //Console.WriteLine(length + "\t" + blockNumber + "\t" + compressed.Length);
                        blockNumber++;
                    }
                }
            }
            catch (Exception ex) { Console.WriteLine(ex); }
        }

        static byte[] Compres(byte[] dataBytes, int length)
        {
            using (var compresStream = new MemoryStream())
            {
                using (var gzStream = new GZipStream(compresStream, CompressionMode.Compress))
                {
                    gzStream.Write(dataBytes, 0, length);
                }
                return compresStream.ToArray();
            }
        }
    }
}