0

以下のようなTestCompressという関数を定義しました。

処理の流れ

  • 長さlのbyte型の配列bytesにランダムな値を書き込む
  • DeflateStreamで圧縮してデータをcompressedBytesに格納
  • 圧縮されたデータをDeflateStreamを使用して展開し、decompressedBytesに格納
  • bytesとdecompressedBytesを比較し、異なっていた場合は例外をスローする

変数lの値を変えて複数回実行したところ、ターゲットフレームワークが.NET5.0の時は正常に終了しますが、.NET6.0に変更して実行するとlの値が9000を超えたあたりで例外がスローされます。

これは.NET5.0から.NET6.0にバージョンが変わったことでDeflateStreamの動作が何か変わったのでしょうか?

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

public static void TestCompress()
{
    var r = new Random();
    int l = 7000;
    var bytes = new byte[l];
    r.NextBytes(bytes);
    byte[] compressedBytes;
    using (var memSt1 = new MemoryStream())
    {
        using (var comp = new DeflateStream(memSt1, CompressionLevel.Optimal, true))
        {
            comp.Write(bytes, 0, l);
        }
        compressedBytes = memSt1.ToArray();
    }

    var decompressedBytes = new byte[l];
    using (var memSt2 = new MemoryStream(compressedBytes))
    {
        using (var decomp = new DeflateStream(memSt2, CompressionMode.Decompress, true))
        {
            decomp.Read(decompressedBytes, 0, l);
        }
    }

    for (int i = 0; i < l; i++)
    {
        if (decompressedBytes[i] != bytes[i])
        {
            throw new Exception();
        }
    }
}
2

1 件の回答 1

0

原因は、kunifさんが紹介されている通り

で説明されています。NetworkStreamなどと同様に、1回のリクエストで要求したバイト数全てが返されるとは限りません。

期待するサイズが得られるまでリクエストを繰り返す必要があります。ちょうどBinaryReader.ReadBytesがそれをやってくれます。

public static void TestCompress() {
    var r = new Random();
    int l = 7000;
    var bytes = new byte[l];
    r.NextBytes(bytes);

    byte[] compressedBytes;
    {
        using var memSt1 = new MemoryStream();
        using var comp = new DeflateStream(memSt1, CompressionLevel.Optimal, true);
        comp.Write(bytes, 0, l);
        compressedBytes = memSt1.ToArray();
    }

    byte[] decompressedBytes;
    {
        using var memSt2 = new MemoryStream(compressedBytes);
        using var decomp = new DeflateStream(memSt2, CompressionMode.Decompress, true);
        using var reader = new BinaryReader(decomp, Encoding.UTF8, true);
        decompressedBytes = reader.ReadBytes(l);
    }

    if (!bytes.SequenceEqual(decompressedBytes))
        throw new Exception();
}
1
  • ありがとうございます。BinaryReader.ReadBytesを使用したら解決しました。
    – examg
    2022年5月23日 21:54

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。