StreamReader ReadToEnd() возвращает пустую строку при первой попытке

Я знаю, что этот вопрос задавался ранее в Stackoverflow, но не смог найти объяснения.

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

Пример кода:

public static string Decompress(byte[] gzBuffer)
{
    if (gzBuffer == null)
        return null;
    using (var ms = new MemoryStream(gzBuffer))
    {
        using (var decompress = new GZipStream(ms, CompressionMode.Decompress))
        {
            using (var sr = new StreamReader(decompress, Encoding.UTF8))
            {
                string ret = sr.ReadToEnd();
                // this is the extra check that is needed !?
                if (ret == "")
                    ret = sr.ReadToEnd();
                return ret;
            }
        }
    }
}

Все предложения приветствуются. - Виктор Кассель

Ответы

Ответ 1

Я нашел ошибку. Это было так, как предложил Майкл в рутине сжатия. Я пропустил вызов Close() в GZipStream.

public static byte[] Compress(string text)
{
    if (string.IsNullOrEmpty(text))
        return null;

    byte[] raw = Encoding.UTF8.GetBytes(text);
    using (var ms = new MemoryStream())
    {
        using (var compress = new GZipStream (ms, CompressionMode.Compress))
        {
            compress.Write(raw, 0, raw.Length);
            compress.Close();

            return ms.ToArray();
        }
    } 
}

Случилось так, что данные, казалось, были сохранены в плохом состоянии, в результате чего в процессе декомпрессии в течение двух раз потребовались два вызова ReadToEnd() для извлечения тех же данных. Очень странно!

Ответ 2

Откуда gzBuffer? Вы также писали код, который создает сжатые данные?

Возможно, данные буфера, которые у вас есть, являются недопустимыми или как-то неполными, или, возможно, состоят из нескольких потоков спускаемых потоков, объединенных вместе.

Ответ 3

попробуйте добавить ms.Position = 0 до string ret = sr.ReadToEnd();

Ответ 4

Страница MSDN в функции упоминает следующее:

Если текущий метод выдает исключение OutOfMemoryException, позиция читателя в базовом объекте Stream увеличивается на количество символов, которые метод смог прочитать, но символы, уже прочитанные во внутреннем буфере ReadLine, отбрасываются. Если вы манипулируете положением базового потока после считывания данных в буфер, позиция базового потока может не соответствовать положению внутреннего буфера. Для reset внутреннего буфера вызовите метод DiscardBufferedData; однако этот метод замедляет работу и должен быть вызван только тогда, когда это абсолютно необходимо.

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

Ответ 5

Надеюсь, это поможет.

Для ByteArray:

static byte[] CompressToByte(string data)
{
    MemoryStream outstream = new MemoryStream();
    GZipStream compressionStream =
    new GZipStream(outstream, CompressionMode.Compress, true);
    StreamWriter writer = new StreamWriter(compressionStream);
    writer.Write(data);
    writer.Close();
    return StreamToByte(outstream);
}

static string Decompress(byte[] data)
{
    MemoryStream instream = new MemoryStream(data);
    GZipStream compressionStream =
    new GZipStream(instream, CompressionMode.Decompress);
    StreamReader reader = new StreamReader(compressionStream);
    string outtext = reader.ReadToEnd();
    reader.Close();
    return outtext;
}

public static byte[] StreamToByte(Stream stream)
{
    stream.Position = 0;
    byte[] buffer = new byte[128];
    using (MemoryStream ms = new MemoryStream())
    {
        while (true)
        {
            int read = stream.Read(buffer, 0, buffer.Length);
            if (!(read > 0))
                return ms.ToArray();
            ms.Write(buffer, 0, read);
        }
    }
}

Вы можете заменить if(!(read > 0)) на if(read <= 0). По какой-то причине if(read <= 0) не отображается выше.

Для потока:

static Stream CompressToStream(string data)
{
    MemoryStream outstream = new MemoryStream();
    GZipStream compressionStream =
    new GZipStream(outstream, CompressionMode.Compress, true);
    StreamWriter writer = new StreamWriter(compressionStream);
    writer.Write(data);
    writer.Close();
    return outstream;
}

static string Decompress(Stream data)
{
    data.Position = 0;
    GZipStream compressionStream =
    new GZipStream(data, CompressionMode.Decompress);
    StreamReader reader = new StreamReader(compressionStream);
    string outtext = reader.ReadToEnd();
    reader.Close();
    return outtext;
}