Потоковая передача содержимого из файла lz4 с использованием InputStreamReader — Stream Corrupted — Java

Я пытаюсь передать данные из сжатого файла lz4 и записать их в StringBuilder. Но я получаю исключение "Поток поврежден". Ниже мой код.

    import java.io.ByteArrayInputStream;
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.nio.charset.StandardCharsets;
    import net.jpountz.lz4.LZ4BlockInputStream;
    import org.apache.commons.io.FileUtils;
    
          public class Lz4TestRead {
        
            public static void main(String[] args) throws IOException {
                byte[] data = FileUtils.readFileToByteArray(new File("D:\\sparker\\input\\payload.lz4"));
                try(ByteArrayInputStream bis = new ByteArrayInputStream(data);
                    LZ4BlockInputStream lz4BlockInputStream = new LZ4BlockInputStream(bis)) {
                    InputStreamReader streamReader = new InputStreamReader(lz4BlockInputStream, StandardCharsets.UTF_8);
                    StringBuilder sb = new StringBuilder();
                    while (true) {
                        int read = streamReader.read();
                        if (read < 0) {
                            break;
                        }
                        sb.append((char) read);
                    }
                    streamReader.close();
                    System.out.println(sb.toString());
        
                }catch (Exception ex) {
                    ex.printStackTrace();
                }
        
        
            }
        }

Я получаю исключение ниже

java.io.IOException: Stream is corrupted
    at net.jpountz.lz4.LZ4BlockInputStream.refill(LZ4BlockInputStream.java:202)
    at net.jpountz.lz4.LZ4BlockInputStream.read(LZ4BlockInputStream.java:157)
    at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
    at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
    at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)
    at sun.nio.cs.StreamDecoder.read0(StreamDecoder.java:127)
    at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:112)
    at java.io.InputStreamReader.read(InputStreamReader.java:168)
    at com.test.Lz4TestRead.main(Lz4TestRead.java:21)

Может ли кто-нибудь помочь мне, что я делаю неправильно.


java compression lz4
person user2731629    schedule 02.12.2020    source источник
comment
Возможно, этот пост поможет вам stackoverflow. ком/вопросы/36012183/   -  person Octavian R.    schedule 02.12.2020

Ответы (1)


arrow_upward
1
arrow_downward

Этот код работает нормально

ОБНОВЛЕНИЕ: обновлен код, чтобы учесть первый комментарий

import net.jpountz.lz4.LZ4BlockInputStream;
import net.jpountz.lz4.LZ4BlockOutputStream;

import java.io.*;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Path;

public class Lz4TestRead {

    public static void main(String[] args) throws IOException {

        //generate an LZ4 encrypted file
        byte[] buf = new byte[1024];
        try (LZ4BlockOutputStream out = new LZ4BlockOutputStream(new FileOutputStream("/tmp/text.lz4"), 1024);
             ByteArrayInputStream in = new ByteArrayInputStream("hello world this is a LZ4 compressed text".getBytes())) {
            int len;
            while ((len = in.read(buf)) > 0) {
                out.write(buf, 0, len);
            }
        }

        StringBuilder sb = new StringBuilder();
        try (ByteArrayInputStream bis = new ByteArrayInputStream(Files.readAllBytes(Path.of("/tmp/text.lz4")));
             LZ4BlockInputStream lz4BlockInputStream = new LZ4BlockInputStream(bis);
             InputStreamReader streamReader = new InputStreamReader(lz4BlockInputStream, StandardCharsets.UTF_8)) {
            while (true) {
                int read = streamReader.read();
                if (read < 0) {
                    break;
                }
                sb.append((char) read);
            }
        }

        System.out.println(sb.toString());

    }
}

Но имейте в виду, что вы должны сжимать данные с помощью LZ4BlockOutputStream, чтобы иметь возможность распаковать их с помощью LZ4BlockInputStream.

person Octavian R.    schedule 02.12.2020
comment
Для меня я должен использовать ByteArrayInputStream. Итак, я читаю файл как BytearrayInputStream и пытаюсь его прочитать. он по-прежнему выдает такое же исключение в lz4BlockInputStream.read(buf). А также я использовал правильный файл lz4. А еще у меня есть потребность читать посимвольно. Вот почему я использовал InpuytStreamReader. - person user2731629; 02.12.2020
comment
Я вижу, тогда я обновил код, чтобы использовать ваш способ. - person Octavian R.; 02.12.2020
comment
Похоже, проблема с моим файлом lz4. Спасибо за вашу помощь. - person user2731629; 02.12.2020